Liking cljdoc? Tell your friends :D
Clojure only.

onyx.messaging.aeron.subscriber

assert-epoch-correct!clj

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

available-imageclj

(available-image sub-info lost-sessions)
source

check-correlation-id-alignmentclj

(check-correlation-id-alignment aligned header)
source

counters->counterclj

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

fragment-limit-receiverclj

source

invalid-replica-found!clj

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

lookup-ticketclj

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

new-error-handlerclj

(new-error-handler error error-counter)
source

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)
source

unavailable-imageclj

(unavailable-image sub-info)
source

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close