AddResumeHook adds a resume hook.

MakeRegistry creates a new Registry.

RunAndWaitForTerminalState runs a closure and potentially tracks its progress using the system.jobs table.

UnmarshalPayload unmarshals and returns the Payload encoded in the input datum, which should be a parser.DBytes.

WrapPayloadDetails wraps a Details object in the protobuf wrapper struct necessary to make it usable as the Details field of a Payload.

DefaultCancelInterval is a reasonable interval at which to poll this node for liveness failures and cancel running jobs.

StatusCanceled is for jobs that were explicitly canceled by the user and cannot be resumed.

StatusFailed is for jobs that failed.

StatusPaused is for jobs that are not currently performing work, but have saved their state and can be resumed by the user later.

StatusPending is for jobs that have been created but on which work has not yet started.

StatusRunning is for jobs that are currently in progress.

StatusSucceeded is for jobs that have successfully completed.

DefaultAdoptInterval is a reasonable interval at which to poll system.jobs for jobs with expired leases.

Noop is a nil ProgressedFn.

WithoutCancel indicates that the job should not have its leasing and cancelation managed by Registry.

InvalidStatusError is the error returned when the desired operation is invalid given the job's current status.

Job manages logging the progress of long-running system processes, like backups and restores, to the system.jobs table.

Record stores the job fields that are not automatically managed by Job.

Registry creates Jobs and manages their leases and cancelation.

Details is a marker interface for job details proto structs.

ProgressedFn is a callback that allows arbitrary modifications to a job's details when updating its progress.

Status represents the status of a job in the system.jobs table.