Trait mssf_core::runtime::stateful::Replicator

source ·

pub trait Replicator: Send + Sync + 'static + Send {
    // Required methods
    fn open(&self) -> impl Future<Output = Result<HSTRING>> + Send;
    fn close(&self) -> impl Future<Output = Result<()>> + Send;
    fn change_role(
        &self,
        epoch: &Epoch,
        role: &Role
    ) -> impl Future<Output = Result<()>> + Send;
    fn update_epoch(
        &self,
        epoch: &Epoch
    ) -> impl Future<Output = Result<()>> + Send;
    fn get_current_progress(&self) -> Result<i64>;
    fn get_catch_up_capability(&self) -> Result<i64>;
    fn abort(&self);
}