Trait mssf_core::runtime::stateful::LocalPrimaryReplicator
source · pub trait LocalPrimaryReplicator: Replicator {
// Required methods
async fn on_data_loss(&self) -> 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
) -> Result<()>;
fn update_current_replica_set_configuration(
&self,
currentconfiguration: &ReplicaSetConfig
) -> Result<()>;
async fn build_replica(&self, replica: &ReplicaInfo) -> Result<()>;
fn remove_replica(&self, replicaid: i64) -> Result<()>;
}Required Methods§
async fn on_data_loss(&self) -> 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 ) -> Result<()>
fn update_current_replica_set_configuration( &self, currentconfiguration: &ReplicaSetConfig ) -> Result<()>
async fn build_replica(&self, replica: &ReplicaInfo) -> Result<()>
fn remove_replica(&self, replicaid: i64) -> Result<()>
Object Safety§
This trait is not object safe.