Struct RaftStore 

pub struct RaftStore { /* private fields */ }

The log and vote live in raft.db, the state machine is orch’s own database. Apply writes each entry and raft:applied in one transaction on orch.db, so a crash never applies an entry twice, and a log that runs ahead of the state is normal for Raft

Implementations

impl RaftStore

pub async fn open(raft_db: &Path, store: TaskStore) -> Result<Self>

Trait Implementations

impl Clone for RaftStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RaftLogReader<TypeConfig> for RaftStore

async fn try_get_log_entries<RB: RangeBounds<u64> + Clone + Debug + OptionalSend>( &mut self, range: RB, ) -> Result<Vec<Entry<TypeConfig>>, StorageError<NodeId>>

Get a series of log entries from storage.

fn limited_get_log_entries( &mut self, start: u64, end: u64, ) -> impl Future<Output = Result<Vec<<C as RaftTypeConfig>::Entry>, StorageError<<C as RaftTypeConfig>::NodeId>>> + Send

Returns log entries within range [start, end), end is exclusive, potentially limited by implementation-defined constraints.

impl RaftSnapshotBuilder<TypeConfig> for RaftStore

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

Build snapshot

impl RaftStorage<TypeConfig> for RaftStore

type LogReader = RaftStore

Log reader type.

type SnapshotBuilder = RaftStore

Snapshot builder type.

async fn save_vote( &mut self, vote: &Vote<NodeId>, ) -> Result<(), StorageError<NodeId>>

To ensure correctness: the vote must be persisted on disk before returning.

async fn read_vote( &mut self, ) -> Result<Option<Vote<NodeId>>, StorageError<NodeId>>

async fn save_committed( &mut self, committed: Option<LogId<NodeId>>, ) -> Result<(), StorageError<NodeId>>

Saves the last committed log id to storage.

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

Return the last saved committed log id by Self::save_committed.

async fn get_log_state( &mut self, ) -> Result<LogState<TypeConfig>, StorageError<NodeId>>

Returns the last deleted log id and the last log id.

async fn get_log_reader(&mut self) -> Self::LogReader

Get the log reader.

async fn append_to_log<I>( &mut self, entries: I, ) -> Result<(), StorageError<NodeId>>

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

Append a payload of entries to the log.

async fn delete_conflict_logs_since( &mut self, log_id: LogId<NodeId>, ) -> Result<(), StorageError<NodeId>>

Delete conflict log entries since log_id, inclusive.

async fn purge_logs_upto( &mut self, log_id: LogId<NodeId>, ) -> Result<(), StorageError<NodeId>>

Delete applied log entries upto log_id, inclusive.

async fn last_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_to_state_machine( &mut self, entries: &[Entry<TypeConfig>], ) -> Result<Vec<Reply>, StorageError<NodeId>>

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, along with its metadata.