package tezos-dal-node-lib

You can search for identifiers within the package.

in-package search v0.2.0

Tezos: `tezos-dal-node` library

Install

Dune Dependency

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

Authors

T

Tezos devteam

Maintainers

C

contact@tezos.com

Sources

tezos-octez-v20.1.tag.bz2

sha256=ddfb5076eeb0b32ac21c1eed44e8fc86a6743ef18ab23fff02d36e365bb73d61

sha512=d22a827df5146e0aa274df48bc2150b098177ff7e5eab52c6109e867eb0a1f0ec63e6bfbb0e3645a6c2112de3877c91a17df32ccbff301891ce4ba630c997a65

doc/tezos-dal-node-lib.gossipsub/Tezos_dal_node_lib_gossipsub/Gossipsub/Worker/index.html

Module `Gossipsub.Worker`Source

The worker module exposes instantiation of the Gossipsub worker functor, alongside the config used to instantiate the functor and the default values of the GS parameters.

Source

module Config : 
  module type of Gs_interface.Worker_config
    with type GS.Topic.t = Tezos_dal_node_services.Types.Topic.t
     and type GS.Message_id.t = Tezos_dal_node_services.Types.Message_id.t
     and type GS.Message.t = Tezos_dal_node_services.Types.Message.t
     and type GS.Peer.t = Tezos_dal_node_services.Types.Peer.t
     and type GS.Span.t = Tezos_dal_node_services.Types.Span.t
     and type GS.Time.t = Tezos_dal_node_services.Types.Time.t
     and type 'a Monad.t = 'a Lwt.t
     and type Point.t = Tezos_dal_node_services.Types.Point.t

Sourcemodule Default_parameters : module type of Gs_default_parameters

This module defines the default values for simple Gossip parameters and limits. These values are used or re-defined in the DAL node before instantiating the Gossipsub worker.

include Tezos_gossipsub.Gossipsub_intf.WORKER
  with type GS.Topic.t = Tezos_dal_node_services.Types.Topic.t
   and type GS.Message_id.t = Tezos_dal_node_services.Types.Message_id.t
   and type GS.Message.t = Tezos_dal_node_services.Types.Message.t
   and type GS.Peer.t = Tezos_dal_node_services.Types.Peer.t
   and type GS.Span.t = Tezos_dal_node_services.Types.Span.t
   and type GS.Time.t = Tezos_dal_node_services.Types.Time.t
   and type Point.t = Tezos_dal_node_services.Types.Point.t

Sourcetype t

The state of a gossipsub worker.

We (re-)export the GS, Monad and Stream modules.

include Tezos_gossipsub.Gossipsub_intf.WORKER_CONFIGURATION
  with type GS.Topic.t = Tezos_dal_node_services.Types.Topic.t
  with type GS.Message_id.t = Tezos_dal_node_services.Types.Message_id.t
  with type GS.Message.t = Tezos_dal_node_services.Types.Message.t
  with type GS.Peer.t = Tezos_dal_node_services.Types.Peer.t
  with type GS.Span.t = Tezos_dal_node_services.Types.Span.t
  with type GS.Time.t = Tezos_dal_node_services.Types.Time.t
  with type Point.t = Tezos_dal_node_services.Types.Point.t

Source

module GS : 
  Tezos_gossipsub.Gossipsub_intf.AUTOMATON
    with type Topic.t = Tezos_dal_node_services.Types.Topic.t
    with type Message_id.t = Tezos_dal_node_services.Types.Message_id.t
    with type Message.t = Tezos_dal_node_services.Types.Message.t
    with type Peer.t = Tezos_dal_node_services.Types.Peer.t
    with type Span.t = Tezos_dal_node_services.Types.Span.t
    with type Time.t = Tezos_dal_node_services.Types.Time.t

The gossipsub automaton that will be used by the worker.

Source

module Point : 
  Tezos_gossipsub.Gossipsub_intf.ITERABLE
    with type t = Tezos_dal_node_services.Types.Point.t

Sourcemodule Monad : sig ... end

Abstraction of the IO monad used by the worker.

Sourcemodule Stream : sig ... end

A mutable (FIFO) stream of data.

Sourcetype message_with_header = {

message : GS.Message.t;
topic : GS.Topic.t;
message_id : GS.Message_id.t;

}

A message together with a header, that is, a topic and an id. This corresponds to what the spec calls a "full message".

Sourcetype p2p_message =

| Graft of {
1. topic : GS.Topic.t;
}
| Prune of {
1. topic : GS.Topic.t;
2. px : GS.Peer.t Tezos_base.TzPervasives.Seq.t;
3. backoff : GS.Span.t;
}
| IHave of {
1. topic : GS.Topic.t;
2. message_ids : GS.Message_id.t list;
}
| IWant of {
1. message_ids : GS.Message_id.t list;
}
| Subscribe of {
1. topic : GS.Topic.t;
}
| Unsubscribe of {
1. topic : GS.Topic.t;
}
| Message_with_header of message_with_header

