Class MemoryBasedStateMachine.SnapshotBuilder

Represents snapshot builder.

Inheritance

object

Disposable

MemoryBasedStateMachine.SnapshotBuilder

MemoryBasedStateMachine.IncrementalSnapshotBuilder

MemoryBasedStateMachine.InlineSnapshotBuilder

Implements

IDisposable

Inherited Members

Disposable.IsDisposed

Disposable.IsDisposing

Disposable.IsDisposingOrDisposed

Disposable.DisposedTask

Disposable.GetDisposedTask<T>()

Disposable.TrySetDisposedException<T>(TaskCompletionSource<T>)

Disposable.TrySetDisposedException(TaskCompletionSource)

Disposable.Dispose(bool)

Disposable.DisposeAsyncCore()

Disposable.DisposeAsync()

Disposable.TryBeginDispose()

Disposable.Dispose()

Disposable.Dispose(IEnumerable<IDisposable>)

Disposable.DisposeAsync(IEnumerable<IAsyncDisposable>)

Disposable.Dispose(ReadOnlySpan<IDisposable>)

Disposable.DisposeAsync(params IAsyncDisposable[])

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: DotNext.Net.Cluster.Consensus.Raft

Assembly: DotNext.Net.Cluster.dll

Syntax

protected abstract class MemoryBasedStateMachine.SnapshotBuilder : Disposable, IDisposable

Methods

AdjustIndex(long, long, ref long)

Allows to adjust the index of the current log entry to be snapshotted.

Declaration

protected virtual void AdjustIndex(long startIndex, long endIndex, ref long currentIndex)

Parameters

Type	Name	Description
long	startIndex	The lower bound of the index, inclusive.
long	endIndex	The upper bound of the index, inclusive.
long	currentIndex	The currently running index.

Remarks

If currentIndex is modified in a way when it out of bounds then snapshot process will be terminated immediately. Moreover, compaction algorithm is optimized for monotonic growth of this index. Stepping back or random access may slow down the process.

ApplyAsync(LogEntry)

Interprets the command specified by the log entry.

Declaration

protected abstract ValueTask ApplyAsync(PersistentState.LogEntry entry)

Parameters

Type	Name	Description
PersistentState.LogEntry	entry	The committed log entry.

Returns

Type	Description
ValueTask	The task representing asynchronous execution of this method.

Implements

IDisposable

Extension Methods

BasicExtensions.As<T>(T)

BasicExtensions.GetUserData<T>(T)

BasicExtensions.IsBetween<T, TLowerBound, TUpperBound>(T, TLowerBound, TUpperBound)

BasicExtensions.IsOneOf<T>(T, ReadOnlySpan<T>)

ExpressionBuilder.Const<T>(T)

AsyncLockAcquisition.AcquireLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireLockAsync<T>(T, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireReadLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireReadLockAsync<T>(T, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, TimeSpan, CancellationToken)

LockAcquisition.AcquireReadLock<T>(T)

LockAcquisition.AcquireReadLock<T>(T, TimeSpan)

LockAcquisition.AcquireUpgradeableReadLock<T>(T)

LockAcquisition.AcquireUpgradeableReadLock<T>(T, TimeSpan)

LockAcquisition.AcquireWriteLock<T>(T)

LockAcquisition.AcquireWriteLock<T>(T, TimeSpan)