Liking cljdoc? Tell your friends :D

onyx.peer.resume-point


coordinates->input-resume-pointclj

(coordinates->input-resume-point {:keys [onyx.core/task-id onyx.core/job-id
                                         onyx.core/resume-point
                                         onyx.core/tenancy-id]
                                  :as event}
                                 latest-coordinates)
source

coordinates->output-resume-pointclj

(coordinates->output-resume-point {:keys [onyx.core/task-id onyx.core/job-id
                                          onyx.core/resume-point
                                          onyx.core/tenancy-id]
                                   :as event}
                                  latest-coordinates)
source

coordinates->windows-resume-pointclj

(coordinates->windows-resume-point
  {:keys [onyx.core/windows onyx.core/task-id onyx.core/job-id
          onyx.core/resume-point onyx.core/tenancy-id]
   :as event}
  latest-coordinates)
source

read-checkpointclj

(read-checkpoint {:keys [onyx.core/storage onyx.core/monitoring] :as event}
                 checkpoint-type
                 {:keys [tenancy-id job-id task-id replica-version epoch]
                  :as coordinates}
                 slot-id)
source

recover-inputclj

(recover-input event recover-coordinates)
source

recover-outputclj

(recover-output event recover-coordinates)
source

recover-windowsclj

(recover-windows {:keys [onyx.core/windows onyx.core/triggers onyx.core/task-id
                         onyx.core/slot-id onyx.core/task-map]
                  :as event}
                 state-store
                 recover-coordinates)
source

resume-point->coordinatesclj

(resume-point->coordinates resume-point)
source

state-reindexclj

(state-reindex old-state-indices new-state-indices)
source

windows-to-fetchclj

(windows-to-fetch {:keys [onyx.core/slot-id] :as event} resume-point task-id)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close