Module `Contract.Queue`Source

Sourceexception Exception of string

Sourcetype instance_status =

| Pending
| Succeeded
| Failed
| Cancelled

val pp_instance_status : 
  Ppx_deriving_runtime.Format.formatter ->
  instance_status ->
  Ppx_deriving_runtime.unit

Sourceval show_instance_status : instance_status -> Ppx_deriving_runtime.string

Sourcetype instance = {

id : string;
name : string;
input : string;
tries : int;
next_run_at : Ptime.t;
max_tries : int;
status : instance_status;
last_error : string option;
last_error_at : Ptime.t option;

}

Source

val pp_instance : 
  Ppx_deriving_runtime.Format.formatter ->
  instance ->
  Ppx_deriving_runtime.unit

Sourceval show_instance : instance -> Ppx_deriving_runtime.string

Sourcetype 'a job = {

name : string;
encode : 'a -> string;
decode : string -> ('a, string) Result.t;
handle : 'a -> (unit, string) Result.t Lwt.t;
failed : string -> instance -> unit Lwt.t;
max_tries : int;
retry_delay : Ptime.Span.t;

}

Source

val pp_job : 
  'a. (Ppx_deriving_runtime.Format.formatter ->
        'a ->
        Ppx_deriving_runtime.unit) ->
  Ppx_deriving_runtime.Format.formatter ->
  'a job ->
  Ppx_deriving_runtime.unit

Source

val show_job : 
  'a. (Ppx_deriving_runtime.Format.formatter ->
        'a ->
        Ppx_deriving_runtime.unit) ->
  'a job ->
  Ppx_deriving_runtime.string

Sourcetype job' = {

name : string;
handle : string -> (unit, string) Result.t Lwt.t;
failed : string -> instance -> unit Lwt.t;
max_tries : int;
retry_delay : Ptime.Span.t;

}

Source

val pp_job' : 
  Ppx_deriving_runtime.Format.formatter ->
  job' ->
  Ppx_deriving_runtime.unit

Sourceval show_job' : job' -> Ppx_deriving_runtime.string

Sourceval hide : 'a job -> job'

Sourceval should_run : instance -> Ptime.t -> bool

Sourceval default_tries : int

Sourceval default_retry_delay : Ptime.span

Sourceval default_error_handler : string -> instance -> unit Lwt.t

Source

val create_job : 
  ('a -> (unit, string) Result.t Lwt.t) ->
  ?max_tries:int ->
  ?retry_delay:Ptime.Span.t ->
  ?failed:(string -> instance -> unit Lwt.t) ->
  ('a -> string) ->
  (string -> ('a, string) Result.t) ->
  string ->
  'a job

Sourceval name : string

Sourcemodule type Sig = sig ... end

package sihl

Module Contract.QueueSource

Module `Contract.Queue`Source