The following type defines the different kinds of messages a peer could receive from or sent to the P2P layer.

Sourcetype p2p_input =

| In_message of {
1. from_peer : GS.Peer.t;
2. p2p_message : p2p_message;
}
| New_connection of {
1. peer : GS.Peer.t;
2. direct : bool;
3. trusted : bool;
4. bootstrap : bool;
}
| Disconnection of {
1. peer : GS.Peer.t;
}

The different kinds of input events that could be received from the P2P layer.

Sourcetype app_input =

| Publish_message of message_with_header
| Join of GS.Topic.t
| Leave of GS.Topic.t

The different kinds of input events that could be received from the application layer.

Sourcetype peer_origin =

| PX of GS.Peer.t
| Trusted

A peer's origin is either another peer (i.e. advertised via PX), or none if it is trusted.

Sourcetype p2p_output =

| Out_message of {
1. to_peer : GS.Peer.t;
2. p2p_message : p2p_message;
}
(*
Emit the given p2p_message to the remote peer to_peer.
*)
| Disconnect of {
1. peer : GS.Peer.t;
}
(*
End the connection with the peer peer.
*)
| Kick of {
1. peer : GS.Peer.t;
}
(*
Kick the peer peer: the peer is disconnected and blacklisted.
*)
| Connect of {
1. peer : GS.Peer.t;
2. origin : peer_origin;
}
(*
Inform the p2p_output messages processor that we want to connect to the peer peer advertised by some other peer origin.
*)
| Connect_point of {
1. point : Point.t;
}
(*
Version of connect where we provide a point directly.
*)
| Forget of {
1. peer : GS.Peer.t;
2. origin : GS.Peer.t;
}
(*
Inform the p2p_output messages processor that we don't want to connect to the peer peer advertised by some other peer origin.
*)

The different kinds of outputs that could be emitted by the worker for the P2P layer.

Sourcetype app_output = message_with_header

The application layer will be advertised about full messages it's interested in.

Sourcetype event = private

| Heartbeat
| P2P_input of p2p_input
| App_input of app_input

The different kinds of events the Gossipsub worker handles.

Source

val make : 
  ?events_logging:(event -> unit Monad.t) ->
  ?bootstrap_points:Point.t list ->
  Random.State.t ->
  (GS.Topic.t, GS.Peer.t, GS.Message_id.t, GS.span)
    Tezos_gossipsub.Gossipsub_intf.limits ->
  (GS.Peer.t, GS.Message_id.t) Tezos_gossipsub.Gossipsub_intf.parameters ->
  t

make ~events_logging ~bootstrap_points rng limits parameters initializes a new Gossipsub automaton with the given arguments. Then, it initializes and returns a worker for it. The events_logging function can be used to define a handler for logging the worker's events. The list of bootstrap_points represents the list of initially known peers' addresses to which we may want to reconnect in the worker.

Sourceval start : GS.Topic.t list -> t -> unit

start topics state runs the (not already started) worker whose state is given together with the initial list of topics the caller is interested in.

Sourceval shutdown : t -> unit Monad.t

shutdown state allows stopping the worker whose state is given.

Sourceval app_input : t -> app_input -> unit

app_input state app_input adds the given application input app_input to the worker's input stream.

Sourceval p2p_input : t -> p2p_input -> unit

p2p_input state p2p_input adds the given P2P input p2p_input to the worker's input stream.

Sourceval p2p_output_stream : t -> p2p_output Stream.t

p2p_output_stream t returns the output stream containing data for the P2P layer.

Sourceval app_output_stream : t -> app_output Stream.t

app_output_stream t returns the output stream containing data for the application layer.

Sourceval input_events_stream : t -> event Stream.t

input_events_stream t returns the input stream in which we push events to be processed by the worker.

Sourceval is_subscribed : t -> GS.Topic.t -> bool

is_subscribed t topic checks whether topic is in the mesh of t.

Sourceval pp_p2p_output : Format.formatter -> p2p_output -> unit

Pretty-printer for values of type p2p_output.

Sourceval pp_app_output : Format.formatter -> app_output -> unit

Pretty-printer for values of type app_output.

Sourcemodule Introspection : sig ... end

Introspection and stats facilities

Sourceval stats : t -> Introspection.stats

Sourceval state : t -> GS.Introspection.view

Sourcemodule Logging : sig ... end

Sourcemodule Validate_message_hook : sig ... end

A hook to set or update messages and messages IDs validation function. Should be called once at startup and every time the DAL parameters change.

package tezos-dal-node-lib

Install

Dune Dependency

Authors

Maintainers

Sources

doc/tezos-dal-node-lib.gossipsub/Tezos_dal_node_lib_gossipsub/Gossipsub/Worker/index.html

Module Gossipsub.WorkerSource

Module `Gossipsub.Worker`Source