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

WriteAsync<TEntryImpl>(ILogEntryProducer<TEntryImpl>, WriteConcern, TimeSpan)

Writes message into the cluster according with the specified concern.

Declaration
Task WriteAsync<TEntryImpl>(ILogEntryProducer<TEntryImpl> entries, WriteConcern concern, TimeSpan timeout)

    where TEntryImpl : TEntry
Parameters
Type Name Description
ILogEntryProducer<TEntryImpl> entries

The number of commands to be committed into the audit trail.

WriteConcern concern

The value describing level of acknowledgment from cluster.

TimeSpan timeout

The timeout of the asynchronous operation.

Returns
Type Description
Task

The task representing asynchronous state of this operation.

Type Parameters
Name Description
TEntryImpl

The actual type of the log entry returned by the supplier.

Remarks

Data isolation level should be implemented by the caller code.

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)
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