DotNext.Net.Cluster by .NET Foundation and Contributors

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

---

API Diff between 4.13.0 and 5.0.1

92 Additions 30 Removals

DotNext.Net.Cluster

• public struct ClusterMemberId : IEquatable<ClusterMemberId>, IBinaryFormattable<ClusterMemberId>
  • public ClusterMemberId(ref SpanReader reader)
  • public void Format(Span<byte> output)
  • public void Format(ref SpanWriter writer)
• public interface IClusterMember : IPeer
  • void OnMemberStatusChanged<TMember>(TMember member, ref ClusterMemberStatus status, ClusterMemberStatus newState, InvocationList<Action<ClusterMemberStatusChangedEventArgs<TMember>>> memberStatusChanged) where TMember : IClusterMember
  • void OnMemberStatusChanged<TMember>(TMember member, ref AtomicEnum status, ClusterMemberStatus newState, InvocationList<Action<ClusterMemberStatusChangedEventArgs<TMember>>> memberStatusChanged) where TMember : IClusterMember

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 : struct, IBinaryFormattable<T>
  • public T Content
  • public T Content { get; set; }
• 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 LastEntryIndex { get; }
  • public long Term { get; }
  • public long LastUncommittedEntryIndex { 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 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 struct EmptyLogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject
  • public EmptyLogEntry()
  • public EmptyLogEntry(long term)
• public enum HeartbeatResult
• public interface IClusterMemberConfiguration
  • bool Partitioning { get; }
• public interface ILeaderLease
  • bool IsExpired { get; }
  • CancellationToken Token { get; }
• public interface IPersistentState : IAuditTrail<IRaftLogEntry>, IAuditTrail
  • ValueTask EnsureConsistencyAsync(CancellationToken token = default)
• public interface IRaftCluster : IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IPeerMesh<IClusterMember>, IPeerMesh, IPeerMesh<IRaftClusterMember>
  • ILeaderLease Lease { get; }
  • bool TryGetLeaseToken(out CancellationToken token)
• public interface IRaftClusterMember : IClusterMember, IPeer
  • 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 ConfigurationFingerprint { get; }
  • ref long NextIndex { get; }
  • Task<Result<bool>> 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>
  • Task<Result<HeartbeatResult>> InstallSnapshotAsync(long term, IRaftLogEntry snapshot, long snapshotIndex, CancellationToken token)
  • Task<Result<bool>> InstallSnapshotAsync(long term, IRaftLogEntry snapshot, long snapshotIndex, CancellationToken token)
• public struct JsonLogEntry<T> : IRaftLogEntry, ILogEntry, IDataTransferObject
  • public JsonLogEntry()
• public class LogEntriesBufferingOptions : LogEntryBufferingOptions
• public class LogEntryBufferingOptions
• 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 abstract class PersistentState : Disposable, IPersistentState, IAuditTrail<IRaftLogEntry>, IAuditTrail
  • public long LastEntryIndex { get; }
  • public long LastUncommittedEntryIndex { get; }
  • 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 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 ValueTask EnsureConsistencyAsync(CancellationToken token)
  • 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<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 class RaftCluster : RaftCluster<RaftClusterMember>, ILocalMember
  • public sealed class UdpConfiguration : BuiltInTransportConfiguration
• 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
  • protected bool IsLeaderLocal { get; }
  • public ILeaderLease Lease { get; }
  • protected MetricsCollector Metrics { get; set; }
  • 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
  • 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 ValueTask<Result<HeartbeatResult>> InstallSnapshotAsync<TSnapshot>(ClusterMemberId sender, long senderTerm, TSnapshot snapshot, long snapshotIndex, CancellationToken token) where TSnapshot : IRaftLogEntry
  • protected ValueTask<Result<bool>> InstallSnapshotAsync<TSnapshot>(ClusterMemberId sender, long senderTerm, TSnapshot snapshot, long snapshotIndex, CancellationToken token) where TSnapshot : IRaftLogEntry
  • public bool TryGetLeaseToken(out CancellationToken token)
  • public ValueTask TurnIntoRegularNodeAsync(CancellationToken token)
• public class RaftLogEntriesBufferingOptions : RaftLogEntryBufferingOptions
  • public int MemoryLimit { get; set; }
  • public RaftLogEntriesBufferingOptions()
• 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()
• 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 Result(long term, T value)

DotNext.Net.Cluster.Consensus.Raft.Commands

• public struct LogEntry<TCommand> : IRaftLogEntry, ILogEntry, IDataTransferObject where TCommand : ISerializable<TCommand>
  • public LogEntry()

DotNext.Net.Cluster.Consensus.Raft.Metrics

• public interface IClientMetricsCollector
  • void ReportResponseTime(TimeSpan value)

DotNext.Net.Cluster.Discovery

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

DotNext.Net.Cluster.Discovery.HyParView

• public class HyParViewProtocolException : DiscoveryProtocolException
  • protected HyParViewProtocolException(SerializationInfo info, StreamingContext context)

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 sealed class JsonMessage<T> : IMessage, IDataTransferObject
  • public JsonMessage()
  • public JsonSerializerOptions Options { get; set; }
  • public JsonTypeInfo<T> TypeInfo { get; set; }
  • public JsonMessage(string name, T content)
  • public static ValueTask<T> FromJsonAsync(IDataTransferObject message, JsonSerializerOptions options, MemoryAllocator<byte> allocator = null, CancellationToken token = default)
  • public static ValueTask<T> FromJsonAsync(IDataTransferObject message, CancellationToken token = default)
  • public static ValueTask<T> FromJsonAsync(IDataTransferObject message, JsonTypeInfo<T> typeInfo, MemoryAllocator<byte> allocator = null, CancellationToken token = default)

DotNext.Net.Cluster.Messaging.Gossip

• public struct RumorTimestamp : IEquatable<RumorTimestamp>, IBinaryFormattable<RumorTimestamp>, IComparable<RumorTimestamp>
  • public void Format(Span<byte> output)
  • public void Format(ref SpanWriter writer)

DotNext.Net.Security

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