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)