Struct HpcStateMachine 

pub struct HpcStateMachine<C, S>
where
    C: RaftTypeConfig<SnapshotData = Cursor<Vec<u8>>>,
    S: StateMachineState<C>,
{ /* private fields */ }

The generic Raft state machine wrapping an application state.

Implementations

impl<C, S> HpcStateMachine<C, S>

where C: RaftTypeConfig<Entry = Entry<C>, SnapshotData = Cursor<Vec<u8>>>, S: StateMachineState<C>, LogId<C>: Serialize + DeserializeOwned, StoredMembership<C>: Serialize + DeserializeOwned,

pub fn new(state: Arc<RwLock<S>>) -> Self

pub fn with_snapshot_dir( state: Arc<RwLock<S>>, snapshot_dir: PathBuf, ) -> Result<Self>

Create a state machine with persistent snapshot directory.

On startup, loads the latest snapshot from disk if available.

pub fn state(&self) -> Arc<RwLock<S>>

Get a read handle to the application state (for queries).

Trait Implementations

impl<C, S> RaftStateMachine<C> for HpcStateMachine<C, S>

where C: RaftTypeConfig<Entry = Entry<C>, SnapshotData = Cursor<Vec<u8>>>, S: StateMachineState<C>, LogId<C>: Serialize + DeserializeOwned, StoredMembership<C>: Serialize + DeserializeOwned + Clone,

type SnapshotBuilder = HpcSnapshotBuilder<C, S>

Snapshot builder type.

async fn applied_state( &mut self, ) -> Result<(Option<LogId<C>>, StoredMembership<C>), Error>

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

async fn apply<Strm>(&mut self, entries: Strm) -> Result<(), Error>

where Strm: Stream<Item = Result<EntryResponder<C>, Error>> + Unpin + 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<Cursor<Vec<u8>>, Error>

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

async fn install_snapshot( &mut self, meta: &SnapshotMeta<C>, snapshot: Cursor<Vec<u8>>, ) -> Result<(), Error>

Install a snapshot which has finished streaming from the leader.

async fn get_current_snapshot(&mut self) -> Result<Option<Snapshot<C>>, Error>

Get a readable handle to the current snapshot.

fn try_create_snapshot_builder( &mut self, force: bool, ) -> impl Future<Output = Option<Self::SnapshotBuilder>> + Send

Try to create a snapshot builder for the state machine.