DotNext.Net.Cluster by Roman Sakno

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

---

API Diff between 3.2.1 and 5.0.0

161 Additions 145 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 void Format(Span<byte> output)
• 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
  • EndPoint EndPoint { get; }
  • event Action<ClusterMemberStatusChangedEventArgs> MemberStatusChanged
  • void OnMemberStatusChanged<TMember>(TMember member, ref ClusterMemberStatus 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

• public abstract class ConsensusProtocolException : ProtocolViolationException
  • protected ConsensusProtocolException(SerializationInfo info, StreamingContext context)

DotNext.Net.Cluster.Consensus.Raft

• public struct BinaryLogEntry : IBinaryLogEntry, IRaftLogEntry, ILogEntry, IDataTransferObject
• public struct BinaryLogEntry<T> : IBinaryLogEntry, IRaftLogEntry, ILogEntry, IDataTransferObject where T : IBinaryFormattable<T>
• public struct BufferedLogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject, IDisposable
• public struct BufferedLogEntryList : IDisposable, IReadOnlyList<BufferedLogEntry>, IEnumerable<BufferedLogEntry>, IEnumerable, IReadOnlyCollection<BufferedLogEntry>
• public struct BufferedRaftLogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject, IDisposable
  • public bool IsSnapshot { get; }
  • public long Length { get; }
  • public long Term { get; }
  • public DateTimeOffset Timestamp { get; }
  • public static ValueTask<BufferedRaftLogEntry> CopyAsync<TEntry>(TEntry entry, RaftLogEntryBufferingOptions options, CancellationToken token) where TEntry : IRaftLogEntry
  • public void Dispose()
• public struct BufferedRaftLogEntryList : IDisposable, IReadOnlyList<BufferedRaftLogEntry>, IEnumerable<BufferedRaftLogEntry>, IEnumerable, IReadOnlyCollection<BufferedRaftLogEntry>
  • public int Count { get; }
  • public BufferedRaftLogEntry& modreq(System.Runtime.InteropServices.InAttribute) this[int index] { get; }
  • public static Task<BufferedRaftLogEntryList> CopyAsync<TEntry>(ILogEntryProducer<TEntry> producer, RaftLogEntriesBufferingOptions options, CancellationToken token = default) where TEntry : IRaftLogEntry
  • public static Task<BufferedRaftLogEntryList> CopyAsync<TEntry, TList>(TList list, RaftLogEntriesBufferingOptions options, CancellationToken token = default) where TEntry : IRaftLogEntry where TList : IReadOnlyList<TEntry>
  • public void Dispose()
  • public ILogEntryProducer<BufferedRaftLogEntry> ToProducer()
• public sealed class ConsensusOnlyState : Disposable, IPersistentState, IAuditTrail<IRaftLogEntry>, IAuditTrail
  • public long LastCommittedEntryIndex { get; }
  • public long LastEntryIndex { get; }
  • public long Term { 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 ValueTask<TResult> ReadAsync<TResult>(LogEntryConsumer<IRaftLogEntry, TResult> reader, long startIndex, long endIndex, CancellationToken token)
  • public ValueTask<TResult> ReadAsync<TResult>(LogEntryConsumer<IRaftLogEntry, TResult> reader, long startIndex, CancellationToken token)
• 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 int RandomTimeout()
• public static class ElectionTimeoutExtensions
  • public static void Update(this ref ElectionTimeout timeout, int? lowerValue, int? upperValue)
• public struct EmptyLogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject
  • public bool IsSnapshot { get; }
  • public EmptyLogEntry()
  • public EmptyLogEntry(long term)
• public enum HeartbeatResult
• public interface IClusterMemberConfiguration
  • bool AggressiveLeaderStickiness { get; }
  • double ClockDriftBound { get; }
  • IEqualityComparer<EndPoint> EndPointComparer { get; }
  • bool Partitioning { get; }
• public interface IPersistentState : IAuditTrail<IRaftLogEntry>, IAuditTrail
  • ValueTask<long> IncrementTermAsync(ClusterMemberId member)
  • bool IsVotedFor(ClusterMemberId& modreq(System.Runtime.InteropServices.InAttribute) id)
  • Task EnsureConsistencyAsync(TimeSpan timeout, CancellationToken token = default)
  • ValueTask<long> IncrementTermAsync()
  • bool IsVotedFor(IRaftClusterMember member)
  • ValueTask UpdateVotedForAsync(ClusterMemberId member)
  • ValueTask UpdateVotedForAsync(IRaftClusterMember member)
• public interface IRaftCluster : IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster
  • protected const string LocalAddressMeterAttributeName = "dotnext.raft.server.address"
  • CancellationToken LeadershipToken { get; }
  • IReadOnlyCollection<IRaftClusterMember> Members { get; }
  • Task Readiness { get; }
  • ValueTask ApplyReadBarrierAsync(CancellationToken token = default)
  • bool TryGetLeaseToken(out CancellationToken token)
• 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>
  • 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)
  • Task<Result<bool>> PreVoteAsync(long term, long lastLogIndex, long lastLogTerm, CancellationToken token)
• public struct JsonLogEntry<T> : IRaftLogEntry, ILogEntry, IDataTransferObject
  • public JsonLogEntry()
• public class LogEntriesBufferingOptions : LogEntryBufferingOptions
• public class LogEntryBufferingOptions
• public abstract class MemoryBasedStateMachine : PersistentState
• public class MetricsCollector : ILeaderStateMetrics, IFollowerStateMetrics
  • public MetricsCollector()
  • public virtual void MovedToCandidateState()
  • public virtual void MovedToFollowerState()
  • public virtual void MovedToLeaderState()
  • public virtual void ReportBroadcastTime(TimeSpan value)
  • public virtual void ReportHeartbeat()
• public class PersistentState : Disposable, IPersistentState, IAuditTrail<IRaftLogEntry>, IAuditTrail, IAsyncDisposable
  • public sealed class InternalStateBrokenException : IntegrityException
  • public enum CompactionMode
  • public enum LogEntryCacheEvictionPolicy
  • 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 long CompactionCount { get; }
  • public bool IsBackgroundCompaction { get; }
  • public PersistentState(DirectoryInfo path, int recordsPerPartition, Options configuration = null)
  • public PersistentState(string path, int recordsPerPartition, Options configuration = null)
  • public Task<WriteLockToken> AcquireWriteLockAsync(TimeSpan timeout, CancellationToken token = default)
  • public Task<WriteLockToken> AcquireWriteLockAsync(CancellationToken token)
  • public Task<bool> AppendAndEnsureCommitAsync<TEntry>(TEntry entry, TimeSpan timeout, bool addToCache = false, CancellationToken token = default) where TEntry : IRaftLogEntry
  • public ValueTask AppendAsync<TEntry>(ref WriteLockToken writeLock, TEntry entry, long startIndex) where TEntry : IRaftLogEntry
  • public ValueTask<long> AppendAsync<TEntry>(ref WriteLockToken writeLock, TEntry entry, bool flush = true, CancellationToken token = default) where TEntry : IRaftLogEntry
  • protected virtual Task ClearAsync(CancellationToken token = default)
  • protected virtual ValueTask ApplyAsync(LogEntry entry)
  • public BinaryLogEntry CreateBinaryLogEntry(ReadOnlyMemory<byte> content)
  • public BinaryLogEntry<T> CreateBinaryLogEntry<T>(T content) where T : IBinaryFormattable<T>
  • public JsonLogEntry<T> CreateJsonLogEntry<T>(T content) where T : IJsonSerializable<T>
  • public void DbgChangeLastIndex(long index)
  • public JsonLogEntry<T> CreateJsonLogEntry<T>(T content, string typeId = null, JsonSerializerOptions options = null)
  • protected virtual SnapshotBuilder CreateSnapshotBuilder()
  • public ValueTask DisposeAsync()
  • public Task EnsureConsistencyAsync(TimeSpan timeout, CancellationToken token)
  • protected virtual ValueTask FlushAsync()
  • public ValueTask ForceCompactionAsync(long count, CancellationToken token)
  • 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 ValueTask<TResult> ReadAsync<TResult>(LogEntryConsumer<IRaftLogEntry, TResult> reader, long startIndex, long endIndex, CancellationToken token = default)
  • public ValueTask<TResult> ReadAsync<TResult>(LogEntryConsumer<IRaftLogEntry, TResult> reader, long startIndex, CancellationToken token = default)
  • public Task ReplayAsync(CancellationToken token = default)
  • public bool Validate(ref WriteLockToken token)
  • 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 sealed class UdpConfiguration : NodeConfiguration
  • 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, IAsyncDisposable 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 sealed delegate MemberCollectionMutator<TMember, T> : MulticastDelegate where TMember : IRaftClusterMember, IDisposable
  • protected struct MemberHolder<TMember> where TMember : IRaftClusterMember, IDisposable
  • protected abstract IClusterConfigurationStorage ConfigurationStorage { get; }
  • protected IEqualityComparer<EndPoint> EndPointComparer { get; }
  • public Func<TimeSpan, TMember, IFailureDetector> FailureDetectorFactory { get; set; }
  • protected bool IsLeaderLocal { get; }
  • public CancellationToken LeadershipToken { get; }
  • protected CancellationToken LifecycleToken { get; }
  • public Task Readiness { get; }
  • public bool Standby { get; }
  • protected MetricsCollector Metrics { get; set; }
  • 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)
  • protected CancellationToken Token { get; }
  • public event ClusterLeaderChangedEventHandler LeaderChanged
  • public event ReplicationCompletedEventHandler ReplicationCompleted
  • protected RaftCluster(IClusterMemberConfiguration config, out MemberCollectionBuilder members)
  • protected Task ChangeMembersAsync<T>(MemberCollectionMutator<TMember, T> mutator, T arg, CancellationToken token)
  • protected Task ChangeMembersAsync(MemberCollectionMutator<TMember> mutator, CancellationToken token)
  • protected Task ChangeMembersAsync(MemberCollectionMutator<TMember> mutator)
  • 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 TMember FindMember(Predicate<TMember> criteria)
  • protected TMember FindMember<TArg>(Func<TMember, TArg, bool> criteria, TArg arg)
  • protected ValueTask<TMember> FindMemberAsync(Func<TMember, CancellationToken, ValueTask<bool>> criteria, CancellationToken token)
  • public Task<bool> ForceReplicationAsync(TimeSpan timeout, CancellationToken token = default)
  • 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<Result<bool>> ReceivePreVoteAsync(long nextTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • protected Task<bool> ReceiveResignAsync(CancellationToken token)
  • protected Task<Result<bool>> ReceiveSnapshotAsync<TSnapshot>(TMember sender, long senderTerm, TSnapshot snapshot, long snapshotIndex, CancellationToken token) where TSnapshot : IRaftLogEntry
  • 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)
  • public bool TryGetLeaseToken(out CancellationToken token)
  • protected TMember TryGetMember(ClusterMemberId id)
  • 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 ValueTask TurnIntoRegularNodeAsync(CancellationToken token)
