Struct LogSync 

pub struct LogSync<L, E, S, Evt> { /* private fields */ }

Efficient sync protocol for append-only log data types.

Implementations

impl<L, E, S, Evt> LogSync<L, E, S, Evt>

pub fn new(store: S, logs: Logs<L>, event_tx: Sender<Evt>) -> Self

pub fn new_with_capacity( store: S, logs: Logs<L>, event_tx: Sender<Evt>, buffer_capacity: usize, ) -> Self

Trait Implementations

impl<L: Debug, E: Debug, S: Debug, Evt: Debug> Debug for LogSync<L, E, S, Evt>

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

Formats the value using the given formatter.

impl<L, E, S, Evt> Protocol for LogSync<L, E, S, Evt>

where L: LogId + Debug + Send + 'static, E: Extensions + Send + 'static, S: LogStore<Operation<E>, VerifyingKey, L, SeqNum, Hash> + Clone + Send + 'static, Evt: Debug + From<LogSyncEvent<E>> + Send + 'static,

type Error = LogSyncError

type Output = (DeduplicationBuffer<Hash>, LogSyncMetrics)

type Message = LogSyncMessage<L>

async fn run( self, sink: &mut (impl Sink<Self::Message, Error = impl Debug> + Unpin), stream: &mut (impl Stream<Item = Result<Self::Message, impl Debug>> + Unpin), ) -> Result<Self::Output, Self::Error>