onyx.log.zookeeper — org.onyxplatform/onyx 0.14.5-SNAPSHOT

await-entry! clj

(await-entry! {:keys [conn opts prefix kill-ch] :as log} ch path position)

catalog-path clj

(catalog-path prefix)

checkpoint-path clj

(checkpoint-path prefix)

checkpoint-path-version clj

(checkpoint-path-version prefix job-id replica-version epoch)

checkpoint-task-key clj

(checkpoint-task-key task-id slot-id checkpoint-type)

chunk-path clj

(chunk-path prefix)

clean-up-broken-connections clj

(clean-up-broken-connections f)

clear-job-data clj

(clear-job-data conn tenancy-id job-id)

clear-tenancy clj

(clear-tenancy conn tenancy-id)

current-replica clj

(current-replica conn tenancy-id job-id)

epoch-low-watermark-path clj

(epoch-low-watermark-path prefix job-id replica-version)

epoch-path clj

(epoch-path prefix)

exception-path clj

(exception-path prefix)

find-log-parameters clj

(find-log-parameters log)

flow-path clj

(flow-path prefix)

global-metadata-path clj

initialize-origin! clj

(initialize-origin! conn config prefix)

job-config-path clj

(job-config-path prefix)

job-hash-path clj

(job-hash-path prefix)

job-metadata-path clj

(job-metadata-path prefix)

job-name-path clj

(job-name-path prefix)

job-paths clj

(job-paths tenancy-id job-id)

latest-checkpoint-path clj

(latest-checkpoint-path prefix)

(latest-checkpoint-path prefix job-id)

lifecycles-path clj

(lifecycles-path prefix)

log-parameters-path clj

(log-parameters-path prefix)

log-path clj

(log-path prefix)

origin-path clj

(origin-path prefix)

pad-sequential-id clj

(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 clj

(parse-task-key s)

poll-znode-timeout-ms clj

prefix-path clj

(prefix-path prefix)

pulse-path clj

(pulse-path prefix)

read-checkpoint-coord clj

(read-checkpoint-coord conn tenancy-id job-id)

read-log-entry clj

(read-log-entry conn tenancy-id position)

read-log-parameters clj

(read-log-parameters conn tenancy-id)

read-origin clj

(read-origin conn tenancy-id)

receive-event clj

(receive-event read-ch
               {:keys [conn opts prefix kill-ch] :as log}
               ch
               path
               position)

resume-point-path clj

(resume-point-path prefix)

root-path clj

savepoint-path clj

seek-and-put-entry! clj

(seek-and-put-entry! log position ch)

seek-to-new-origin! clj

(seek-to-new-origin! log ch)

task-path clj

(task-path prefix)

tenancy-alive? clj

(tenancy-alive? conn tenancy-id)

throw-subscriber-closed clj

(throw-subscriber-closed)

triggers-path clj

(triggers-path prefix)

windows-path clj

(windows-path prefix)

workflow-path clj

(workflow-path prefix)

znode clj

(znode position)

znode-path clj

(znode-path prefix position)

zookeeper clj

(zookeeper config)