package sihl
The modular functional web framework
Install
Dune Dependency
Authors
Maintainers
Sources
sihl-queue-0.1.7.tbz
sha256=a432c28b88610b8ef914aa93d1be5bf3ad4b357ebaa8e95848e981ea30611cd4
sha512=e85a2c2935973826ef29191d6a784dca53660c8df55a98174d7326a8a73865cf7f35bfae034b179d85f30bb809985da3c6d170608da2e9ac9763b8fd1f8a1a4e
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