Show / Hide Table of Contents

Interface IReplicationCluster<TEntry>

Represents replication cluster.

Inherited Members
ICluster.Leader
ICluster.Members
ICluster.LeaderChanged
ICluster.ResignAsync(CancellationToken)
Namespace: DotNext.Net.Cluster.Replication
Assembly: DotNext.Net.Cluster.dll
Syntax
public interface IReplicationCluster<TEntry> : IReplicationCluster, ICluster where TEntry : class, ILogEntry
Type Parameters
Name Description
TEntry

The type of the log entry in the transaction log.

Properties

| Improve this Doc View Source

AuditTrail

Gets transaction log used for replication.

Declaration
IAuditTrail<TEntry> AuditTrail { get; }
Property Value
Type Description
IAuditTrail<TEntry>

Methods

| Improve this Doc View Source

ForceReplicationAsync(TimeSpan, CancellationToken)

Forces replication.

Declaration
Task<bool> ForceReplicationAsync(TimeSpan timeout, CancellationToken token = default(CancellationToken))
Parameters
Type Name Description
TimeSpan timeout

The time to wait until replication ends.

CancellationToken token

The token that can be used to cancel waiting.

Returns
Type Description
Task<Boolean>

true if replication is completed; false.

Exceptions
Type Condition
InvalidOperationException

The local cluster member is not a leader.

OperationCanceledException

The operation has been canceled.

Explicit Interface Implementations

| Improve this Doc View Source

IReplicationCluster.AuditTrail

Declaration
IAuditTrail IReplicationCluster.AuditTrail { get; }
Returns
Type Description
IAuditTrail

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)
ObjectExtensions.GetUserData<T>(T)
ObjectExtensions.IsOneOf<T>(T, IEnumerable<T>)
ObjectExtensions.IsOneOf<T>(T, T[])
ObjectExtensions.Decompose<T, TResult1, TResult2>(T, Func<T, TResult1>, Func<T, TResult2>, out TResult1, out TResult2)
ObjectExtensions.Decompose<T, TResult1, TResult2>(T, ValueFunc<T, TResult1>, ValueFunc<T, TResult2>, out TResult1, out TResult2)
ObjectExtensions.Decompose<T, TResult1, TResult2>(T, Func<T, TResult1>, Func<T, TResult2>)
ObjectExtensions.Decompose<T, TResult1, TResult2>(T, ValueFunc<T, TResult1>, ValueFunc<T, TResult2>)
ObjectExtensions.As<T>(T)
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)
ExpressionBuilder.Const<T>(T)
  • Improve this Doc
  • View Source
In This Article
Back to top Generated by DocFX