Struct LogSyncProtocol

pub struct LogSyncProtocol<TM, L, E, S: LogStore<L, E>> { /* private fields */ }

Efficient sync protocol for append-only log data types.

Implementations

impl<TM, L, E, S> LogSyncProtocol<TM, L, E, S>

where S: LogStore<L, E>,

pub fn new(topic_map: TM, store: S) -> Self

Returns a new sync protocol instance, configured with a store and TopicLogMap implementation which associates the to-be-synced logs with a given topic.

Trait Implementations

impl<TM: Clone, L: Clone, E: Clone, S: Clone + LogStore<L, E>> Clone for LogSyncProtocol<TM, L, E, S>

fn clone(&self) -> LogSyncProtocol<TM, L, E, S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<TM: Debug, L: Debug, E: Debug, S: Debug + LogStore<L, E>> Debug for LogSyncProtocol<TM, L, E, S>

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

Formats the value using the given formatter.

impl<'a, T, TM, L, E, S> SyncProtocol<'a, T> for LogSyncProtocol<TM, L, E, S>

where T: TopicQuery, TM: TopicLogMap<T, L>, L: LogId + Send + Sync + for<'de> Deserialize<'de> + Serialize + 'a, E: Extensions + Send + Sync + 'a, S: Debug + Sync + LogStore<L, E>,

fn name(&self) -> &'static str

Custom identifier for this sync protocol implementation.

fn initiate<'async_trait>( self: Arc<Self>, topic_query: T, tx: Box<&'a mut (dyn AsyncWrite + Send + Unpin)>, rx: Box<&'a mut (dyn AsyncRead + Send + Unpin)>, app_tx: Box<&'a mut (dyn Sink<FromSync<T>, Error = SyncError> + Send + Unpin)>, ) -> Pin<Box<dyn Future<Output = Result<(), SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Initiate a sync protocol session over the provided bi-directional stream for the given topic query.

fn accept<'async_trait>( self: Arc<Self>, tx: Box<&'a mut (dyn AsyncWrite + Send + Unpin)>, rx: Box<&'a mut (dyn AsyncRead + Send + Unpin)>, app_tx: Box<&'a mut (dyn Sink<FromSync<T>, Error = SyncError> + Send + Unpin)>, ) -> Pin<Box<dyn Future<Output = Result<(), SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Accept a sync protocol session over the provided bi-directional stream.