package sihl-queue

  1. Overview
  2. Docs
module Status : sig ... end
type t = {
  1. id : string;
  2. name : string;
  3. input : string option;
  4. tries : int;
  5. next_run_at : Ptime.t;
  6. max_tries : int;
  7. status : Status.t;
}
val sexp_of_t : t -> Sexplib0.Sexp.t
val pp : Stdlib.Format.formatter -> t -> unit
val create : input:'a -> delay:Sihl_core.Time.duration option -> now:Ptime.t -> 'b Sihl_contract.Queue.t -> t
val is_pending : t -> bool
val incr_tries : t -> t
val update_next_run_at : Workable_job.t -> t -> t
val set_failed : t -> t
val set_succeeded : t -> t
val should_run : job_instance:t -> now:Ptime.t -> bool