Trait mssf_core::runtime::stateful::LocalPrimaryReplicator

pub trait LocalPrimaryReplicator: Replicator {
    // Required methods
    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<()>;
}

Required Methods

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

Object Safety

This trait is not object safe.

Implementors

impl<TraitVariantBlanketType: PrimaryReplicator> LocalPrimaryReplicator for TraitVariantBlanketType