DotNext.Net.Cluster by .NET Foundation and Contributors

<PackageReference Include="DotNext.Net.Cluster" Version="4.4.0" />

---

API Diff between 4.4.0 and 4.1.3

27 Additions 5 Removals

DotNext.Net.Cluster.Consensus.Raft

• public struct BinaryLogEntry<T> : IBinaryLogEntry, IRaftLogEntry, ILogEntry, IDataTransferObject where T : struct, IBinaryFormattable<T>
  • public T Content
  • public int? CommandId { get; set; }
  • public long Term { get; set; }
  • public DateTimeOffset Timestamp { get; }
  • public BinaryLogEntry()
• public interface IClusterMemberConfiguration
  • bool AggressiveLeaderStickiness { get; }
• public interface IPersistentState : IAuditTrail<IRaftLogEntry>, IAuditTrail
  • ValueTask<long> IncrementTermAsync()
  • ValueTask<long> IncrementTermAsync(ClusterMemberId member)
• public interface IRaftClusterMember : IClusterMember, IPeer
  • Task<Result<bool>> PreVoteAsync(long term, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • Task<long?> SynchronizeAsync(CancellationToken token)
  • Task<Result<PreVoteResult>> PreVoteAsync(long term, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • Task<long?> SynchronizeAsync(long commitIndex, CancellationToken token)
• public abstract class PersistentState : Disposable, IPersistentState, IAuditTrail<IRaftLogEntry>, IAuditTrail
  • public sealed class InternalStateBrokenException : IntegrityException
  • public enum WriteMode
  • protected virtual Task ClearAsync(CancellationToken token = default)
  • public JsonLogEntry<T> CreateJsonLogEntry<T>(T content, string typeId, JsonTypeInfo<T> typeInfo)
• public enum PreVoteResult
  • Accepted = 1
  • RejectedByFollower = 0
  • RejectedByLeader = 2
• public abstract class RaftCluster<TMember> : Disposable, IRaftCluster, IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh, IPeerMesh<IRaftClusterMember>, IRaftStateMachine, IAsyncDisposable where TMember : IRaftClusterMember, IDisposable
  • protected Task<Result<bool>> PreVoteAsync(long nextTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • protected Task<Result<PreVoteResult>> PreVoteAsync(long nextTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • protected void StartFollowing()
  • protected Task<long?> SynchronizeAsync(CancellationToken token)
  • protected Task<long?> SynchronizeAsync(long commitIndex, CancellationToken token)
• public struct RaftLogEntry : IBinaryLogEntry, IRaftLogEntry, ILogEntry, IDataTransferObject
  • public int? CommandId { get; set; }
  • public ReadOnlyMemory<byte> Content { get; set; }
  • public long Term { get; set; }
  • public DateTimeOffset Timestamp { get; }
  • public RaftLogEntry()