Dispatcher¶
Introduction¶
Dispatcher
is the module that is a proxy between KvStore
and the other
modules. Modules that subscribe to Dispatcher
pass filters to allow
Dispatcher
to send deltas from KvStore
that are relevant to that module.
General Workflow¶
Below the diagram describes the flow of the delta changes coming from KvStore
to the subscribing modules.
Operations¶
Below we describe the pseudocode of the Dispatcher
module
Read
incoming deltas fromKvStore
via aReplicateQueue
Copy
the incoming publication and only add keys that pass through one of a subscriber’s list of filtersReplicate
non-empty publications to modules that are interested in receiving the publication