Trait mssf_core::runtime::stateful::LocalReplicator

pub trait LocalReplicator: Send + Sync + 'static {
    // Required methods
    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);
}

Required Methods

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)

Object Safety

This trait is not object safe.

Implementors

impl<TraitVariantBlanketType: Replicator> LocalReplicator for TraitVariantBlanketType