DotNext.Net.Cluster by Roman Sakno

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

---

API Diff between 3.2.1 and 2.12.0

99 Additions 20 Removals

DotNext.Net.Cluster

• public struct ClusterMemberId : IEquatable<ClusterMemberId>, ISerializable
  • public static ClusterMemberId FromEndPoint(EndPoint ep)
  • public static bool TryParse(string identifier, out ClusterMemberId value)
• public interface IClusterMember
  • IPEndPoint Endpoint { get; }
  • EndPoint EndPoint { get; }

DotNext.Net.Cluster.Consensus.Raft

• 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 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 ElectionTimeout
  • public ElectionTimeout Modify(int lowerValue, int upperValue)
• public struct EmptyEntry : IRaftLogEntry, ILogEntry, IDataTransferObject
• public struct EmptyLogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject
  • public long Term { get; }
  • public DateTimeOffset Timestamp { get; }
  • public EmptyLogEntry(long term)
• public interface IClusterMemberConfiguration
  • bool Standby { get; }
• public interface IPersistentState : IAuditTrail<IRaftLogEntry>, IAuditTrail
  • ValueTask UpdateTermAsync(long term)
  • ValueTask UpdateTermAsync(long term, bool resetLastVote)
• public interface IRaftClusterMember : IClusterMember
  • void CancelPendingRequests()
  • Task<Result<bool>> PreVoteAsync(long term, long lastLogIndex, long lastLogTerm, CancellationToken token)
• public interface IRaftLogEntry : ILogEntry, IDataTransferObject
  • int? CommandId { get; }
• public struct JsonLogEntry<T> : IRaftLogEntry, ILogEntry, IDataTransferObject
  • public T Content { get; }
  • public long Term { get; }
  • public DateTimeOffset Timestamp { get; }
• public class PersistentState : Disposable, IPersistentState, IAuditTrail<IRaftLogEntry>, IAuditTrail, IAsyncDisposable
  • protected struct LogEntry : IRaftLogEntry, ILogEntry, IDataTransferObject, IAsyncBinaryReader
  • public enum CompactionMode
  • public enum LogEntryCacheEvictionPolicy
  • public sealed class MissingPartitionException : IntegrityException
  • public long CompactionCount { get; }
  • public bool IsBackgroundCompaction { get; }
  • public Task<bool> AppendAndEnsureCommitAsync<TEntry>(TEntry entry, TimeSpan timeout, bool addToCache = false, CancellationToken token = default) 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 AppendAsync<TEntry>(TEntry entry, long startIndex, CancellationToken token = default) where TEntry : IRaftLogEntry
  • public ValueTask<long> AppendAsync<TEntry>(ref WriteLockToken writeLock, TEntry entry, bool flush = true, CancellationToken token = default) where TEntry : IRaftLogEntry
  • public ValueTask<long> AppendAsync<TEntry>(TEntry entry, bool addToCache, CancellationToken token = default) where TEntry : IRaftLogEntry
  • public JsonLogEntry<T> CreateJsonLogEntry<T>(T content, string typeId = null, JsonSerializerOptions options = null)
  • public ValueTask<long> DropAsync(long startIndex, CancellationToken token)
  • public ValueTask<long> DropAsync(long startIndex, bool reuseSpace = false, CancellationToken token = default)
  • public ValueTask ForceCompactionAsync(long count, CancellationToken token)
  • 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 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 bool Validate(ref WriteLockToken token)
• public abstract class RaftCluster<TMember> : Disposable, IRaftCluster, IReplicationCluster<IRaftLogEntry>, IReplicationCluster, ICluster, IRaftStateMachine, IAsyncDisposable where TMember : IRaftClusterMember, IDisposable
  • protected sealed delegate MemberCollectionMutator<TMember, T> : MulticastDelegate where TMember : IRaftClusterMember, IDisposable
  • public TimeSpan ElectionTimeout { get; }
  • public event ReplicationCompletedEventHandler ReplicationCompleted
  • protected Task ChangeMembersAsync<T>(MemberCollectionMutator<TMember, T> mutator, T arg, CancellationToken token)
  • public ValueTask DisposeAsync()
  • protected ValueTask<TMember> FindMemberAsync(Func<TMember, CancellationToken, ValueTask<bool>> criteria, CancellationToken token)
  • protected Task<Result<bool>> ReceiveEntries<TEntry>(TMember sender, long senderTerm, ILogEntryProducer<TEntry> entries, long prevLogIndex, long prevLogTerm, long commitIndex) where TEntry : IRaftLogEntry
  • protected Task<bool> ReceiveResign()
  • protected Task<Result<bool>> ReceivePreVoteAsync(long nextTerm, long lastLogIndex, long lastLogTerm, CancellationToken token)
  • protected Task<Result<bool>> ReceiveSnapshot(TMember sender, long senderTerm, IRaftLogEntry snapshot, long snapshotIndex)
  • protected Task<Result<bool>> ReceiveVote(TMember sender, long senderTerm, long lastLogIndex, long lastLogTerm)
  • public ValueTask TurnIntoRegularNodeAsync(CancellationToken token)
• public abstract class RaftClusterMember : Disposable, IRaftClusterMember, IClusterMember
  • public IPEndPoint Endpoint { get; }
  • public EndPoint EndPoint { get; }
  • public virtual void CancelPendingRequests()
• 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()

DotNext.Net.Cluster.Consensus.Raft.Commands

• public sealed class CommandAttribute : Attribute
  • public Type Formatter { get; set; }
  • public string FormatterMember { get; set; }
  • public int Id { get; }
  • public CommandAttribute(int id)
• public class CommandInterpreter : Disposable
  • public sealed class Builder : ISupplier<CommandInterpreter>
  • protected sealed class CommandHandlerAttribute : Attribute
  • public sealed class UnknownCommandException : IntegrityException
  • protected CommandInterpreter()
  • public LogEntry<TCommand> CreateLogEntry<TCommand>(TCommand command, long term) where TCommand : struct
  • public ValueTask<int> InterpretAsync<TEntry>(TEntry entry, CancellationToken token = default) where TEntry : struct, IRaftLogEntry
• public struct LogEntry<TCommand> : IRaftLogEntry, ILogEntry, IDataTransferObject where TCommand : struct
  • public long Term { get; }
  • public DateTimeOffset Timestamp { get; }

DotNext.Net.Cluster.Messaging

• public sealed class JsonMessage<T> : IMessage, IDataTransferObject
  • public T Content { get; }
  • public string Name { get; }
  • 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 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.Replication

• public interface IReplicationCluster : ICluster
  • event ReplicationCompletedEventHandler ReplicationCompleted
  • Task<bool> ForceReplicationAsync(TimeSpan timeout, CancellationToken token = default)
• public interface IReplicationCluster<TEntry> : IReplicationCluster, ICluster where TEntry : ILogEntry
  • Task<bool> ForceReplicationAsync(TimeSpan timeout, CancellationToken token = default)
• 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.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