onyx.messaging.protocols.publisher

Publisher
protocol
members
alive?
(alive? this)
encode-segment!
(encode-segment! this bs)
endpoint-status
(endpoint-status this)
equiv-meta
(equiv-meta this pub-info)
heartbeat!
(heartbeat! this)
info
(info this)
key
(key this)
metrics
(metrics this)
offer!
(offer! this buf length endpoint-epoch)
offer-heartbeat!
(offer-heartbeat! this)
offer-ready!
(offer-ready! this)
offer-segments!
(offer-segments! this)
poll-heartbeats!
(poll-heartbeats! this)
ready?
(ready? this)
reset-segment-encoder!
(reset-segment-encoder! this)
serialize
(serialize this segment)
set-endpoint-peers!
(set-endpoint-peers! this new-peers)
set-epoch!
(set-epoch! this new-epoch)
set-replica-version!
(set-replica-version! this new-replica-version)
set-short-id!
(set-short-id! this new-short-id)
short-id
(short-id this)
start
(start this)
statuses
(statuses this)
stop
(stop this)