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)