Struct TopicSyncManager 

pub struct TopicSyncManager<T, S, L, E>
where
    T: Clone,
    E: Extensions,
{ /* private fields */ }

Create and manage topic log sync sessions.

Sync sessions are created via the manager, which instantiates them with access to the shared topic map and operation store as well as channels for receiving sync events and for sending newly arriving operations in live mode.

A handle can be acquired to a sync session via the session_handle method for sending any live mode operations to a specific session. It’s expected that users map sessions (by their id) to any topic subscriptions in order to understand the correct mappings.

There are two points where message deduplication occurs; 1) per-subscription deduplication of received operations across all sessions for this manager occurs in the event stream 2) per-session deduplication occurs on sending operations to a remote, this is especially required during live-mode when we may receive the same new operation from several sources. The former stops any local consumers from receiving the same operation more than once, the latter reduces unnecessary noise on the network.

Implementations

impl<T, S, L, E> TopicSyncManager<T, S, L, E>

where T: Clone, E: Extensions,

pub fn new(store: S) -> Self

Trait Implementations

impl<T, S: Debug, L: Debug, E> Debug for TopicSyncManager<T, S, L, E>

where T: Clone + Debug, E: Extensions + Debug,

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

Formats the value using the given formatter.

impl<T, S, L, E> Manager<T> for TopicSyncManager<T, S, L, E>

where T: Clone + Debug + Eq + StdHash + Serialize + for<'a> Deserialize<'a> + Send + 'static, S: LogStore<Operation<E>, VerifyingKey, L, SeqNum, Hash> + TopicStore<T, VerifyingKey, L> + Clone + Send + 'static, L: LogId + Debug + Send + 'static, E: Extensions + Send + 'static,

fn from_args(store: Self::Args) -> Self

Instantiate a manager from arguments.

async fn session( &mut self, session_id: u64, config: &SessionConfig<T>, ) -> Self::Protocol

Instantiate a new sync session.

async fn session_handle( &self, session_id: u64, ) -> Option<Pin<Box<dyn Sink<ToTopicSync<E>, Error = Self::Error>>>>

Retrieve a handle to a running sync session.

fn subscribe( &mut self, ) -> impl Stream<Item = FromSync<Self::Event>> + Send + Unpin + 'static

Subscribe to the event stream for all running sync sessions.

type Protocol = TopicLogSync<T, S, L, E>

type Args = S

type Event = TopicLogSyncEvent<E>

type Message = Operation<E>

type Error = TopicSyncManagerError