Struct LocalReplication 

pub struct LocalReplication<E>
where
    E: KvEngine + SnapshotEngine,
{ /* private fields */ }

Local replication implementation that forwards to a single engine

Implementations

impl<E> LocalReplication<E>

where E: KvEngine + SnapshotEngine,

pub fn new(engine: Arc<E>) -> Self

Creates a new local replication handle for the given engine

Trait Implementations

impl<E> Clone for LocalReplication<E>

where E: KvEngine + SnapshotEngine + Clone,

fn clone(&self) -> LocalReplication<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E> CommandSubmitter for LocalReplication<E>

where E: KvEngine + SnapshotEngine,

fn submit(&self, command: Command) -> Result<ApplyOutcome>

Submits a single command and returns the outcome

fn submit_batch<I>(&self, commands: I) -> Result<Vec<ApplyOutcome>>

where I: IntoIterator<Item = Command>,

Submits a batch of commands and returns the outcomes

impl<E> Debug for LocalReplication<E>

where E: KvEngine + SnapshotEngine + Debug,

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

Formats the value using the given formatter.

impl<E> SnapshotProvider for LocalReplication<E>

where E: KvEngine + SnapshotEngine,

fn snapshot_state(&self) -> Result<KvState>

Returns a snapshot of the current state

fn latest_version(&self) -> Result<u64>

Returns the latest version number