onyx.plugin.bookkeeper — org.onyxplatform/onyx-bookkeeper 0.13.1.0

add-ledger-data! clj

(add-ledger-data! {:keys [conn] :as log} path ledger-id)

bookkeeper-write-ledger-ids-path clj

(bookkeeper-write-ledger-ids-path onyx-id & path-args)

BookKeeperInput clj

BookKeeperOutput clj

close-new-ledger-resources clj

(close-new-ledger-resources {:keys [bookkeeper/client bookkeeper/ledger-handle]
                             :as event}
                            lifecycle)

close-read-ledgers-resources clj

(close-read-ledgers-resources
  {:keys [bookkeeper/producer-ch bookkeeper/commit-ch bookkeeper/read-ch
          bookkeeper/retry-ch bookkeeper/shutdown-ch]
   :as event}
  lifecycle)

close-write-ledger-resources clj

(close-write-ledger-resources event lifecycle)

default-value clj

(default-value task-map k v)

digest-type clj

HandleWriteCallback clj

inject-new-ledger clj

(inject-new-ledger {:keys [onyx.core/task-map onyx.core/log onyx.core/peer-opts
                           onyx.core/task-id onyx.core/job-id]
                    :as event}
                   lifecycle)

inject-write-ledger-resources clj

(inject-write-ledger-resources event lifecycle)

new-ledger-calls clj

read-handle-exception clj

(read-handle-exception event lifecycle lf-kw exception)

read-ledgers clj

(read-ledgers {:keys [onyx.core/task-map onyx.core/log onyx.core/task-id
                      onyx.core/log-prefix]
               :as pipeline-data})

read-ledgers-calls clj

read-ledgers-data clj

(read-ledgers-data {:keys [conn] :as log} onyx-id job-id task-id)

validate-task-map! clj

(validate-task-map! task-map schema)

validate-within-supplied-bounds clj

(validate-within-supplied-bounds start-id end-id checkpoint-id)

write-handle-exception clj

(write-handle-exception event lifecycle lf-kw exception)

write-ledger clj

(write-ledger {:keys [onyx.core/task-map onyx.core/log onyx.core/peer-opts
                      onyx.core/task-id onyx.core/job-id]
               :as event})

write-ledger-calls clj

zookeeper-timeout clj