pub struct ReplicatorProxy { /* private fields */ }Trait Implementations§
source§impl Replicator for ReplicatorProxy
impl Replicator for ReplicatorProxy
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<()>
source§async fn update_epoch(
&self,
epoch: &Epoch,
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. Read more
fn get_current_progress(&self) -> Result<i64>
fn get_catch_up_capability(&self) -> Result<i64>
fn abort(&self)
Auto Trait Implementations§
impl Freeze for ReplicatorProxy
impl RefUnwindSafe for ReplicatorProxy
impl Send for ReplicatorProxy
impl Sync for ReplicatorProxy
impl Unpin for ReplicatorProxy
impl UnwindSafe for ReplicatorProxy
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<TraitVariantBlanketType> LocalReplicator for TraitVariantBlanketTypewhere
TraitVariantBlanketType: Replicator,
impl<TraitVariantBlanketType> LocalReplicator for TraitVariantBlanketTypewhere
TraitVariantBlanketType: Replicator,
async fn open( &self, cancellation_token: CancellationToken, ) -> Result<HSTRING, Error>
async fn close( &self, cancellation_token: CancellationToken, ) -> Result<(), Error>
async fn change_role( &self, epoch: &Epoch, role: &ReplicaRole, cancellation_token: CancellationToken, ) -> Result<(), Error>
source§async fn update_epoch(
&self,
epoch: &Epoch,
cancellation_token: CancellationToken,
) -> Result<(), Error>
async fn update_epoch( &self, epoch: &Epoch, cancellation_token: CancellationToken, ) -> Result<(), Error>
(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. Read more