DotNext.Net.Cluster by .NET Foundation and Contributors

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

---

API Diff between 4.13.0 and 4.7.2

63 Additions 29 Removals

DotNext.Diagnostics

• public interface IFailureDetector : IResettable
  • bool IsHealthy { get; }
  • bool IsMonitoring { get; }
  • void ReportHeartbeat()
• public class PhiAccrualFailureDetector : IFailureDetector, IResettable, ISupplier<double>, IFunctional<Func<double>>
  • public TimeSpan AcceptableHeartbeatPause { get; set; }
  • public bool IsHealthy { get; }
  • public bool IsMonitoring { get; }
  • public int MaxSampleSize { get; set; }
  • public TimeSpan MinStdDeviation { get; set; }
  • public double Threshold { get; set; }
  • public bool TreatUnknownValueAsUnhealthy { get; set; }
  • public double Value { get; }
  • public event Action<TimeSpan> SuspiciousIntervalGrowth
  • public PhiAccrualFailureDetector(TimeSpan estimatedFirstHeartbeat)
  • public double GetValue(Timestamp ts)
  • public void ReportHeartbeat()
  • public void ReportHeartbeat(Timestamp ts)
  • public void Reset()

DotNext.Net.Cluster

• public interface ICluster : IPeerMesh<IClusterMember>, IPeerMesh
  • Task<bool> ResignAsync(CancellationToken token)
  • Task<IClusterMember> WaitForLeaderAsync(TimeSpan timeout, CancellationToken token = default)
  • ValueTask<bool> ResignAsync(CancellationToken token = default)
  • ValueTask<IClusterMember> WaitForLeaderAsync(TimeSpan timeout, CancellationToken token = default)

DotNext.Net.Cluster.Consensus.Raft

• public struct EmptyLogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject
  • public bool IsSnapshot { get; }
• public interface IRaftCluster : IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh, IPeerMesh<IRaftClusterMember>
  • protected const string LocalAddressMeterAttributeName = "dotnext.raft.server.address"
• public interface IRaftClusterMember : IClusterMember, IPeer
  • protected const string MessageTypeAttributeName = "dotnext.raft.client.message"
  • protected const string RemoteAddressMeterAttributeName = "dotnext.raft.client.address"
• public class RaftCluster : RaftCluster<RaftClusterMember>, ILocalMember
  • public Task<bool> AddMemberAsync(ClusterMemberId id, EndPoint address, CancellationToken token = default)
  • public Task<bool> AddMemberAsync(EndPoint address, CancellationToken token = default)
