FabricReplicator 类

定义

Replicates state for high availability and reliability.

Remarks:Provides the default implementation of the StateReplicator, Replicator, and PrimaryReplicator interfaces, which user services can use, along with their implementation of the StateProvider interface. An instance of the system.fabric.FabricReplicator class is obtained via the createReplicator(StateProvider stateProvider, ReplicatorSettings replicatorSettings) method, which can be cast to StateReplicator for use.

public class FabricReplicator implements Replicator
继承
java.lang.Object
FabricReplicator

构造函数

FabricReplicator(long replicator)

Creates instance of FabricReplicator.

方法

abort()

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

buildReplicaAsync(ReplicaInformation replicaInfo, CancellationToken cancellationToken)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

changeRoleAsync(Epoch epoch, ReplicaRole role, CancellationToken cancellationToken)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

closeAsync(CancellationToken cancellationToken)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

getCatchUpCapability()

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

getCurrentProgress()

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

onDataLossAsync(CancellationToken cancellationToken)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

openAsync(CancellationToken cancellationToken)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

removeReplica(long replicaId)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

Remarks: This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

updateCatchUpReplicaSetConfiguration(ReplicaSetConfiguration currentConfiguration, ReplicaSetConfiguration previousConfiguration)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

updateCurrentReplicaSetConfiguration(ReplicaSetConfiguration currentConfiguration)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

Remarks: This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

updateEpochAsync(Epoch epoch, CancellationToken cancellationToken)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

waitForCatchUpQuorumAsync(ReplicaSetQuorumMode quorumMode, CancellationToken cancellationToken)

This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

For Internal Use Only.

适用于