package sihl-queue

You can search for identifiers within the package.

in-package search v0.2.0

package sihl-queue

sihl-queue
- Sihl_queue
  - InMemory
  - Job_instance
    
    Status
  - Logs
  - Make
    
    Repo
  - MariaDb
  - PostgreSql
  - Workable_job

Legend:
Library
Module
Module type
Parameter
Class
Class type

include module type of struct include Sihl.Contract.Queue end

type 'a t = {

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) Result.t Lwt.t;
max_tries : int;
retry_delay : Sihl__.Core_time.duration;

}

val name : string

module type Sig = Sihl.Contract.Queue.Sig

val to_sexp : 'a t -> Sexplib0.Sexp.t

val pp : Stdlib.Format.formatter -> 'a t -> unit

val default_tries : int

val default_retry_delay : Sihl__.Core_time.duration

val 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

val set_max_tries : int -> 'a t -> 'a t

val set_retry_delay : Sihl__.Core_time.duration -> 'a t -> 'a t

val log_src : Logs.src

module Logs : Logs.LOG

val registered_jobs : Workable_job.t list Stdlib.ref

val stop_schedule : (unit -> unit) option Stdlib.ref

module Job_instance : sig ... end

module Workable_job : sig ... end

module Make (Repo : sig ... end) : Sihl.Contract.Queue.Sig

module InMemory : sig ... end

module MariaDb : sig ... end

module PostgreSql : sig ... end