package sihl

  1. Overview
  2. Docs
The modular functional web framework

Install 

dune-project
 Dependency

github.com Readme Changelog Edit opam file Versions (35)

Authors

  1. J
    Josef Erben

Maintainers

  1. J
    josef@oxidizing.io

Sources

sihl-0.1.1.tbz
sha256=eac58e5ee9c869aa3b0f0bcee936b01c53bf7fe1febb42edd607268dfb11f4e9
sha512=012b6cf1cf6af0966059761b4916ea8aa590aa8d5809a6f480cb17e23ee10c3b9245062c4f0cf9ad98ab950391c0827c9780999d39fa16a93f7aab4b12f9ab8c

doc/sihl.queue/Queue/Service/Repo/Job/index.html

Module Repo.JobSource

This is the description of a job. A job dispatch is a job description and some arguments/input.

Sourceval default_tries : int
Sourceval default_retry_delay : Utils.Time.duration
Sourcetype 'a t = {
  1. name : Base.string;
  2. with_context : Core.Ctx.t -> Core.Ctx.t;
  3. input_to_string : 'a -> Base.string Base.option;
  4. string_to_input : Base.string Base.option -> ('a, Base.string) Base.Result.t;
  5. handle : Core.Ctx.t -> input:'a -> (Base.unit, Base.string) Base.Result.t Lwt.t;
  6. failed : Core.Ctx.t -> (Base.unit, Base.string) Base.Result.t Lwt.t;
  7. max_tries : Base.int;
  8. retry_delay : Utils.Time.duration;
}
Sourceval retry_delay : 'a t -> Utils.Time.duration
Sourceval max_tries : 'a t -> Base.int
Sourceval failed : 'a t -> Core.Ctx.t -> (Base.unit, Base.string) Base.Result.t Lwt.t
Sourceval handle : 'a t -> Core.Ctx.t -> input:'a -> (Base.unit, Base.string) Base.Result.t Lwt.t
Sourceval string_to_input : 'a t -> Base.string Base.option -> ('a, Base.string) Base.Result.t
Sourceval input_to_string : 'a t -> 'a -> Base.string Base.option
Sourceval with_context : 'a t -> Core.Ctx.t -> Core.Ctx.t
Sourceval name : 'a t -> Base.string
Sourcemodule Fields : sig ... end
Sourceval create : name:Base.string -> ?with_context:(Core.Ctx.t -> Core.Ctx.t) -> input_to_string:('a -> Base.string Base.option) -> string_to_input:(Base.string Base.option -> ('a, Base.string) Base.Result.t) -> handle: (Core.Ctx.t -> input:'a -> (Base.unit, Base.string) Base.Result.t Lwt.t) -> ?failed:(Core.Ctx.t -> (Base.unit, Base.string) Lwt_result.t) -> unit -> 'a t
Sourceval set_max_tries : Base.int -> 'a t -> 'a t
Sourceval set_retry_delay : Utils.Time.duration -> 'a t -> 'a t