Show / Hide Table of Contents

Class PersistentState.SnapshotBuilder

Represents snapshot builder.

Inheritance
Object
PersistentState.SnapshotBuilder
Implements
IRaftLogEntry
ILogEntry
IDataTransferObject
Namespace: DotNext.Net.Cluster.Consensus.Raft
Assembly: DotNext.Net.Cluster.dll
Syntax
protected abstract class SnapshotBuilder : Disposable, IRaftLogEntry, ILogEntry, IDataTransferObject

Constructors

| Improve this Doc View Source

SnapshotBuilder()

Initializes a new snapshot builder.

Declaration
protected SnapshotBuilder()

Methods

| Improve this Doc View Source

ApplyAsync(PersistentState.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.

| Improve this Doc View Source

CopyToAsync(PipeWriter, CancellationToken)

Copies the reduced command into the specified pipe.

Declaration
public abstract ValueTask CopyToAsync(PipeWriter output, CancellationToken token)
Parameters
Type Name Description
PipeWriter output

The write-only representation of the pipe.

CancellationToken token

The token that can be used to cancel the operation.

Returns
Type Description
ValueTask

The task representing asynchronous state of this operation.

| Improve this Doc View Source

CopyToAsync(Stream, CancellationToken)

Copies the reduced command into the specified stream.

Declaration
public abstract Task CopyToAsync(Stream output, CancellationToken token)
Parameters
Type Name Description
Stream output

The write-only stream.

CancellationToken token

The token that can be used to cancel the operation.

Returns
Type Description
Task

The task representing asynchronous state of this operation.

Explicit Interface Implementations

| Improve this Doc View Source

IDataTransferObject.IsReusable

Declaration
bool IDataTransferObject.IsReusable { get; }
Returns
Type Description
Boolean
| Improve this Doc View Source

IDataTransferObject.Length

Declaration
long? IDataTransferObject.Length { get; }
Returns
Type Description
Nullable<Int64>
| Improve this Doc View Source

IRaftLogEntry.Term

Declaration
long IRaftLogEntry.Term { get; }
Returns
Type Description
Int64
| Improve this Doc View Source

ILogEntry.IsSnapshot

Declaration
bool ILogEntry.IsSnapshot { get; }
Returns
Type Description
Boolean
| Improve this Doc View Source

ILogEntry.Timestamp

Declaration
DateTimeOffset ILogEntry.Timestamp { get; }
Returns
Type Description
DateTimeOffset

Implements

IRaftLogEntry
ILogEntry
IDataTransferObject

Extension Methods

AsyncLockAcquisition.AcquireLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireUpgradeableReadLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireUpgradeableReadLockAsync<T>(T, CancellationToken)
DataTransferObject.ReadAsTextAsync(IDataTransferObject, Encoding, CancellationToken)
ExpressionBuilder.Const<T>(T)
ObjectExtensions.GetUserData<T>(T)
ObjectExtensions.IsOneOf<T>(T, IEnumerable<T>)
ObjectExtensions.IsOneOf<T>(T, T[])
ObjectExtensions.Decompose<T, R1, R2>(T, Func<T, R1>, Func<T, R2>, out R1, out R2)
ObjectExtensions.Decompose<T, R1, R2>(T, ValueFunc<T, R1>, ValueFunc<T, R2>, out R1, out R2)
ObjectExtensions.Decompose<T, R1, R2>(T, Func<T, R1>, Func<T, R2>)
ObjectExtensions.Decompose<T, R1, R2>(T, ValueFunc<T, R1>, ValueFunc<T, R2>)
LockAcquisition.AcquireReadLock<T>(T)
LockAcquisition.AcquireReadLock<T>(T, TimeSpan)
LockAcquisition.AcquireWriteLock<T>(T)
LockAcquisition.AcquireWriteLock<T>(T, TimeSpan)
LockAcquisition.AcquireUpgradeableReadLock<T>(T)
LockAcquisition.AcquireUpgradeableReadLock<T>(T, TimeSpan)
  • Improve this Doc
  • View Source
Back to top Generated by DocFX