Replicator Interface

Package:

system.fabric

public interface Replicator extends PrimaryReplicator

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

Method Summary

Modifier and Type	Method and Description
void	abort() This supports the Service Fabric infrastructure and is not meant to be used directly from your code.
CompletableFuture	changeRoleAsync(Epoch epoch, ReplicaRole role, CancellationToken cancellationToken) This supports the Service Fabric infrastructure and is not meant to be used directly from your code.
CompletableFuture	closeAsync(CancellationToken cancellationToken) This supports the Service Fabric infrastructure and is not meant to be used directly from your code.
long	getCatchUpCapability() This supports the Service Fabric infrastructure and is not meant to be used directly from your code.
long	getCurrentProgress() This supports the Service Fabric infrastructure and is not meant to be used directly from your code.
CompletableFuture<String>	openAsync(CancellationToken cancellationToken) This supports the Service Fabric infrastructure and is not meant to be used directly from your code.
CompletableFuture	updateEpochAsync(Epoch epoch, CancellationToken cancellationToken) This supports the Service Fabric infrastructure and is not meant to be used directly from your code.

Inherited Members

PrimaryReplicator.buildReplicaAsync(ReplicaInformation replicaInfo, CancellationToken cancellationToken) PrimaryReplicator.onDataLossAsync(CancellationToken cancellationToken) PrimaryReplicator.removeReplica(long replicaId) PrimaryReplicator.updateCatchUpReplicaSetConfiguration(ReplicaSetConfiguration currentConfiguration, ReplicaSetConfiguration previousConfiguration) PrimaryReplicator.updateCurrentReplicaSetConfiguration(ReplicaSetConfiguration currentConfiguration) PrimaryReplicator.waitForCatchUpQuorumAsync(ReplicaSetQuorumMode quorumMode, CancellationToken cancellationToken)

Method Details

abort

public void abort()

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

changeRoleAsync

public CompletableFuture changeRoleAsync(Epoch epoch, ReplicaRole role, CancellationToken cancellationToken)

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

Parameters:

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

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

cancellationToken - The CancellationToken object that the operation is observing. It can be used to send a notification that the operation should be canceled. Note that cancellation is advisory and that the operation might still be completed even if it is canceled.

Returns:

A future that represents the asynchronous operation. The future completes exceptionally with FabricException for fabric related failures.

closeAsync

public CompletableFuture closeAsync(CancellationToken cancellationToken)

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

Parameters:

cancellationToken - The CancellationToken object that the operation is observing. It can be used to send a notification that the operation should be canceled. Note that cancellation is advisory and that the operation might still be completed even if it is canceled.

Returns:

A future that represents the asynchronous operation. The future completes exceptionally with FabricException for fabric related failures.

getCatchUpCapability

public long getCatchUpCapability()

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

Returns:

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

getCurrentProgress

public long getCurrentProgress()

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

Returns:

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

openAsync

public CompletableFuture openAsync(CancellationToken cancellationToken)

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

Parameters:

cancellationToken - The CancellationToken object that the operation is observing. It can be used to send a notification that the operation should be canceled. Note that cancellation is advisory and that the operation might still be completed even if it is canceled.

Returns:

A future that represents the asynchronous operation. The future completes exceptionally with FabricException for fabric related failures.

updateEpochAsync

public CompletableFuture updateEpochAsync(Epoch epoch, CancellationToken cancellationToken)

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

Parameters:

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

cancellationToken - The CancellationToken object that the operation is observing. It can be used to send a notification that the operation should be canceled. Note that cancellation is advisory and that the operation might still be completed even if it is canceled.

Returns:

This supports the Service Fabric infrastructure and is not meant to be used directly from your code. The future completes exceptionally with FabricException for fabric related failures.