DotNext.Net.Cluster by Roman Sakno

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

---

API Diff between 2.12.1 and 4.15.2

96 Additions 161 Removals

DotNext.Diagnostics

• public interface IFailureDetector : IResettable
• public class PhiAccrualFailureDetector : IFailureDetector, IResettable, ISupplier<double>, IFunctional<Func<double>>

DotNext.Net

• public static class EndPointFormatter
• public interface IPeer
• public interface IPeerMesh
• public interface IPeerMesh<TPeer> : IPeerMesh where TPeer : IPeer
• public abstract class PeerEventArgs : EventArgs

DotNext.Net.Cluster

• public class ClusterMemberEventArgs : PeerEventArgs
• public sealed delegate ClusterChangedEventHandler : MulticastDelegate
  • public ClusterChangedEventHandler(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(ICluster cluster, IClusterMember member, AsyncCallback callback, object object)
  • public virtual void EndInvoke(IAsyncResult result)
  • public virtual void Invoke(ICluster cluster, IClusterMember member)
• public sealed delegate ClusterLeaderChangedEventHandler : MulticastDelegate
  • public ClusterLeaderChangedEventHandler(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(ICluster cluster, IClusterMember leader, AsyncCallback callback, object object)
  • public virtual void EndInvoke(IAsyncResult result)
  • public virtual void Invoke(ICluster cluster, IClusterMember leader)
• public struct ClusterMemberId : IEquatable<ClusterMemberId>, ISerializable
  • public static int Size { get; }
  • public ClusterMemberId(Random random)
  • public ClusterMemberId(ref SpanReader reader)
  • public static ClusterMemberId FromEndPoint(EndPoint ep)
  • public static bool TryParse(string identifier, out ClusterMemberId value)
  • public void Format(ref SpanWriter writer)
• public class ClusterMemberStatusChangedEventArgs : ClusterMemberEventArgs
• public class ClusterMemberStatusChangedEventArgs<TMember> : ClusterMemberStatusChangedEventArgs where TMember : IClusterMember
• public sealed delegate ClusterMemberStatusChanged : MulticastDelegate
  • public ClusterMemberStatusChanged(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(IClusterMember member, ClusterMemberStatus previousStatus, ClusterMemberStatus newStatus, AsyncCallback callback, object object)
  • public virtual void EndInvoke(IAsyncResult result)
  • public virtual void Invoke(IClusterMember member, ClusterMemberStatus previousStatus, ClusterMemberStatus newStatus)
• public interface ICluster
  • event Action<ICluster, IClusterMember> LeaderChanged
  • ValueTask<bool> ResignAsync(CancellationToken token = default)
  • ValueTask<IClusterMember> WaitForLeaderAsync(TimeSpan timeout, CancellationToken token = default)
  • IReadOnlyCollection<IClusterMember> Members { get; }
  • event ClusterLeaderChangedEventHandler LeaderChanged
  • Task<bool> ResignAsync(CancellationToken token)
• public interface IClusterMember
  • IPEndPoint Endpoint { get; }
  • event Action<ClusterMemberStatusChangedEventArgs> MemberStatusChanged
  • void OnMemberStatusChanged<TMember>(TMember member, ref AtomicEnum status, ClusterMemberStatus newState, InvocationList<Action<ClusterMemberStatusChangedEventArgs<TMember>>> memberStatusChanged) where TMember : IClusterMember
  • event ClusterMemberStatusChanged MemberStatusChanged
  • void OnMemberStatusChanged(IClusterMember member, ref AtomicEnum status, ClusterMemberStatus newState, ClusterMemberStatusChanged memberStatusChanged)
• public interface IExpandableCluster : ICluster
  • event ClusterChangedEventHandler MemberAdded
  • event ClusterChangedEventHandler MemberRemoved
• public class MemberUnavailableException : IOException
  • public MemberUnavailableException(IClusterMember member, string message)

DotNext.Net.Cluster.Consensus.Raft

• public struct BinaryLogEntry<T> : IBinaryLogEntry, IRaftLogEntry, ILogEntry, IDataTransferObject where T : struct, IBinaryFormattable<T>
• public struct BufferedRaftLogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject, IDisposable
• public struct BufferedRaftLogEntryList : IDisposable, IReadOnlyList<BufferedRaftLogEntry>, IEnumerable<BufferedRaftLogEntry>, IEnumerable, IReadOnlyCollection<BufferedRaftLogEntry>
• public sealed class ConsensusOnlyState : Disposable, IPersistentState, IAuditTrail<IRaftLogEntry>, IAuditTrail
  • public long LastCommittedEntryIndex { get; }
  • public long LastEntryIndex { get; }
  • public ValueTask<TResult> ReadAsync<TResult>(ILogEntryConsumer<IRaftLogEntry, TResult> reader, long startIndex, long endIndex, CancellationToken token)
  • public ValueTask<TResult> ReadAsync<TResult>(ILogEntryConsumer<IRaftLogEntry, TResult> reader, long startIndex, CancellationToken token)
  • public long GetLastIndex(bool committed)
• public abstract class DiskBasedStateMachine : PersistentState
• public struct ElectionTimeout
  • public void Deconstruct(out int lowerValue, out int upperValue)
  • public int RandomTimeout(Random random)
  • public ElectionTimeout(int lowerValue, int upperValue)
  • public ElectionTimeout Modify(int lowerValue, int upperValue)
  • public int RandomTimeout()
• public struct EmptyLogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject
• public enum HeartbeatResult
• public static class ElectionTimeoutExtensions
  • public static void Update(this ref ElectionTimeout timeout, int? lowerValue, int? upperValue)
• public struct EmptyEntry : IRaftLogEntry, ILogEntry, IDataTransferObject
  • public long Term { get; }
  • public DateTimeOffset Timestamp { get; }
  • public EmptyEntry(long term)
• public interface IClusterMemberConfiguration
  • bool AggressiveLeaderStickiness { get; }
  • double ClockDriftBound { get; }
  • IEqualityComparer<EndPoint> EndPointComparer { get; }
  • bool Standby { get; }
• public interface ILeaderLease
• public interface IPersistentState : IAuditTrail<IRaftLogEntry>, IAuditTrail
  • ValueTask EnsureConsistencyAsync(CancellationToken token = default)
  • ValueTask<long> IncrementTermAsync(ClusterMemberId member)
  • bool IsVotedFor(ClusterMemberId& modreq(System.Runtime.InteropServices.InAttribute) id)
  • ValueTask UpdateTermAsync(long term, bool resetLastVote)
  • ValueTask UpdateVotedForAsync(ClusterMemberId member)
  • Task EnsureConsistencyAsync(TimeSpan timeout, CancellationToken token = default)
  • ValueTask<long> IncrementTermAsync()
  • bool IsVotedFor(IRaftClusterMember member)
  • ValueTask UpdateTermAsync(long term)
  • ValueTask UpdateVotedForAsync(IRaftClusterMember member)
• public interface IRaftCluster : IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster
  • protected const string LocalAddressMeterAttributeName = "dotnext.raft.server.address"
  • CancellationToken LeadershipToken { get; }
  • ILeaderLease Lease { get; }
  • IReadOnlyCollection<IRaftClusterMember> Members { get; }
  • Task Readiness { get; }
  • ValueTask ApplyReadBarrierAsync(CancellationToken token = default)
• public interface IRaftClusterMember : IClusterMember
  • protected const string MessageTypeAttributeName = "dotnext.raft.client.message"
  • protected const string RemoteAddressMeterAttributeName = "dotnext.raft.client.address"
  • Task<Result<HeartbeatResult>> AppendEntriesAsync<TEntry, TList>(long term, TList entries, long prevLogIndex, long prevLogTerm, long commitIndex, IClusterConfiguration config, bool applyConfig, CancellationToken token) where TEntry : IRaftLogEntry where TList : IReadOnlyList<TEntry>
  • ref long NextIndex { get; }
  • Task<Result<bool>> AppendEntriesAsync<TEntry, TList>(long term, TList entries, long prevLogIndex, long prevLogTerm, long commitIndex, CancellationToken token) where TEntry : IRaftLogEntry where TList : IReadOnlyList<TEntry>
  • void CancelPendingRequests()
  • Task<Result<HeartbeatResult>> InstallSnapshotAsync(long term, IRaftLogEntry snapshot, long snapshotIndex, CancellationToken token)
  • Task<Result<PreVoteResult>> PreVoteAsync(long term, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • Task<long?> SynchronizeAsync(long commitIndex, CancellationToken token)
  • Task<Result<bool>> InstallSnapshotAsync(long term, IRaftLogEntry snapshot, long snapshotIndex, CancellationToken token)
• public interface IRaftLogEntry : ILogEntry, IDataTransferObject
  • int? CommandId { get; }
• public struct JsonLogEntry<T> : IRaftLogEntry, ILogEntry, IDataTransferObject
• public abstract class MemoryBasedStateMachine : PersistentState
• public class PersistentState : Disposable, IPersistentState, IAuditTrail<IRaftLogEntry>, IAuditTrail, IAsyncDisposable
  • public sealed class InternalStateBrokenException : IntegrityException
  • public sealed class MissingPartitionException : IntegrityException
  • protected struct LogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject, IAsyncBinaryReader
  • public enum WriteMode
  • public long LastCommittedEntryIndex { get; }
  • public long LastEntryIndex { get; }
  • protected DirectoryInfo Location { get; }
  • protected abstract class SnapshotBuilder : Disposable, IRaftLogEntry, ILogEntry, IDataTransferObject
  • public struct WriteLockToken : IDisposable
  • protected Memory<byte> Buffer { get; }
  • public PersistentState(DirectoryInfo path, int recordsPerPartition, Options configuration = null)
  • public PersistentState(string path, int recordsPerPartition, Options configuration = null)
  • public ValueTask AppendAsync<TEntry>(TEntry entry, long startIndex, CancellationToken token = default) where TEntry : IRaftLogEntry
  • public Task<WriteLockToken> AcquireWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<WriteLockToken> AcquireWriteLockAsync(CancellationToken token)
  • public ValueTask AppendAsync<TEntry>(ref WriteLockToken writeLock, TEntry entry, long startIndex) where TEntry : IRaftLogEntry
  • public ValueTask AppendAsync<TEntry>(TEntry entry, long startIndex) where TEntry : IRaftLogEntry
  • public ValueTask<long> AppendAsync<TEntry>(ref WriteLockToken writeLock, TEntry entry, CancellationToken token) where TEntry : IRaftLogEntry
  • public ValueTask<long> AppendAsync<TEntry>(TEntry entry, bool addToCache, CancellationToken token = default) where TEntry : IRaftLogEntry
  • protected virtual Task ClearAsync(CancellationToken token = default)
  • protected virtual ValueTask ApplyAsync(LogEntry entry)
  • public JsonLogEntry<T> CreateJsonLogEntry<T>(T content, string typeId = null, JsonSerializerOptions options = null)
  • public JsonLogEntry<T> CreateJsonLogEntry<T>(T content, string typeId, JsonTypeInfo<T> typeInfo)
  • public void DbgChangeLastIndex(long index)
  • public ValueTask<long> DropAsync(long startIndex, bool reuseSpace = false, CancellationToken token = default)
  • public ValueTask EnsureConsistencyAsync(CancellationToken token)
  • protected virtual SnapshotBuilder CreateSnapshotBuilder()
  • public virtual ValueTask DisposeAsync()
  • public ValueTask<long> DropAsync(long startIndex, CancellationToken token)
  • public Task EnsureConsistencyAsync(TimeSpan timeout, CancellationToken token)
  • protected virtual ValueTask FlushAsync()
  • public long GetLastIndex(bool committed)
  • public ValueTask<TResult> ReadAsync<TResult>(ILogEntryConsumer<IRaftLogEntry, TResult> reader, long startIndex, long endIndex, CancellationToken token = default)
  • public ValueTask<TResult> ReadAsync<TResult>(ILogEntryConsumer<IRaftLogEntry, TResult> reader, long startIndex, CancellationToken token = default)
  • public ValueTask WaitForCommitAsync(CancellationToken token = default)
  • public ValueTask WaitForCommitAsync(long index, CancellationToken token = default)
  • public bool IsValidToken(ref WriteLockToken token)
  • public ValueTask<TResult> ReadAsync<TReader, TResult>(TReader reader, long startIndex, long endIndex, CancellationToken token) where TReader : ILogEntryConsumer<IRaftLogEntry, TResult>
  • public ValueTask<TResult> ReadAsync<TReader, TResult>(TReader reader, long startIndex, CancellationToken token) where TReader : ILogEntryConsumer<IRaftLogEntry, TResult>
  • public Task ReplayAsync(CancellationToken token = default)
  • public Task<bool> WaitForCommitAsync(TimeSpan timeout, CancellationToken token)
  • public Task<bool> WaitForCommitAsync(long index, TimeSpan timeout, CancellationToken token)
• public enum PreVoteResult
• public class RaftCluster : RaftCluster<RaftClusterMember>, ILocalMember
  • public abstract class BuiltInTransportConfiguration : NodeConfiguration
  • public sealed class CustomTransportConfiguration : NodeConfiguration, IConnectionOrientedTransportConfiguration, IClusterMemberConfiguration
  • protected IClusterConfigurationStorage<EndPoint> ConfigurationStorage { get; }
  • public EndPoint LocalMemberAddress { get; }
  • public Task<bool> AddMemberAsync(EndPoint address, CancellationToken token = default)
  • public Task<bool> RemoveMemberAsync(EndPoint address, CancellationToken token = default)
  • protected RaftClusterMember CreateClient(IPEndPoint address)
• public abstract class RaftCluster<TMember> : Disposable, IRaftCluster, IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IRaftStateMachine where TMember : IRaftClusterMember, IDisposable
  • public sealed class ConcurrentMembershipModificationException<TMember> : RaftProtocolException where TMember : IRaftClusterMember, IDisposable
  • protected struct MemberCollectionBuilder<TMember> where TMember : IRaftClusterMember, IDisposable
  • protected sealed delegate MemberCollectionMutator<TMember> : MulticastDelegate where TMember : IRaftClusterMember, IDisposable
  • protected struct MemberHolder<TMember> where TMember : IRaftClusterMember, IDisposable
  • protected abstract IClusterConfigurationStorage ConfigurationStorage { get; }
  • public TimeSpan ElectionTimeout { get; }
  • protected IEqualityComparer<EndPoint> EndPointComparer { get; }
  • public Func<TimeSpan, TMember, IFailureDetector> FailureDetectorFactory { get; set; }
  • public CancellationToken LeadershipToken { get; }
  • public ILeaderLease Lease { get; }
  • protected CancellationToken LifecycleToken { get; }
  • public Task Readiness { get; }
  • public bool Standby { get; }
  • public event Action<RaftCluster<TMember>, TMember> LeaderChanged
  • public event Action<RaftCluster<TMember>, RaftClusterMemberEventArgs<TMember>> MemberAdded
  • public event Action<RaftCluster<TMember>, RaftClusterMemberEventArgs<TMember>> MemberRemoved
  • public event Action<RaftCluster<TMember>, TMember> ReplicationCompleted
  • protected RaftCluster(IClusterMemberConfiguration config)
  • protected RaftCluster(IClusterMemberConfiguration config, ref TagList measurementTags)
  • public ValueTask<bool> AddMemberAsync(TMember member, CancellationToken token)
  • protected Task<bool> AddMemberAsync<TAddress>(TMember member, int rounds, IClusterConfigurationStorage<TAddress> configurationStorage, Func<TMember, TAddress> addressProvider, CancellationToken token = default)
  • protected ValueTask<Result<HeartbeatResult>> AppendEntriesAsync<TEntry>(ClusterMemberId sender, long senderTerm, ILogEntryProducer<TEntry> entries, long prevLogIndex, long prevLogTerm, long commitIndex, IClusterConfiguration config, bool applyConfig, CancellationToken token) where TEntry : IRaftLogEntry
  • public ValueTask ApplyReadBarrierAsync(CancellationToken token = default)
  • protected abstract ValueTask<bool> DetectLocalMemberAsync(TMember candidate, CancellationToken token)
  • public ValueTask DisposeAsync()
  • public ValueTask<bool> EnableStandbyModeAsync(CancellationToken token = default)
  • public ValueTask ForceReplicationAsync(CancellationToken token = default)
  • protected ValueTask<Result<HeartbeatResult>> 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 ValueTask<TMember> RemoveMemberAsync(ClusterMemberId id, 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 CancellationToken Token { get; }
  • public event ClusterLeaderChangedEventHandler LeaderChanged
  • protected RaftCluster(IClusterMemberConfiguration config, out MemberCollectionBuilder members)
  • protected Task ChangeMembersAsync(MemberCollectionMutator<TMember> mutator, CancellationToken token)
  • protected Task ChangeMembersAsync(MemberCollectionMutator<TMember> mutator)
  • protected TMember FindMember(Predicate<TMember> criteria)
  • protected TMember FindMember<TArg>(Func<TMember, TArg, bool> criteria, TArg arg)
  • public Task<bool> ForceReplicationAsync(TimeSpan timeout, CancellationToken token = default)
  • protected Task<Result<bool>> ReceiveEntries<TEntry>(TMember sender, long senderTerm, ILogEntryProducer<TEntry> entries, long prevLogIndex, long prevLogTerm, long commitIndex) where TEntry : IRaftLogEntry
  • protected Task<Result<bool>> ReceiveEntriesAsync<TEntry>(TMember sender, long senderTerm, ILogEntryProducer<TEntry> entries, long prevLogIndex, long prevLogTerm, long commitIndex, CancellationToken token) where TEntry : IRaftLogEntry
  • protected Task<bool> ReceiveResign()
  • protected Task<bool> ReceiveResignAsync(CancellationToken token)
  • protected Task<Result<bool>> ReceiveSnapshot(TMember sender, long senderTerm, IRaftLogEntry snapshot, long snapshotIndex)
  • protected Task<Result<bool>> ReceiveSnapshotAsync<TSnapshot>(TMember sender, long senderTerm, TSnapshot snapshot, long snapshotIndex, CancellationToken token) where TSnapshot : IRaftLogEntry
  • protected Task<Result<bool>> ReceiveVote(TMember sender, long senderTerm, long lastLogIndex, long lastLogTerm)
  • protected Task<Result<bool>> ReceiveVoteAsync(TMember sender, long senderTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • protected void StartFollowing()
  • protected ValueTask<long?> SynchronizeAsync(long commitIndex, CancellationToken token)
  • protected TMember TryGetMember(ClusterMemberId id)
  • public ValueTask TurnIntoRegularNodeAsync(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)
  • public Task<TMember> WaitForLeaderAsync(TimeSpan timeout, CancellationToken token = default)
• public abstract class RaftClusterMember : Disposable, IRaftClusterMember, IClusterMember
  • public EndPoint EndPoint { get; }
  • public IPEndPoint Endpoint { get; }
  • public event Action<ClusterMemberStatusChangedEventArgs<RaftClusterMember>> MemberStatusChanged
  • public event ClusterMemberStatusChanged MemberStatusChanged
  • public virtual void CancelPendingRequests()
• public class RaftClusterMemberEventArgs<TMember> : ClusterMemberEventArgs where TMember : IRaftClusterMember
• public class RaftLogEntriesBufferingOptions : RaftLogEntryBufferingOptions
• public struct RaftLogEntry : IBinaryLogEntry, IRaftLogEntry, ILogEntry, IDataTransferObject
• public class RaftLogEntryBufferingOptions
• public struct Result<T>
  • public long Term { get; set; }
  • public T Value { get; set; }
  • public readonly long Term
  • public readonly T Value
  • public Result(long term, T value)

DotNext.Net.Cluster.Consensus.Raft.Commands

• public abstract class CommandAttribute : Attribute
• public sealed class CommandAttribute<TCommand> : CommandAttribute where TCommand : ISerializable<TCommand>
• public class CommandInterpreter : Disposable, IBuildable<CommandInterpreter, Builder>
• public struct LogEntry<TCommand> : IRaftLogEntry, ILogEntry, IDataTransferObject where TCommand : ISerializable<TCommand>

DotNext.Net.Cluster.Consensus.Raft.Extensions

• public interface IStandbyModeSupport : IRaftCluster, IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh, IPeerMesh<IRaftClusterMember>
• public interface IUnresponsiveClusterMemberRemovalSupport : IRaftCluster, IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh, IPeerMesh<IRaftClusterMember>

DotNext.Net.Cluster.Consensus.Raft.Membership

• public abstract class ClusterConfigurationStorage<TAddress> : Disposable, IClusterConfigurationStorage<TAddress>, IClusterConfigurationStorage, IDisposable
• public sealed delegate ClusterMemberAnnouncer<TAddress> : MulticastDelegate
• public interface IClusterConfiguration : IDataTransferObject
• public interface IClusterConfigurationStorage : IDisposable
• public interface IClusterConfigurationStorage<TAddress> : IClusterConfigurationStorage, IDisposable
• public abstract class InMemoryClusterConfigurationStorage<TAddress> : ClusterConfigurationStorage<TAddress>
• public abstract class PersistentClusterConfigurationStorage<TAddress> : ClusterConfigurationStorage<TAddress>, IAsyncDisposable

DotNext.Net.Cluster.Discovery

• public abstract class DiscoveryProtocolException : ProtocolViolationException

DotNext.Net.Cluster.Discovery.HyParView

• public class HyParViewProtocolException : DiscoveryProtocolException
• public interface IPeerConfiguration
• public abstract class PeerController : Disposable, IPeerMesh, IAsyncDisposable

DotNext.Net.Cluster.Messaging

• public interface IOutputChannel
  • Task<TResponse> SendMessageAsync<TResponse>(IMessage message, CancellationToken token = default) where TResponse : ISerializable<TResponse>
• public sealed class JsonMessage<T> : IMessage, IDataTransferObject
• public abstract class MessageAttribute : Attribute
• public sealed class MessageAttribute<TMessage> : MessageAttribute where TMessage : ISerializable<TMessage>
• public class MessageHandler : IBuildable<MessageHandler, Builder>, IInputChannel
• public class MessagingClient
• public static class Messenger
  • public static Task<TResponse> SendJsonMessageAsync<TRequest, TResponse>(this ISubscriber messenger, MessageReader<TResponse> responseReader, string messageName, TRequest request, CancellationToken token)
  • public static Task SendJsonSignalAsync<TSignal>(this ISubscriber messenger, string messageName, TSignal signal, bool requiresConfirmation = true, CancellationToken token = default)
• public class StreamMessage : StreamTransferObject, IDisposableMessage, IMessage, IDataTransferObject, IDisposable, IAsyncDisposable
  • public StreamMessage(string name, ContentType type, int size = 1024, bool growable = true)

DotNext.Net.Cluster.Messaging.Gossip

• public interface IRumorSender : IAsyncDisposable
• public sealed class RumorSpreadingManager
• public struct RumorTimestamp : IEquatable<RumorTimestamp>, IBinaryFormattable<RumorTimestamp>, IComparable<RumorTimestamp>

DotNext.Net.Cluster.Replication

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

DotNext.Net.ConsistentHash

• public static class JumpHash