Module manager 

Manager for initiating and orchestrating topic log sync sessions.

Concurrently running sessions perform message forwarding with de-duplication. Events from all running sync sessions can be consumed via a single manager event stream.

Structs

ManagerEventStream

Event stream for a manager returned from SyncManager::subscribe().

SessionTopicMap

Map of generic topics to session ids and of session ids to a channel sender.

TopicSyncManager

Create and manage topic log sync sessions.

TopicSyncManagerArgs

Configuration object for TopicSyncManager.

Enums

TopicSyncManagerError

Error types which can be returned from TopicSyncManager.

Type Aliases

ToTopicSync