Struct PrimaryReplicatorProxy

pub struct PrimaryReplicatorProxy { /* private fields */ }

Implementations

impl PrimaryReplicatorProxy

pub fn new(com_impl: IFabricPrimaryReplicator) -> PrimaryReplicatorProxy

Trait Implementations

impl PrimaryReplicator for PrimaryReplicatorProxy

async fn on_data_loss( &self, cancellation_token: CancellationToken, ) -> Result<u8>

fn update_catch_up_replica_set_configuration( &self, currentconfiguration: &ReplicaSetConfig, previousconfiguration: &ReplicaSetConfig, ) -> Result<()>

async fn wait_for_catch_up_quorum( &self, catchupmode: ReplicaSetQuarumMode, cancellation_token: CancellationToken, ) -> Result<()>

fn update_current_replica_set_configuration( &self, currentconfiguration: &ReplicaSetConfig, ) -> Result<()>

async fn build_replica( &self, replica: &ReplicaInfo, cancellation_token: CancellationToken, ) -> Result<()>

fn remove_replica(&self, replicaid: i64) -> Result<()>

impl Replicator for PrimaryReplicatorProxy

async fn open(&self, cancellation_token: CancellationToken) -> Result<HSTRING>

async fn close(&self, cancellation_token: CancellationToken) -> Result<()>

async fn change_role( &self, epoch: &Epoch, role: &ReplicaRole, cancellation_token: CancellationToken, ) -> Result<()>

async fn update_epoch( &self, epoch: &Epoch, cancellation_token: CancellationToken, ) -> Result<()>

(TODO: This doc is from IStateProvider but not Replicator.) Indicates to a replica that the configuration of a replica set has changed due to a change or attempted change to the primary replica. The change occurs due to failure or load balancing of the previous primary replica. Epoch changes act as a barrier by segmenting operations into the exact configuration periods in which they were sent by a specific primary replica.

fn get_current_progress(&self) -> Result<i64>

fn get_catch_up_capability(&self) -> Result<i64>

fn abort(&self)