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)