package sihl
The modular functional web framework
Install
Dune Dependency
Authors
Maintainers
Sources
sihl-queue-0.1.8.tbz
sha256=e77ffae26dac04e446ff07854de68a03edfd05031b5cb0dbcb6dc4a96e2d1c8e
sha512=7682c55136dbb8c68517ccd2c157a3556d966cb8565d15cf21ab270f92ea7e9ee5d3ac1479ba2e34a80f3052ca5dd1a74e964a8764c2164e3e71e9048fcdf51b
doc/sihl.queue/Sihl_queue_core/index.html
Module Sihl_queue_coreSource
This module provides a job queue. This is typically used for long-running or resource intensive tasks.
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).
module Sig : sig ... endSource
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 Sihl_queue_core__.Model.Job.tSource
val set_max_tries :
int ->
'a Sihl_queue_core__.Model.Job.t ->
'a Sihl_queue_core__.Model.Job.tSource
val set_retry_delay :
Utils.Time.duration ->
'a Sihl_queue_core__.Model.Job.t ->
'a Sihl_queue_core__.Model.Job.t