Liking cljdoc? Tell your friends :D
Clojure only.
onyx.messaging.protocols.subscriber
Subscribercljprotocol
alive?clj
(alive? this)set-epoch!clj
(set-epoch! this new-epoch)recovered?clj
(recovered? this)update-sources!clj
(update-sources! this sources)watermarksclj
(watermarks this)received-barrier!clj
(received-barrier! this header barrier)completed?clj
(completed? this)offer-ready-reply!clj
(offer-ready-reply! this)get-ticketclj
(get-ticket this session-id)blocked?clj
(blocked? this)equiv-metaclj
(equiv-meta this sub-info)src-peersclj
(src-peers this)get-recoverclj
(get-recover this)add-assemblerclj
(add-assembler this)unblock!clj
(unblock! this)startclj
(start this)offer-barrier-status!clj
(offer-barrier-status! this src-peer-id opts)checkpoint?clj
(checkpoint? this)stopclj
(stop this)poll!clj
(poll! this)status-pubsclj
(status-pubs this)set-replica-version!clj
(set-replica-version! this new-replica-version)infoclj
(info this)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close