onyx.peer.resume-point

coordinates->input-resume-point

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

coordinates->output-resume-point

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

coordinates->windows-resume-point

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

read-checkpoint

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

recover-input

(recover-input {:keys [onyx.core/slot-id], :as event} recover-coordinates)

recover-output

(recover-output event recover-coordinates)

recover-windows

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

resume-point->coordinates

(resume-point->coordinates resume-point)

state-reindex

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

windows-to-fetch

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