package octez-libs

You can search for identifiers within the package.

in-package search v0.2.0

A package that contains multiple base libraries used by the Octez suite

Install

Dune Dependency

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

Authors

T

Tezos devteam

Maintainers

C

contact@tezos.com

Sources

octez-19.1.tar.gz

sha256=55ea1fb8bb3273a7fc270ca8f650d45c56449665619482aad9bc12f3ea736b7e

sha512=fec850fc2d17d7490bbabd5147d62aad13b3aaed8774270f8a38ab419670ed03e0fd30cf8642a97984eca5c2446726fe590ad99c015f7ec50919dc7652f25053

doc/octez-libs.distributed-plonk/Distributed_plonk/Worker/Make/D/index.html

Module `Make.D`Source

include Distributed.Process with type 'a io = 'a Lwt.t

exception Init_more_than_once

exception InvalidNode of Distributed.Node_id.t

exception Local_only_mode

type 'a t

type 'a io = 'a Lwt.t

type message_type

type 'a matcher_list

type monitor_ref

type monitor_reason =

| Normal of Distributed.Process_id.t
| Exception of Distributed.Process_id.t * exn
| UnkownNodeId of Distributed.Process_id.t * Distributed.Node_id.t
| NoProcess of Distributed.Process_id.t

module Remote_config : sig ... end

module Local_config : sig ... end

type node_config =

| Local of Local_config.t
| Remote of Remote_config.t

val return : 'a -> 'a t

val (>>=) : 'a t -> ('a -> 'b t) -> 'b t

type proc_rep =

| Fun of unit -> unit t
| Registered of string

val register : string -> (Distributed.Process_id.t -> unit -> unit t) -> unit t

val fail : exn -> 'a t

val catch : (unit -> 'a t) -> (exn -> 'a t) -> 'a t

val spawn : 
  ?monitor:bool ->
  Distributed.Node_id.t ->
  proc_rep ->
  Distributed.Process_id.t ->
  (Distributed.Process_id.t * monitor_ref option) t

val case : (message_type -> (unit -> 'a t) option) -> 'a matcher_list

val termination_case : (monitor_reason -> 'a t) -> 'a matcher_list

val (|.) : 'a matcher_list -> 'a matcher_list -> 'a matcher_list

val receive : ?timeout_duration:float -> 'a matcher_list -> 'a option t

val receive_loop : ?timeout_duration:float -> bool matcher_list -> unit t

val send : Distributed.Process_id.t -> message_type -> unit t

val (>!) : Distributed.Process_id.t -> message_type -> unit t

val broadcast : Distributed.Node_id.t -> message_type -> unit t

val monitor : Distributed.Process_id.t -> monitor_ref t

val unmonitor : monitor_ref -> unit t

val get_self_pid : Distributed.Process_id.t t

val get_self_node : Distributed.Node_id.t t

val get_remote_node : string -> Distributed.Node_id.t option t

val get_remote_nodes : Distributed.Node_id.t list t

val add_remote_node : string -> int -> string -> Distributed.Node_id.t t

val remove_remote_node : Distributed.Node_id.t -> unit t

val lift_io : 'a io -> 'a t

val run_node : ?process:(unit -> unit t) -> node_config -> unit io

module M : 
  Communication.Distributed_wrapper.Enriched_message_type
    with type 'a step = 'a Msg.step
    with type 'a request = 'a Msg.request
    with type 'a reply = 'a Msg.reply

Additional monadic interface

val (let*) : 'a t -> ('a -> 'b t) -> 'b t

val (let+) : 'a t -> ('a -> 'b) -> 'b t

val mapM : ('a -> 'b t) -> 'a list -> 'b list t

val dmap : 
  pids:Distributed.Process_id.t list ->
  request:('a -> index:int -> 'step M.request) ->
  reply:('step M.reply -> (unit -> 'b t) option) ->
  'a list ->
  'b list t

dmap ~pids ~request ~reply l sends requests built by applying request to the elements of l to the workers pids and waits to receive a valid reply from each worker.

val handle_request : 
  Distributed.Process_id.t ->
  step:'step M.step ->
  handler:('step M.request -> (unit -> ('step M.reply * 'b) t) option) ->
  'b t

handle_request master_pid ~setp ~handler l waits to receive a request for a given step, process it through handler and sends the reply to master_pid. The handler might also return some additional data ('b) that isn't meant to be sent back to the master, but rather kept by the worker for future computation.