Struct mssf_core::runtime::stateful_proxy::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) -> 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<()>

impl Replicator for PrimaryReplicatorProxy

async fn open(&self) -> Result<HSTRING>

async fn close(&self) -> Result<()>

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

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

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

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

fn abort(&self)