package octez-libs

  1. Overview
  2. No Docs
A package that contains multiple base libraries used by the Octez suite

Install 

dune-project
 Dependency

www.tezos.com Edit opam file Versions (5)

Authors

  1. T
    Tezos devteam

Maintainers

  1. C
    contact@tezos.com

Sources

tezos-18.1.tar.gz
sha256=aa2f5bc99cc4ca2217c52a1af2a2cdfd3b383208cb859ca2e79ca0903396ca1d
sha512=d68bb3eb615e3dcccc845fddfc9901c95b3c6dc8e105e39522ce97637b1308a7fa7aa1d271351d5933febd7476b2819e1694f31198f1f0919681f1f9cc97cb3a

doc/octez-libs.tezos-workers/Tezos_workers/Worker/MakeSingle/index.html

Module Worker.MakeSingleSource

MakeSingle (Name) (Request) (Types) is the same as using MakeGroup and then MakeWorker. It's a special case which you can use if you only ever need a single instantiation.

Parameters

Signature

module Name = Name
module Request = Request
module Types = Types
Sourcetype 'kind t

A handle to a specific worker, parameterized by the type of internal message buffer.

Sourcetype 'kind table

A handle to a table of workers.

Sourcetype 'a queue

Internal buffer kinds used as parameters to t.

Sourceand bounded
Sourceand infinite
Sourcetype dropbox
Sourcetype 'a message_error =
  1. | Closed of Tezos_base.TzPervasives.error list option
  2. | Request_error of 'a
  3. | Any of exn

An error returned when waiting for a message pushed to the worker. Closed errs is returned if the worker is terminated or has crashed. If the worker is terminated, errs is an empty list. Request_error err is returned if the request failed with an error. Any exn is returned if the request failed with an exception.

Sourcetype _ buffer_kind =
  1. | Queue : infinite queue buffer_kind
  2. | Bounded : {
    1. size : int;
    } -> bounded queue buffer_kind
  3. | Dropbox : {
    1. merge : dropbox t -> any_request -> any_request option -> any_request option;
    } -> dropbox buffer_kind

Supported kinds of internal buffers.

Sourceand any_request =
  1. | Any_request : (_, _) Request.t -> any_request
Sourceval create_table : 'kind buffer_kind -> 'kind table

Create a table of workers.

Sourcemodule type HANDLERS = sig ... end

The callback handlers specific to each worker instance.

Sourceval launch : 'kind table -> ?timeout:Tezos_base.Time.System.Span.t -> Name.t -> Types.parameters -> (module HANDLERS with type launch_error = 'launch_error and type self = 'kind t) -> ('kind t, 'launch_error) result Lwt.t

Creates a new worker instance. Parameter queue_size not passed means unlimited queue.

Sourceval shutdown : _ t -> unit Lwt.t

Triggers a worker termination and waits for its completion. Cannot be called from within the handlers.

Sourcemodule type BOX = sig ... end

The following interface are common elements of multiple modules below. They are used to minimize repetition.

Sourcemodule type QUEUE = sig ... end
Sourcemodule Dropbox : sig ... end
Sourcemodule Queue : sig ... end
Sourceval canceler : _ t -> Lwt_canceler.t

Exports the canceler to allow cancellation of other tasks when this worker is shutdown or when it dies.

Sourceval trigger_shutdown : _ t -> unit

Triggers a worker termination.

Sourceval state : _ t -> Types.state

Access the internal state, once initialized.

Sourceval with_state : _ t -> (Types.state -> (unit, 'request_error) result Lwt.t) -> (unit, 'request_error) result Lwt.t

with_state w f calls f on the current state of worker w if it was intialized and not closed or crashed, otherwise returns immediately.

Sourceval pending_requests : _ queue t -> (Tezos_base.Time.System.t * Request.view) list

Introspect the message queue, gives the times requests were pushed.

Get the running status of a worker.

Get the request being treated by a worker. Gives the time the request was pushed, and the time its treatment started.

Sourceval list : 'a table -> (Name.t * 'a t) list

Lists the running workers in this group.

Sourceval find_opt : 'a table -> Name.t -> 'a t option

find_opt table n is Some worker if the worker is in the table and has name n.