Struct TopicSyncManager 

pub struct TopicSyncManager<T, S, M, 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.

Implementations

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

where T: Clone, E: Extensions,

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

Trait Implementations

impl<T, S: Debug, M: Debug, L: Debug, E> Debug for TopicSyncManager<T, S, M, 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, M, L, E> Manager<T> for TopicSyncManager<T, S, M, L, E>

where T: Clone + Debug + Eq + StdHash + Serialize + for<'a> Deserialize<'a> + Send + 'static, S: LogStore<L, E> + OperationStore<L, E> + Send + 'static, M: TopicMap<T, Logs<L>> + Send + 'static, L: LogId + for<'de> Deserialize<'de> + Serialize + Send + 'static, E: Extensions + Send + 'static,

fn from_args(config: 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, M, L, E>

type Args = TopicSyncManagerArgs<S, M>

type Event = TopicLogSyncEvent<E>

type Message = Operation<E>

type Error = TopicSyncManagerError