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)