onyx.messaging.protocols.subscriber

Subscriber
protocol
members
add-assembler
(add-assembler this)
alive?
(alive? this)
blocked?
(blocked? this)
checkpoint?
(checkpoint? this)
completed?
(completed? this)
equiv-meta
(equiv-meta this sub-info)
get-recover
(get-recover this)
get-ticket
(get-ticket this session-id)
info
(info this)
offer-barrier-status!
(offer-barrier-status! this src-peer-id opts)
offer-ready-reply!
(offer-ready-reply! this)
poll!
(poll! this)
received-barrier!
(received-barrier! this header barrier)
recovered?
(recovered? this)
set-epoch!
(set-epoch! this new-epoch)
set-replica-version!
(set-replica-version! this new-replica-version)
src-peers
(src-peers this)
start
(start this)
status-pubs
(status-pubs this)
stop
(stop this)
unblock!
(unblock! this)
update-sources!
(update-sources! this sources)
watermarks
(watermarks this)