onyx.messaging.protocols.messenger — org.onyxplatform/onyx 0.14.2

assign-task-resources clj/s multimethod

build-messenger clj/s multimethod

build-messenger-group clj/s multimethod

get-peer-site clj/s multimethod

Messenger clj/s≠ protocol

next-epoch! clj/s

(next-epoch! messenger)

offer-heartbeats clj/s

(offer-heartbeats messenger)

set-epoch! clj/s

(set-epoch! messenger epoch)

update-publishers clj/s

(update-publishers messenger pub-infos)

poll-heartbeats clj/s

(poll-heartbeats messenger)

epoch clj/s

(epoch messenger)

replica-version clj/s

(replica-version messenger)

task->publishers clj/s

(task->publishers messenger)

update-subscriber clj/s

(update-subscriber messenger sub-info)

publishers clj/s

(publishers messenger)

start clj/s

(start messenger)

poll clj/s

(poll messenger)

unblock-subscriber! clj/s

(unblock-subscriber! messenger)

stop clj/s

(stop messenger)

subscriber clj/s

(subscriber messenger)

id clj/s

(id messenger)

offer-barrier clj/s

(offer-barrier messenger publication)

(offer-barrier messenger publication barrier-opts)

(offer-barrier messenger publication barrier-opts endpoint-epoch)

set-replica-version! clj/s

(set-replica-version! messenger replica-version)

info clj/s

(info messenger)

MessengerGroup clj/s≠ protocol

peer-site clj/s

(peer-site messenger-group peer-id)