Struct AstraStateMachine 

pub struct AstraStateMachine { /* private fields */ }

Implementations

impl AstraStateMachine

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

Trait Implementations

impl Clone for AstraStateMachine

fn clone(&self) -> AstraStateMachine

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AstraStateMachine

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RaftStateMachine<AstraTypeConfig> for AstraStateMachine

type SnapshotBuilder = AstraSnapshotBuilder

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<AstraWriteResponse>, StorageError<u64>>

where I: IntoIterator<Item = Entry<AstraTypeConfig>> + OptionalSend, I::IntoIter: OptionalSend,

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<AstraTypeConfig>>, StorageError<u64>>

Get a readable handle to the current snapshot.