module Job: sig .. end
Persisting state for jobs.
include Store.S
val status : Store.t -> Job.id -> Job.status Lwt.t
status t job is job's status in t.
val pending : Store.t -> Job.id -> unit Lwt.t
pending t j sets id's status to `Pending.
val running : Store.t -> Job.id -> unit Lwt.t
runnning t id sets id's status to `Running.
val success : Store.t -> Job.id -> unit Lwt.t
success t id sets id's status to `Success.
val failure : Store.t -> Job.id -> unit Lwt.t
failure t id set id's status to `Failure.
val add_output : Store.t -> Job.id -> Object.id -> unit Lwt.t
add_output t j o adds o to the list of objects created by
the job j.
val outputs : Store.t -> Job.id -> Object.id list Lwt.t
outputs t job are job's output objects.
val watch : Store.t -> Job.t Store.callback -> Store.cancel Lwt.t
watch t f calls f on every job added in the store.
val watch_status : Store.t -> Job.id -> Job.status Store.callback -> Store.cancel Lwt.t
watch_status t j f calls f everytime j's status is
updated.