onyx.messaging.protocols.messenger

assign-task-resources

multimethod

build-messenger

multimethod

build-messenger-group

multimethod

get-peer-site

multimethod

Messenger

protocol

members

epoch

(epoch messenger)

id

(id messenger)

info

(info messenger)

next-epoch!

(next-epoch! messenger)

offer-barrier

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

offer-heartbeats

(offer-heartbeats messenger)

poll

(poll messenger)

poll-heartbeats

(poll-heartbeats messenger)

publishers

(publishers messenger)

replica-version

(replica-version messenger)

set-epoch!

(set-epoch! messenger epoch)

set-replica-version!

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

start

(start messenger)

stop

(stop messenger)

subscriber

(subscriber messenger)

task->publishers

(task->publishers messenger)

unblock-subscriber!

(unblock-subscriber! messenger)

update-publishers

(update-publishers messenger pub-infos)

update-subscriber

(update-subscriber messenger sub-info)

MessengerGroup

protocol

members

peer-site

(peer-site messenger-group peer-id)