Struct StateMachine 

pub struct StateMachine { /* private fields */ }

Raft state machine wrapping the persistent ClusterStore.

Implementations

impl StateMachine

pub fn new(store: Arc<ClusterStore>) -> Self

Trait Implementations

impl RaftStateMachine<OrcaTypeConfig> for StateMachine

type SnapshotBuilder = Arc<StateMachine>

Snapshot builder type.

async fn applied_state( &mut self, ) -> Result<(Option<LogId<u64>>, StoredMembership<u64, BasicNode>), StorageError<u64>>

Returns the last applied log id which is recorded in state machine, and the last applied membership config.

async fn apply<I>(&mut self, entries: I) -> Result<Vec<()>, StorageError<u64>>

where I: IntoIterator<Item = Entry<OrcaTypeConfig>> + Send, I::IntoIter: Send,

Apply the given payload of entries to the state machine.

async fn get_snapshot_builder(&mut self) -> Self::SnapshotBuilder

Get the snapshot builder for the state machine.

async fn begin_receiving_snapshot( &mut self, ) -> Result<Box<Cursor<Vec<u8>>>, StorageError<u64>>

Create a new blank snapshot, returning a writable handle to the snapshot object.

async fn install_snapshot( &mut self, meta: &SnapshotMeta<u64, BasicNode>, snapshot: Box<Cursor<Vec<u8>>>, ) -> Result<(), StorageError<u64>>

Install a snapshot which has finished streaming from the leader.

async fn get_current_snapshot( &mut self, ) -> Result<Option<Snapshot<OrcaTypeConfig>>, StorageError<u64>>

Get a readable handle to the current snapshot.