Trait openraft::storage::RaftLogStorageExt

pub trait RaftLogStorageExt<C>: RaftLogStorage<C> + Send
where
    C: RaftTypeConfig,
{
    // Provided method
    fn blocking_append<I>(
        &mut self,
        entries: I
    ) -> impl Future<Output = Result<(), StorageError<C::NodeId>>> + Send
       where I: IntoIterator<Item = C::Entry> + OptionalSend,
             I::IntoIter: OptionalSend { ... }
}

Extension trait for RaftLogStorage to provide utility methods.

All methods in this trait are provided with default implementation.

Provided Methods

fn blocking_append<I>( &mut self, entries: I ) -> impl Future<Output = Result<(), StorageError<C::NodeId>>> + Send

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

Blocking mode append log entries to the storage.

It blocks until the callback is called by the underlying storage implementation.

Object Safety

This trait is not object safe.

Implementors

impl<C, T> RaftLogStorageExt<C> for T

where T: RaftLogStorage<C>, C: RaftTypeConfig,