module Task: sig
.. end
Persisting state for tasks.
include Store.S
val update_status : Store.t -> Task.id -> unit Lwt.t
update_status t id
updates id
's status by looking at the
status of its jobs.
val reset : Store.t -> Task.id -> unit Lwt.t
reset t task
resets the status of t
to be `New
.
val status : Store.t -> Task.id -> Task.status Lwt.t
status t task
is task
's status in t
.
val jobs : Store.t -> Task.id -> Job.id list Lwt.t
jobs t task
are task
's jobs in t
.
val watch : Store.t -> Task.t Store.callback -> Store.cancel Lwt.t
watch t f
calls f
on every task added in the store.
val watch_status : Store.t -> Task.id -> Task.status Store.callback -> Store.cancel Lwt.t
watch_status t ta f
calls f
everytime ta
's status is
updated.