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)