package sihl-queue

  1. Overview
  2. Docs

Module Sihl_queueSource

include module type of struct include Sihl.Contract.Queue end
Sourcetype 'a t = {
  1. name : string;
  2. input_to_string : 'a -> string option;
  3. string_to_input : string option -> ('a, string) Result.t;
  4. handle : 'a -> (unit, string) Result.t Lwt.t;
  5. failed : string -> (unit, string) Result.t Lwt.t;
  6. max_tries : int;
  7. retry_delay : Sihl__.Core_time.duration;
}
Sourceval name : string
Sourceval to_sexp : 'a t -> Sexplib0.Sexp.t
Sourceval pp : Format.formatter -> 'a t -> unit
Sourceval default_tries : int
Sourceval default_retry_delay : Sihl__.Core_time.duration
Sourceval create : name:string -> input_to_string:('a -> string option) -> string_to_input:(string option -> ('a, string) Result.t) -> handle:('a -> (unit, string) Result.t Lwt.t) -> ?failed:(string -> (unit, string) Lwt_result.t) -> unit -> 'a t
Sourceval set_max_tries : int -> 'a t -> 'a t
Sourceval set_retry_delay : Sihl__.Core_time.duration -> 'a t -> 'a t
Sourceval log_src : Logs.src
Sourcemodule Logs : Logs.LOG
Sourceval registered_jobs : Workable_job.t list ref
Sourceval stop_schedule : (unit -> unit) option ref
Sourcemodule Job_instance : sig ... end
Sourcemodule Workable_job : sig ... end
Sourcemodule Make (Repo : sig ... end) : Sihl.Contract.Queue.Sig
Sourcemodule InMemory : sig ... end
Sourcemodule MariaDb : sig ... end
Sourcemodule PostgreSql : sig ... end