onyx.log.zookeeper

->ZooKeeper
(->ZooKeeper config)
Positional factory function for class onyx.log.zookeeper.ZooKeeper.

await-entry!
(await-entry! {:keys [conn opts prefix kill-ch], :as log} ch path position)
catalog-path
(catalog-path prefix)
checkpoint-path
(checkpoint-path prefix)
checkpoint-path-version
(checkpoint-path-version prefix job-id replica-version epoch)
checkpoint-task-key
(checkpoint-task-key task-id slot-id checkpoint-type)
chunk-path
(chunk-path prefix)
clean-up-broken-connections
(clean-up-broken-connections f)
clear-job-data
(clear-job-data conn tenancy-id job-id)
clear-tenancy
(clear-tenancy conn tenancy-id)
current-replica
(current-replica conn tenancy-id job-id)
epoch-low-watermark-path
(epoch-low-watermark-path prefix job-id replica-version)
epoch-path
(epoch-path prefix)
exception-path
(exception-path prefix)
find-log-parameters
(find-log-parameters log)
flow-path
(flow-path prefix)
global-metadata-path
initialize-origin!
(initialize-origin! conn config prefix)
job-config-path
(job-config-path prefix)
job-hash-path
(job-hash-path prefix)
job-metadata-path
(job-metadata-path prefix)
job-name-path
(job-name-path prefix)
job-paths
(job-paths tenancy-id job-id)
latest-checkpoint-path
(latest-checkpoint-path prefix)(latest-checkpoint-path prefix job-id)
lifecycles-path
(lifecycles-path prefix)
log-parameters-path
(log-parameters-path prefix)
log-path
(log-path prefix)
map->ZooKeeper
(map->ZooKeeper m__6522__auto__)
Factory function for class onyx.log.zookeeper.ZooKeeper, taking a map of keywords to field values.

origin-path
(origin-path prefix)
pad-sequential-id
(pad-sequential-id id)
ZooKeeper sequential IDs are at least 10 digits.
If this node's id is less, pad it. Otherwise returns the str'ed id
parse-task-key
(parse-task-key s)
poll-znode-timeout-ms
prefix-path
(prefix-path prefix)
pulse-path
(pulse-path prefix)
read-checkpoint-coord
(read-checkpoint-coord conn tenancy-id job-id)
read-log-entry
(read-log-entry conn tenancy-id position)
read-log-parameters
(read-log-parameters conn tenancy-id)
read-origin
(read-origin conn tenancy-id)
receive-event
(receive-event read-ch {:keys [conn opts prefix kill-ch], :as log} ch path position)
resume-point-path
(resume-point-path prefix)
root-path
savepoint-path
seek-and-put-entry!
(seek-and-put-entry! log position ch)
seek-to-new-origin!
(seek-to-new-origin! log ch)
task-path
(task-path prefix)
tenancy-alive?
(tenancy-alive? conn tenancy-id)
throw-subscriber-closed
(throw-subscriber-closed)
triggers-path
(triggers-path prefix)
windows-path
(windows-path prefix)
workflow-path
(workflow-path prefix)
znode
(znode position)
znode-path
(znode-path prefix position)
zookeeper
(zookeeper config)