onyx.messaging.aeron.publisher

->LocalDispatch

(->LocalDispatch base-encoder segments-encoder segments batch-size short-circuit-group short-circuit peer-config job-id)
Positional factory function for class onyx.messaging.aeron.publisher.LocalDispatch.

->Publisher

(->Publisher pub-info peer-config src-peer-id job-id dst-task-id slot-id site serializer-fn buffer control-buffer written-bytes errors conn publication status-mon error segment-sender short-id replica-version epoch)
Positional factory function for class onyx.messaging.aeron.publisher.Publisher.

->RemoteDispatch

(->RemoteDispatch base-encoder segments-encoder)
Positional factory function for class onyx.messaging.aeron.publisher.RemoteDispatch.

assert-not-closed

(assert-not-closed ret)

LocalRemoteDispatch

protocol

members

encode-segment

(encode-segment this bs)

local-usage

(local-usage this)

next-replica-version

(next-replica-version this replica-version short-id session-id status-mon)

offer-segments

(offer-segments this publisher curr-position epoch)

reset-segments-encoder

(reset-segments-encoder this)

map->LocalDispatch

(map->LocalDispatch m__6522__auto__)
Factory function for class onyx.messaging.aeron.publisher.LocalDispatch, taking a map of keywords to field values.

new-publisher

(new-publisher {:keys [peer-config short-circuit], :as messenger-group} {:keys [written-bytes publication-errors], :as monitoring} {:keys [job-id src-peer-id dst-task-id slot-id site short-id batch-size term-buffer-size short-circuit?], :as pub-info})

reconcile-pub

(reconcile-pub messenger-group monitoring publisher pub-info)