Trait mssf_core::runtime::stateful::StatefulServiceReplica

pub trait StatefulServiceReplica:
    Send
    + Sync
    + 'static
    + Send {
    // Required methods
    fn open(
        &self,
        openmode: OpenMode,
        partition: &StatefulServicePartition,
        cancellation_token: CancellationToken,
    ) -> impl Future<Output = Result<impl PrimaryReplicator>> + Send;
    fn change_role(
        &self,
        newrole: ReplicaRole,
        cancellation_token: CancellationToken,
    ) -> impl Future<Output = Result<HSTRING>> + Send;
    fn close(
        &self,
        cancellation_token: CancellationToken,
    ) -> impl Future<Output = Result<()>> + Send;
    fn abort(&self);
}

Required Methods

fn open( &self, openmode: OpenMode, partition: &StatefulServicePartition, cancellation_token: CancellationToken, ) -> impl Future<Output = Result<impl PrimaryReplicator>> + Send

fn change_role( &self, newrole: ReplicaRole, cancellation_token: CancellationToken, ) -> impl Future<Output = Result<HSTRING>> + Send

fn close( &self, cancellation_token: CancellationToken, ) -> impl Future<Output = Result<()>> + Send

fn abort(&self)

Object Safety

This trait is not object safe.

Implementors

impl StatefulServiceReplica for StatefulServiceReplicaProxy