onyx.messaging.aeron.publisher — org.onyxplatform/onyx 0.14.5-SNAPSHOT

assert-not-closed clj

(assert-not-closed ret)

LocalRemoteDispatch clj protocol

encode-segment clj

(encode-segment this bs)

local-usage clj

(local-usage this)

next-replica-version clj

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

offer-segments clj

(offer-segments this publisher curr-position epoch)

reset-segments-encoder clj

(reset-segments-encoder this)

new-publisher clj

(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 clj

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