onyx.messaging.aeron.subscriber — org.onyxplatform/onyx 0.14.3

assert-epoch-correct! clj

(assert-epoch-correct! epoch message-epoch message)

available-image clj

(available-image sub-info lost-sessions)

check-correlation-id-alignment clj

(check-correlation-id-alignment aligned header)

counters->counter clj

(counters->counter ticket-counters job-id replica-version short-id session-id)

fragment-limit-receiver clj

invalid-replica-found! clj

(invalid-replica-found! replica-version message)

lookup-ticket clj

(lookup-ticket ticket-counters job-id replica-version short-id session-id)

new-error-handler clj

(new-error-handler error error-counter)

new-subscription clj

(new-subscription {:keys [peer-config short-circuit ticket-counters]
                   :as messenger-group}
                  {:keys [read-bytes subscription-errors] :as monitoring}
                  peer-id
                  sub-info)

unavailable-image clj

(unavailable-image sub-info)