package sihl
The modular functional web framework
Install
Dune Dependency
Authors
Maintainers
Sources
sihl-0.1.3.tbz
sha256=3d1acdd1eae24a7131033656f90b5d20c1621e6ef92957edf88a09b8b5f2d9e9
sha512=d224f54e20a9465c7a03d534dadcb2b9a181ae87c13731840db945aab37534f6f3982c5cb25a197e90c17d8772da062b19fa92bb93ed53a8b736c3776a7776db
doc/sihl.queue/Queue/index.html
Module QueueSource
This module provides a job queue. This is typically used for long-running or resource intensive tasks.
This is the description of a job. A job dispatch is a job description and some arguments/input.
This is the actual job instance that is derived from the job description 'a Job.t and some input. This needs to be serialized and persisted for persistent job queues.
A workable job can process a job instance that is persisted. We can not store the job directly because of the polymorphic type ('a Job.t).
Source
val create_job :
name:string ->
?with_context:(Core.Ctx.t -> Core.Ctx.t) ->
input_to_string:('a -> string option) ->
string_to_input:(string option -> ('a, string) Result.t) ->
handle:(Core.Ctx.t -> input:'a -> (unit, string) Result.t Lwt.t) ->
?failed:(Core.Ctx.t -> (unit, string) Result.t Lwt.t) ->
unit ->
'a Queue__.Queue_core.Job.tSource
val set_retry_delay :
Utils.Time.duration ->
'a Queue__.Queue_core.Job.t ->
'a Queue__.Queue_core.Job.t