Liking cljdoc? Tell your friends :D
Clojure only.
onyx.messaging.aeron.subscriber
assert-epoch-correct!clj
(assert-epoch-correct! epoch message-epoch message)available-imageclj
(available-image sub-info lost-sessions)check-correlation-id-alignmentclj
(check-correlation-id-alignment aligned header)counters->counterclj
(counters->counter ticket-counters job-id replica-version short-id session-id)fragment-limit-receiverclj
invalid-replica-found!clj
(invalid-replica-found! replica-version message)lookup-ticketclj
(lookup-ticket ticket-counters job-id replica-version short-id session-id)new-error-handlerclj
(new-error-handler error error-counter)new-subscriptionclj
(new-subscription {:keys [peer-config short-circuit ticket-counters]
:as messenger-group}
{:keys [read-bytes subscription-errors] :as monitoring}
peer-id
sub-info)unavailable-imageclj
(unavailable-image sub-info)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close