Module `Job.Fields`

val names : string list

val retry_delay : 
  ([< `Read | `Set_and_create ], 'a t, Sihl_utils.Time.duration)
    Fieldslib.Field.t_with_perm

val max_tries : 
  ([< `Read | `Set_and_create ], 'a t, int) Fieldslib.Field.t_with_perm

val failed : 
  ([< `Read | `Set_and_create ], 'a t, unit -> (unit, string) Result.t Lwt.t)
    Fieldslib.Field.t_with_perm

val handle : 
  ([< `Read | `Set_and_create ],
    'a t,
    input:'a ->
    (unit, string) Result.t Lwt.t)
    Fieldslib.Field.t_with_perm

val string_to_input : 
  ([< `Read | `Set_and_create ], 'a t, string option -> ('a, string) Result.t)
    Fieldslib.Field.t_with_perm

val input_to_string : 
  ([< `Read | `Set_and_create ], 'a t, 'a -> string option)
    Fieldslib.Field.t_with_perm

val name : 
  ([< `Read | `Set_and_create ], 'a t, string) Fieldslib.Field.t_with_perm

val make_creator : 
  name:
    (([< `Read | `Set_and_create ], 'a t, string) Fieldslib.Field.t_with_perm ->
      'b ->
      ('c -> string) * 'd) ->
  input_to_string:
    (([< `Read | `Set_and_create ], 'e t, 'e -> string option)
       Fieldslib.Field.t_with_perm ->
      'd ->
      ('c -> 'f -> string option) * 'g) ->
  string_to_input:
    (([< `Read | `Set_and_create ],
       'h t,
       string option ->
       ('h, string) Result.t)
       Fieldslib.Field.t_with_perm ->
      'g ->
      ('c -> string option -> ('f, string) Result.t) * 'i) ->
  handle:
    (([< `Read | `Set_and_create ],
       'j t,
       input:'j ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      'i ->
      ('c -> input:'f -> (unit, string) Result.t Lwt.t) * 'k) ->
  failed:
    (([< `Read | `Set_and_create ],
       'l t,
       unit ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      'k ->
      ('c -> unit -> (unit, string) Result.t Lwt.t) * 'm) ->
  max_tries:
    (([< `Read | `Set_and_create ], 'n t, int) Fieldslib.Field.t_with_perm ->
      'm ->
      ('c -> int) * 'o) ->
  retry_delay:
    (([< `Read | `Set_and_create ], 'p t, Sihl_utils.Time.duration)
       Fieldslib.Field.t_with_perm ->
      'o ->
      ('c -> Sihl_utils.Time.duration) * 'q) ->
  'b ->
  ('c -> 'f t) * 'q

val create : 
  name:string ->
  input_to_string:('a -> string option) ->
  string_to_input:(string option -> ('a, string) Result.t) ->
  handle:(input:'a -> (unit, string) Result.t Lwt.t) ->
  failed:(unit -> (unit, string) Result.t Lwt.t) ->
  max_tries:int ->
  retry_delay:Sihl_utils.Time.duration ->
  'a t

val map : 
  name:
    (([< `Read | `Set_and_create ], 'a t, string) Fieldslib.Field.t_with_perm ->
      string) ->
  input_to_string:
    (([< `Read | `Set_and_create ], 'b t, 'b -> string option)
       Fieldslib.Field.t_with_perm ->
      'c ->
      string option) ->
  string_to_input:
    (([< `Read | `Set_and_create ],
       'd t,
       string option ->
       ('d, string) Result.t)
       Fieldslib.Field.t_with_perm ->
      string option ->
      ('c, string) Result.t) ->
  handle:
    (([< `Read | `Set_and_create ],
       'e t,
       input:'e ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      input:'c ->
      (unit, string) Result.t Lwt.t) ->
  failed:
    (([< `Read | `Set_and_create ],
       'f t,
       unit ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      unit ->
      (unit, string) Result.t Lwt.t) ->
  max_tries:
    (([< `Read | `Set_and_create ], 'g t, int) Fieldslib.Field.t_with_perm ->
      int) ->
  retry_delay:
    (([< `Read | `Set_and_create ], 'h t, Sihl_utils.Time.duration)
       Fieldslib.Field.t_with_perm ->
      Sihl_utils.Time.duration) ->
  'c t

val iter : 
  name:
    (([< `Read | `Set_and_create ], 'a t, string) Fieldslib.Field.t_with_perm ->
      unit) ->
  input_to_string:
    (([< `Read | `Set_and_create ], 'b t, 'b -> string option)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  string_to_input:
    (([< `Read | `Set_and_create ],
       'c t,
       string option ->
       ('c, string) Result.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  handle:
    (([< `Read | `Set_and_create ],
       'd t,
       input:'d ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  failed:
    (([< `Read | `Set_and_create ],
       'e t,
       unit ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  max_tries:
    (([< `Read | `Set_and_create ], 'f t, int) Fieldslib.Field.t_with_perm ->
      unit) ->
  retry_delay:
    (([< `Read | `Set_and_create ], 'g t, Sihl_utils.Time.duration)
       Fieldslib.Field.t_with_perm ->
      unit) ->
  unit

val fold : 
  init:'a ->
  name:
    ('a ->
      ([< `Read | `Set_and_create ], 'b t, string) Fieldslib.Field.t_with_perm ->
      'c) ->
  input_to_string:
    ('c ->
      ([< `Read | `Set_and_create ], 'd t, 'd -> string option)
        Fieldslib.Field.t_with_perm ->
      'e) ->
  string_to_input:
    ('e ->
      ([< `Read | `Set_and_create ],
        'f t,
        string option ->
        ('f, string) Result.t)
        Fieldslib.Field.t_with_perm ->
      'g) ->
  handle:
    ('g ->
      ([< `Read | `Set_and_create ],
        'h t,
        input:'h ->
        (unit, string) Result.t Lwt.t)
        Fieldslib.Field.t_with_perm ->
      'i) ->
  failed:
    ('i ->
      ([< `Read | `Set_and_create ],
        'j t,
        unit ->
        (unit, string) Result.t Lwt.t)
        Fieldslib.Field.t_with_perm ->
      'k) ->
  max_tries:
    ('k ->
      ([< `Read | `Set_and_create ], 'l t, int) Fieldslib.Field.t_with_perm ->
      'm) ->
  retry_delay:
    ('m ->
      ([< `Read | `Set_and_create ], 'n t, Sihl_utils.Time.duration)
        Fieldslib.Field.t_with_perm ->
      'o) ->
  'o

val map_poly : 
  ([< `Read | `Set_and_create ], 'a t, 'b) Fieldslib.Field.user ->
  'b list

val for_all : 
  name:
    (([< `Read | `Set_and_create ], 'a t, string) Fieldslib.Field.t_with_perm ->
      bool) ->
  input_to_string:
    (([< `Read | `Set_and_create ], 'b t, 'b -> string option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  string_to_input:
    (([< `Read | `Set_and_create ],
       'c t,
       string option ->
       ('c, string) Result.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  handle:
    (([< `Read | `Set_and_create ],
       'd t,
       input:'d ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  failed:
    (([< `Read | `Set_and_create ],
       'e t,
       unit ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  max_tries:
    (([< `Read | `Set_and_create ], 'f t, int) Fieldslib.Field.t_with_perm ->
      bool) ->
  retry_delay:
    (([< `Read | `Set_and_create ], 'g t, Sihl_utils.Time.duration)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bool

val exists : 
  name:
    (([< `Read | `Set_and_create ], 'a t, string) Fieldslib.Field.t_with_perm ->
      bool) ->
  input_to_string:
    (([< `Read | `Set_and_create ], 'b t, 'b -> string option)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  string_to_input:
    (([< `Read | `Set_and_create ],
       'c t,
       string option ->
       ('c, string) Result.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  handle:
    (([< `Read | `Set_and_create ],
       'd t,
       input:'d ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  failed:
    (([< `Read | `Set_and_create ],
       'e t,
       unit ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  max_tries:
    (([< `Read | `Set_and_create ], 'f t, int) Fieldslib.Field.t_with_perm ->
      bool) ->
  retry_delay:
    (([< `Read | `Set_and_create ], 'g t, Sihl_utils.Time.duration)
       Fieldslib.Field.t_with_perm ->
      bool) ->
  bool

val to_list : 
  name:
    (([< `Read | `Set_and_create ], 'a t, string) Fieldslib.Field.t_with_perm ->
      'b) ->
  input_to_string:
    (([< `Read | `Set_and_create ], 'c t, 'c -> string option)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  string_to_input:
    (([< `Read | `Set_and_create ],
       'd t,
       string option ->
       ('d, string) Result.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  handle:
    (([< `Read | `Set_and_create ],
       'e t,
       input:'e ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  failed:
    (([< `Read | `Set_and_create ],
       'f t,
       unit ->
       (unit, string) Result.t Lwt.t)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  max_tries:
    (([< `Read | `Set_and_create ], 'g t, int) Fieldslib.Field.t_with_perm ->
      'b) ->
  retry_delay:
    (([< `Read | `Set_and_create ], 'h t, Sihl_utils.Time.duration)
       Fieldslib.Field.t_with_perm ->
      'b) ->
  'b list

module Direct : sig ... end

Install

Dune Dependency

Authors

Maintainers

Sources

doc/sihl.queue/Sihl_queue_core/Sig/Job/Fields/index.html

Module `Job.Fields`

package sihl

Install

Dune Dependency

Authors

Maintainers

Sources

doc/sihl.queue/Sihl_queue_core/Sig/Job/Fields/index.html

Module Job.Fields

Module `Job.Fields`