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)