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, E, S, Evt> Protocol for LogSync<L, E, S, Evt>

where L: LogId + for<'de> Deserialize<'de> + Serialize + Send + 'static, E: Extensions + Send + 'static, S: LogStore<L, E> + OperationStore<L, E> + Send + 'static, Evt: Debug + From<LogSyncEvent<E>> + Send + 'static,

type Error = LogSyncError

type Output = Dedup<Hash>

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>