• public abstract class RaftClusterMember : Disposable, IRaftClusterMember, IClusterMember
  • public event Action<ClusterMemberStatusChangedEventArgs<RaftClusterMember>> MemberStatusChanged
  • public event ClusterMemberStatusChanged MemberStatusChanged
• public class RaftClusterMemberEventArgs<TMember> : ClusterMemberEventArgs where TMember : IRaftClusterMember
• public class RaftLogEntriesBufferingOptions : RaftLogEntryBufferingOptions
  • public int MemoryLimit { get; set; }
  • public RaftLogEntriesBufferingOptions()
• public class RaftLogEntryBufferingOptions
  • public int BufferSize { get; set; }
  • public MemoryAllocator<byte> MemoryAllocator { get; set; }
  • public int MemoryThreshold { get; set; }
  • public string TempPath { get; set; }
  • public RaftLogEntryBufferingOptions()
• public class RaftProtocolException : ConsensusProtocolException
  • protected RaftProtocolException(SerializationInfo info, StreamingContext context)
• 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 sealed class CommandAttribute : Attribute
  • public Type Formatter { get; set; }
  • public string FormatterMember { get; set; }
• public sealed class CommandAttribute<TCommand> : CommandAttribute where TCommand : ISerializable<TCommand>
• public struct LogEntry<TCommand> : IRaftLogEntry, ILogEntry, IDataTransferObject where TCommand : struct
  • public TCommand Command { get; set; }
  • public int CommandId { get; set; }
  • public LogEntry()

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.Consensus.Raft.Metrics

