Liking cljdoc? Tell your friends :D
onyx.log.commands.accept-join-cluster
No vars found in this namespace.
onyx.log.commands.common
- allocations->peers
- build-stop-task-fn
- grouped-task?
- input-task?
- job->peers
- job-allocations->peer-ids
- job-peer-count
- leaf-tasks
- messenger-slot-id
- peer->allocated-job
- promote-orphans
- remove-peers
- replica->job-peers
- root-tasks
- src-peers
- start-new-lifecycle
- start-task!
- state-task?
- stop-lifecycle-peer-group!
- to-graph
- upstream-peers
onyx.log.commands.complete-job
No vars found in this namespace.
onyx.log.commands.gc
No vars found in this namespace.
onyx.log.commands.set-replica
No vars found in this namespace.
onyx.log.replica-invariants
- active-job-invariant
- all-coordinators-exist
- all-groups-invariant
- all-jobs-have-coordinator
- all-peers-are-group-indexed
- all-peers-are-reverse-group-indexed
- all-tasks-have-non-zero-peers
- allocations-invariant
- group-index-keys-never-nil
- group-index-vals-never-nil
- no-extra-coordinators
- peer-site-invariant
- short-identifiers-correct
- slot-id-invariant
- version-invariant
onyx.log.zookeeper
- await-entry!
- catalog-path
- checkpoint-path
- checkpoint-path-version
- checkpoint-task-key
- chunk-path
- clean-up-broken-connections
- clear-job-data
- clear-tenancy
- current-replica
- epoch-low-watermark-path
- epoch-path
- exception-path
- find-log-parameters
- flow-path
- global-metadata-path
- initialize-origin!
- job-config-path
- job-hash-path
- job-metadata-path
- job-name-path
- job-paths
- latest-checkpoint-path
- lifecycles-path
- log-parameters-path
- log-path
- origin-path
- pad-sequential-id
- parse-task-key
- poll-znode-timeout-ms
- prefix-path
- pulse-path
- read-checkpoint-coord
- read-log-entry
- read-log-parameters
- read-origin
- receive-event
- resume-point-path
- root-path
- savepoint-path
- seek-and-put-entry!
- seek-to-new-origin!
- task-path
- tenancy-alive?
- throw-subscriber-closed
- triggers-path
- windows-path
- workflow-path
- znode
- znode-path
- zookeeper
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close