Struct StateMachineStore 

pub struct StateMachineStore<S = RedbStore> { /* private fields */ }

Implementations

impl<S: Storage> StateMachineStore<S>

pub fn new(db: Arc<S>) -> Result<Self, StorageError<NodeId>>

pub fn rate_config(&self, topic: &str) -> Option<(u64, u32)>

pub fn metrics(&self) -> QueueMetrics

pub fn has_deliverable(&self, topic: &str, group: &str, now_ms: u64) -> bool

Trait Implementations

impl<S> Clone for StateMachineStore<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Storage> RaftStateMachine<TypeConfig> for StateMachineStore<S>

type SnapshotBuilder = SnapshotBuilder<S>

Snapshot builder type.

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

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<AppResponse>, StorageError<NodeId>>

where I: IntoIterator<Item = Entry<TypeConfig>> + 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<NodeId>>

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

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

Install a snapshot which has finished streaming from the leader.

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

Get a readable handle to the current snapshot.