Struct ToRaftApp

pub struct ToRaftApp { /* private fields */ }

Available on crate feature simple only.

ToRaftApp turns an instance of RaftAppSimple into a RaftApp instance.

Implementations

impl ToRaftApp

pub fn new(app: impl RaftAppSimple, store: impl SnapshotRepository) -> Self

Trait Implementations

impl RaftApp for ToRaftApp

fn process_read<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process read request. This operation should not change the state of the application.

fn process_write<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 [u8], entry_index: Index, ) -> Pin<Box<dyn Future<Output = Result<(Vec<u8>, MakeSnapshot)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process write request. This may change the state of the application.

fn install_snapshot<'life0, 'async_trait>( &'life0 self, snapshot: Option<Index>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Special type of process_write but when the entry is a snapshot entry. Snapshot is None when apply_index is 1 which is the most youngest snapshot.

fn fold_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, old_snapshot: Option<Index>, requests: Vec<&'life1 [u8]>, snapshot_index: Index, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

This function is called from the compaction thread. It should return new snapshot from accumulative computation with the old_snapshot and the subsequent log entries.

fn save_snapshot<'life0, 'async_trait>( &'life0 self, st: SnapshotStream, idx: Index, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Make a snapshot resource from an in-coming SnapshotStream.

fn open_snapshot<'life0, 'async_trait>( &'life0 self, x: Index, ) -> Pin<Box<dyn Future<Output = Result<SnapshotStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Open a SnapshotStream from a snapshot resource.

fn delete_snapshot<'life0, 'async_trait>( &'life0 self, idx: Index, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a snapshot resource.