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)