package tezos-dal-node-lib
Install
Dune Dependency
Authors
Maintainers
Sources
sha256=ddfb5076eeb0b32ac21c1eed44e8fc86a6743ef18ab23fff02d36e365bb73d61
sha512=d22a827df5146e0aa274df48bc2150b098177ff7e5eab52c6109e867eb0a1f0ec63e6bfbb0e3645a6c2112de3877c91a17df32ccbff301891ce4ba630c997a65
doc/tezos-dal-node-lib.gossipsub/Tezos_dal_node_lib_gossipsub/Gossipsub/Transport_layer/index.html
Module Gossipsub.Transport_layerSource
The transport layer module exposes the needed primitives, interface and default parameters for the instantiation of the Octez-p2p library.
val create :
network_name:string ->
public_addr:Tezos_base.TzPervasives.P2p_point.Id.t ->
is_bootstrap_peer:bool ->
Tezos_p2p.P2p.config ->
Tezos_p2p_services.P2p_limits.t ->
t Tezos_base.TzPervasives.tzresult Lwt.tcreate ~network_name ~is_bootstrap_peer ~public_addr config limits creates a new instance of type t. It is a wrapper on top of P2p.create.
val activate :
?additional_points:Tezos_base.TzPervasives.P2p_point.Id.t list ->
t ->
unit Lwt.tactivate ?additional_points t activates the given transport layer t. It is a wrapper on top of P2p.activate. If some additional_points are given, they are added to t's known points.
val connect :
t ->
?timeout:Ptime.Span.t ->
Tezos_base.TzPervasives.P2p_point.Id.t ->
unit Tezos_base.TzPervasives.tzresult Lwt.tconnect t ?timeout point initiates a connection to the point point. The promise returned by this function is resolved once the P2P handhshake successfully completes. If the timeout is set, an error is returned if the P2P handshake takes more than timeout to complete.
val disconnect_point :
t ->
?wait:bool ->
Tezos_base.TzPervasives.P2p_point.Id.t ->
unit Lwt.tdisconnect_point t ?wait point initiaties a disconnection to the point point. The promise returned by this function is fullfiled when the socket is closed on our side. If wait is true, we do not close the socket before having canceled all the current messages in the write buffer. Should not matter in practice.
Due to the following issue https://gitlab.com/tezos/tezos/-/issues/5319
it may occur that a discconnection takes several minutes.
val disconnect_peer :
t ->
?wait:bool ->
Tezos_crypto.Crypto_box.Public_key_hash.t ->
unit Lwt.tdisconnect_peer t ?wait point initiaties a disconnection to the point peer. The promise returned by this function is fullfiled when the socket is closed on our side. If wait is true, we do not close the socket before having canceled all the current messages in the write buffer. Should not matter in practice.
Due to the following issue https://gitlab.com/tezos/tezos/-/issues/5319
it may occur that a discconnection takes several minutes.
val get_points :
?connected:bool ->
t ->
Tezos_base.TzPervasives.P2p_point.Id.t list Tezos_base.TzPervasives.tzresult
Lwt.tget_points ?connected t returns a list of points. If connected is true (default), it returns only points we are currently connected. Otherwise, it returns a list of known points (points for which we were already successfully connected in the past.)
val get_points_info :
?connected:bool ->
t ->
(Tezos_base.TzPervasives.P2p_point.Id.t
* Tezos_base.TzPervasives.P2p_point.Info.t)
list
Tezos_base.TzPervasives.tzresult
Lwt.tget_points_info ?connected t returns a list of info for points. If connected is true (default), it returns only info for points we are currently connected. Otherwise, it returns a list of infos for known points (points for which we were already successfully connected in the past.)
val get_point_info :
t ->
Tezos_base.TzPervasives.P2p_point.Id.t ->
Tezos_base.TzPervasives.P2p_point.Info.t option
Tezos_base.TzPervasives.tzresult
Lwt.tget_point_info t point returns the info of the corresponding point if found.
val get_peers :
?connected:bool ->
t ->
Tezos_base.TzPervasives.P2p_peer.Id.t list Tezos_base.TzPervasives.tzresult
Lwt.tget_peers ?connected t returns a list of peers. If connected is true (default), it returns only the peers we are connected to. Otherwise, it returns a list of known peers (peers for which we were already successfully connected in the past.)
val get_peers_info :
?connected:bool ->
t ->
(Tezos_base.TzPervasives.P2p_peer.Id.t
* Tezos_dal_node_services.Types.P2P.Peer.Info.t)
list
Tezos_base.TzPervasives.tzresult
Lwt.tget_peers_info ?connected t returns a list of info for peers. If connected is true (default), it returns only info for peers we are currently connected. Otherwise, it returns a list of infos for known peers (peers for which we were already successfully connected in the past.)
val get_peer_info :
t ->
Tezos_base.TzPervasives.P2p_peer.Id.t ->
Tezos_dal_node_services.Types.P2P.Peer.Info.t option
Tezos_base.TzPervasives.tzresult
Lwt.tget_peer_info t peer returns the info of the corresponding peer if found.
val patch_peer :
t ->
Tezos_base.TzPervasives.P2p_peer.Id.t ->
[ `Ban | `Open | `Trust ] option ->
Tezos_dal_node_services.Types.P2P.Peer.Info.t option
Tezos_base.TzPervasives.tzresult
Lwt.tpatch_peer t peer acl patches the acl of the corresponding peer if found and returns the info. When acl is None this is equivalent to get_peer_info.