• public abstract class RaftCluster<TMember> : Disposable, IUnresponsiveClusterMemberRemovalSupport, IRaftCluster, IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh, IPeerMesh<IRaftClusterMember>, IStandbyModeSupport, IRaftStateMachine<TMember>, IRaftStateMachine, IAsyncDisposable where TMember : IRaftClusterMember, IDisposable
  • public Func<TimeSpan, TMember, IFailureDetector> FailureDetectorFactory { get; set; }
  • public ClusterMemberId& modreq(System.Runtime.InteropServices.InAttribute) LocalMemberId { get; }
  • public bool Standby { get; }
  • protected RaftCluster(IClusterMemberConfiguration config, ref TagList measurementTags)
  • protected Task<Result<bool>> AppendEntriesAsync<TEntry>(ClusterMemberId sender, long senderTerm, ILogEntryProducer<TEntry> entries, long prevLogIndex, long prevLogTerm, long commitIndex, IClusterConfiguration config, bool applyConfig, CancellationToken token) where TEntry : IRaftLogEntry
  • protected ValueTask<Result<bool>> AppendEntriesAsync<TEntry>(ClusterMemberId sender, long senderTerm, ILogEntryProducer<TEntry> entries, long prevLogIndex, long prevLogTerm, long commitIndex, IClusterConfiguration config, bool applyConfig, CancellationToken token) where TEntry : IRaftLogEntry
  • protected abstract ValueTask<bool> DetectLocalMemberAsync(TMember candidate, CancellationToken token)
  • public Task ForceReplicationAsync(CancellationToken token = default)
  • protected Task<Result<bool>> InstallSnapshotAsync<TSnapshot>(ClusterMemberId sender, long senderTerm, TSnapshot snapshot, long snapshotIndex, CancellationToken token) where TSnapshot : IRaftLogEntry
  • protected Task<Result<PreVoteResult>> PreVoteAsync(ClusterMemberId sender, long nextTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • public ValueTask<bool> EnableStandbyModeAsync(CancellationToken token = default)
  • public ValueTask ForceReplicationAsync(CancellationToken token = default)
  • protected ValueTask<Result<bool>> InstallSnapshotAsync<TSnapshot>(ClusterMemberId sender, long senderTerm, TSnapshot snapshot, long snapshotIndex, CancellationToken token) where TSnapshot : IRaftLogEntry
  • protected ValueTask<Result<PreVoteResult>> PreVoteAsync(ClusterMemberId sender, long nextTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • public Task<bool> RemoveMemberAsync<TAddress>(ClusterMemberId id, IClusterConfigurationStorage<TAddress> configurationStorage, CancellationToken token = default)
  • public Task<bool> ReplicateAsync<TEntry>(TEntry entry, CancellationToken token) where TEntry : IRaftLogEntry
  • protected Task<bool> ResignAsync(CancellationToken token)
  • protected Task<bool> RemoveMemberAsync<TAddress>(ClusterMemberId id, IClusterConfigurationStorage<TAddress> configurationStorage, Func<TMember, TAddress> addressProvider, CancellationToken token = default)
  • public ValueTask<bool> ReplicateAsync<TEntry>(TEntry entry, CancellationToken token) where TEntry : IRaftLogEntry
  • protected ValueTask<bool> ResignAsync(CancellationToken token)
  • public ValueTask<bool> RevertToNormalModeAsync(CancellationToken token = default)
  • protected Task<long?> SynchronizeAsync(long commitIndex, CancellationToken token)
  • protected ValueTask<long?> SynchronizeAsync(long commitIndex, CancellationToken token)
  • protected Task<Result<bool>> VoteAsync(ClusterMemberId sender, long senderTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • protected virtual ValueTask UnavailableMemberDetected(TMember member, CancellationToken token)
  • protected ValueTask<Result<bool>> VoteAsync(ClusterMemberId sender, long senderTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)

DotNext.Net.Cluster.Consensus.Raft.Extensions

• public interface IStandbyModeSupport : IRaftCluster, IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh, IPeerMesh<IRaftClusterMember>
  • bool Standby { get; }
  • ValueTask<bool> EnableStandbyModeAsync(CancellationToken token = default)
  • ValueTask<bool> RevertToNormalModeAsync(CancellationToken token = default)
• public interface IUnresponsiveClusterMemberRemovalSupport : IRaftCluster, IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh, IPeerMesh<IRaftClusterMember>

DotNext.Net.Cluster.Consensus.Raft.Membership

• public struct ClusterConfigurationEvent<TAddress>
• public abstract class ClusterConfigurationStorage<TAddress> : Disposable, IClusterConfigurationStorage<TAddress>, IClusterConfigurationStorage, IDisposable
  • public abstract ValueTask<bool> AddMemberAsync(ClusterMemberId id, TAddress address, CancellationToken token = default)
  • public event Func<TAddress, bool, CancellationToken, ValueTask> ActiveConfigurationChanged
  • protected abstract ValueTask<bool> AddMemberAsync(TAddress address, CancellationToken token = default)
  • public abstract ValueTask<bool> RemoveMemberAsync(ClusterMemberId id, CancellationToken token = default)
  • protected abstract ValueTask<bool> RemoveMemberAsync(TAddress address, CancellationToken token = default)
• public sealed delegate ClusterMemberAnnouncer<TAddress> : MulticastDelegate
  • public virtual IAsyncResult BeginInvoke(ClusterMemberId id, TAddress address, CancellationToken token, AsyncCallback callback, object object)
  • public virtual IAsyncResult BeginInvoke(TAddress address, IReadOnlyDictionary<string, string> metadata, CancellationToken token, AsyncCallback callback, object object)
  • public virtual Task Invoke(ClusterMemberId id, TAddress address, CancellationToken token)
  • public virtual Task Invoke(TAddress address, IReadOnlyDictionary<string, string> metadata, CancellationToken token)
• public interface IClusterConfigurationStorage<TAddress> : IClusterConfigurationStorage, IDisposable
  • IReadOnlyDictionary<ClusterMemberId, TAddress> ActiveConfiguration { get; }
  • IReadOnlyDictionary<ClusterMemberId, TAddress> ProposedConfiguration { get; }
  • ValueTask<bool> AddMemberAsync(ClusterMemberId id, TAddress address, CancellationToken token = default)
  • IAsyncEnumerable<ClusterConfigurationEvent<TAddress>> PollChangesAsync(CancellationToken token = default)
  • ValueTask<bool> RemoveMemberAsync(ClusterMemberId id, CancellationToken token = default)
  • IReadOnlySet<TAddress> ActiveConfiguration { get; }
  • IReadOnlySet<TAddress> ProposedConfiguration { get; }
  • event Func<TAddress, bool, CancellationToken, ValueTask> ActiveConfigurationChanged
  • ValueTask<bool> AddMemberAsync(TAddress address, CancellationToken token = default)
  • ValueTask<bool> RemoveMemberAsync(TAddress address, CancellationToken token = default)
• public abstract class InMemoryClusterConfigurationStorage<TAddress> : ClusterConfigurationStorage<TAddress>
  • protected InMemoryClusterConfigurationStorage(MemoryAllocator<byte> allocator = null)
  • public bool AddMember(ClusterMemberId id, TAddress address)
  • protected InMemoryClusterConfigurationStorage(IEqualityComparer<TAddress> comparer = null, MemoryAllocator<byte> allocator = null)
  • public bool AddMember(TAddress address)
  • public bool RemoveMember(ClusterMemberId id)
  • public bool RemoveMember(TAddress address)
• public abstract class PersistentClusterConfigurationStorage<TAddress> : ClusterConfigurationStorage<TAddress>, IAsyncDisposable
  • protected PersistentClusterConfigurationStorage(string path, int fileBufferSize = 512, MemoryAllocator<byte> allocator = null)
  • protected PersistentClusterConfigurationStorage(string path, int fileBufferSize = 512, IEqualityComparer<TAddress> comparer = null, MemoryAllocator<byte> allocator = null)

DotNext.Net.Cluster.Replication

• public interface IReplicationCluster : ICluster, IPeerMesh<IClusterMember>, IPeerMesh
  • Task ForceReplicationAsync(CancellationToken token = default)
  • ValueTask ForceReplicationAsync(CancellationToken token = default)
• public interface IReplicationCluster<TEntry> : IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh where TEntry : ILogEntry
  • Task<bool> ReplicateAsync<TEntryImpl>(TEntryImpl entry, CancellationToken token = default) where TEntryImpl : TEntry
  • ValueTask<bool> ReplicateAsync<TEntryImpl>(TEntryImpl entry, CancellationToken token = default) where TEntryImpl : TEntry