package obatcher

  1. Overview
  2. Docs

Module type Obatcher.ServiceSource

Sourcetype t

t represents the underlying service that processes and handles batches of operations as input. Only a single batch is active at any time

Sourcetype cfg

cfg represents config variables that you want to expose to users.

Sourcetype 'a op

'a op represents an single operation on t with the return type 'a.

Sourcetype wrapped_op =
  1. | Mk : 'a op * 'a Picos.Computation.t -> wrapped_op
    (*

    wrapped_op binds the operation on the service with it's corresponding suspended continuation to run after its completion.

    *)
Sourceval init : ?cfg:cfg -> unit -> t

init () returns a new instance of the service.

Sourceval run : t -> wrapped_op array -> unit

run t ops when called on service t, processes all the operations in ops, possibly using parallelism to complete the batch.