Liking cljdoc? Tell your friends :D
lib-onyx.log-subscriber
start-log-subscriberclj
(start-log-subscriber peer-config)(start-log-subscriber peer-config args)Takes a peer config map, and an args map. Args accepts keys :inbox-capacity, representing the buffer size of the core.async channel reading from ZooKeeper. This function returns a Component with key :state. :state is an atom of a map of keys :replica, :as-of-entry, and :as-of-timestamp. :replica is the current replica. :as-of-entry is the sequential ID in ZooKeeper for the last entry read by this subscriber, and :as-of-timestamp is the timestamp of the entry, as known by ZooKeeper.
Takes a peer config map, and an args map. Args accepts keys :inbox-capacity, representing the buffer size of the core.async channel reading from ZooKeeper. This function returns a Component with key :state. :state is an atom of a map of keys :replica, :as-of-entry, and :as-of-timestamp. :replica is the current replica. :as-of-entry is the sequential ID in ZooKeeper for the last entry read by this subscriber, and :as-of-timestamp is the timestamp of the entry, as known by ZooKeeper.
stop-log-subscriberclj
(stop-log-subscriber log-subscriber)Shuts down the log subscriber Component.
Shuts down the log subscriber Component.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close