onyx.messaging.aeron.subscriber

->Subscriber

(->Subscriber peer-id ticket-counters peer-config job-id dst-task-id slot-id site batch-size short-circuit read-bytes error-counter error bs channel conn subscription aligned sources short-id-status-pub status-pubs & overage)
Positional factory function for class onyx.messaging.aeron.subscriber.Subscriber.

assert-epoch-correct!

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

available-image

(available-image sub-info lost-sessions)

check-correlation-id-alignment

(check-correlation-id-alignment aligned header)

counters->counter

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

fragment-limit-receiver

invalid-replica-found!

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

lookup-ticket

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

new-error-handler

(new-error-handler error error-counter)

new-subscription

(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

(unavailable-image sub-info)