• public interface IClientMetricsCollector
  • void ReportResponseTime(TimeSpan value)

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 class BinaryMessage : BinaryTransferObject, IMessage, IDataTransferObject
  • public string Name { get; }
  • public ContentType Type { get; }
  • public BinaryMessage(ReadOnlySequence<byte> content, string name, ContentType type = null)
  • public BinaryMessage(ReadOnlyMemory<byte> content, string name, ContentType type = null)
• public class BinaryMessage<T> : BinaryTransferObject<T>, IMessage, IDataTransferObject where T : ValueType modreq(System.Runtime.InteropServices.UnmanagedType)
  • public static readonly MessageReader<T> Reader
  • public string Name { get; }
  • public ContentType Type { get; }
  • public BinaryMessage(string name, ContentType type)
• public interface IOutputChannel
  • Task<TResponse> SendMessageAsync<TResponse>(IMessage message, CancellationToken token = default) where TResponse : ISerializable<TResponse>
• public sealed class JsonMessage<T> : IMessage, IDataTransferObject
  • public JsonMessage()
  • public JsonSerializerOptions Options { get; set; }
  • public JsonMessage(string name, T content)
  • public static ValueTask<T> FromJsonAsync(IDataTransferObject message, JsonSerializerOptions options = null, MemoryAllocator<byte> allocator = null, CancellationToken token = default)
  • public static ValueTask<T> FromJsonAsync(IDataTransferObject message, CancellationToken token = default)
