Struct LogSync 

pub struct LogSync<S, L, E, TM>
where
    S: OperationStore<L, E> + LogStore<L, E> + Send + 'static,
    L: LogId + Serialize + for<'de> Deserialize<'de> + Send + 'static,
    E: Extensions + Send + 'static,
    TM: TopicMap<TopicId, Logs<L>> + Send + 'static,
{ /* private fields */ }

Eventually consistent, local-first sync protocol based on append-only logs.

Example

See chat.rs for a full example using the sync protocol.

Local-first

In local-first applications we want to converge towards the same state eventually, which requires nodes to catch up on missed messages - independent of if they’ve been offline or not.

p2panda-net comes with a default LogSync protocol implementation which uses p2panda’s append-only log Base Convergent Data Type (CDT).

After initial sync has finished, nodes switch to live-mode to directly push new messages to the network using a gossip protocol.

Implementations

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

where S: OperationStore<L, E> + LogStore<L, E> + Send + 'static, L: LogId + Serialize + for<'de> Deserialize<'de> + Send + 'static, E: Extensions + Send + 'static, TM: TopicMap<TopicId, Logs<L>> + Send + 'static,

pub fn builder( store: S, topic_map: TM, endpoint: Endpoint, gossip: Gossip, ) -> Builder<S, L, E, TM>

pub async fn stream( &self, topic: TopicId, live_mode: bool, ) -> Result<SyncHandle<Operation<E>, TopicLogSyncEvent<E>>, LogSyncError<E>>

Trait Implementations

impl<S, L, E, TM> Clone for LogSync<S, L, E, TM>

where S: OperationStore<L, E> + LogStore<L, E> + Send + 'static + Clone, L: LogId + Serialize + for<'de> Deserialize<'de> + Send + 'static + Clone, E: Extensions + Send + 'static + Clone, TM: TopicMap<TopicId, Logs<L>> + Send + 'static + Clone,

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.