package sihl
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
include module type of struct include Sihl_facade.Queue end
val to_sexp : 'a Sihl_contract.Queue.t -> Sexplib0.Sexp.tval pp : Format.formatter -> 'a Sihl_contract.Queue.t -> unitval default_retry_delay : Sihl_core.Time.durationval create :
name:string ->
input_to_string:('a -> string option) ->
string_to_input:(string option -> ('a, string) result) ->
handle:('a -> (unit, string) result Lwt.t) ->
?failed:(string -> (unit, string) Lwt_result.t) ->
unit ->
'a Sihl_contract.Queue.tval set_max_tries : int -> 'a Sihl_contract.Queue.t -> 'a Sihl_contract.Queue.tval set_retry_delay :
Sihl_core.Time.duration ->
'a Sihl_contract.Queue.t ->
'a Sihl_contract.Queue.tinclude Sihl_contract.Queue.Sig
include Sihl_core.Container.Service.Sig
val dispatch :
'a Sihl_contract.Queue.t ->
?delay:Sihl_core.Time.duration ->
'a ->
unit Lwt.tdispatch job ?delay input queues job for processing while input input is the input that the job needs to run. Use delay to run the job earliest after a certain amount of time.
val register_jobs : 'a Sihl_contract.Queue.t list -> unit Lwt.tregister_jobs jobs registers jobs that can be dispatched.
Only registered jobs can be dispatched. Dispatching a job that was not registered does nothing.
val lifecycle : unit -> Sihl_core.Container.Lifecycle.tval register :
?jobs:'a Sihl_contract.Queue.t list ->
(module Sihl_contract.Queue.Sig) ->
Sihl_core.Container.Service.tmodule Setup : sig ... end