• 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

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)
  • event ReplicationCompletedEventHandler ReplicationCompleted
  • Task<bool> ForceReplicationAsync(TimeSpan timeout, CancellationToken token = default)
• public interface IReplicationCluster<TEntry> : IReplicationCluster, ICluster where TEntry : ILogEntry
  • ValueTask<bool> ReplicateAsync<TEntryImpl>(TEntryImpl entry, CancellationToken token = default) where TEntryImpl : TEntry
• public sealed delegate ReplicationCompletedEventHandler : MulticastDelegate
  • public ReplicationCompletedEventHandler(object object, IntPtr method)
  • public virtual IAsyncResult BeginInvoke(ICluster cluster, IClusterMember source, AsyncCallback callback, object object)
  • public virtual void EndInvoke(IAsyncResult result)
  • public virtual void Invoke(ICluster cluster, IClusterMember source)

DotNext.Net.ConsistentHash

• public static class JumpHash

DotNext.Net.Security

• public class SslOptions
  • public SslOptions(SslServerAuthenticationOptions serverOptions, SslClientAuthenticationOptions clientOptions)

DotNext.Runtime.Serialization

• public interface IFormatter<T>
  • ValueTask<T> DeserializeAsync<TReader>(TReader reader, CancellationToken token) where TReader : IAsyncBinaryReader
  • long? GetLength(T obj)
  • ValueTask SerializeAsync<TWriter>(T obj, TWriter writer, CancellationToken token) where TWriter : IAsyncBinaryWriter