Module `Make.Introspection`Source

Sourcetype connection = {

topics : Topic.Set.t;
direct : bool;
outbound : bool;

}

Sourcetype fanout_peers = {

peers : Peer.Set.t;
last_published_time : Time.t;

}

Sourcemodule Connections : sig ... end

Sourcemodule Message_cache : sig ... end

Sourcetype view = {

limits : limits;
parameters : parameters;
connections : Connections.t;
scores : Score.t Peer.Map.t;
ihave_per_heartbeat : int Peer.Map.t;
iwant_per_heartbeat : int Peer.Map.t;
mesh : Peer.Set.t Topic.Map.t;
fanout : fanout_peers Topic.Map.t;
backoff : Time.t Peer.Map.t Topic.Map.t;
message_cache : Message_cache.t;
rng : Random.State.t;
heartbeat_ticks : int64;

}

Sourcetype connected_peers_filter =

| Direct
| Subscribed_to of Topic.t
| Score_above of {
1. threshold : Score.value;
}

When selecting a set of connected peers, one can specify some criteria to filter the result.

Sourceval view : state -> view

Sourceval get_peers_in_topic_mesh : Topic.t -> view -> Peer.t list

get_peers_in_topic_mesh topic state returns the peers in the mesh of topic.

Source

val get_connected_peers : 
  ?filters:connected_peers_filter list ->
  view ->
  Peer.t list

get_connected_peers ?filters view returns the list of connected peers filtered by the given criteria.

Sourceval get_our_topics : view -> Topic.t list

get_our_topics state returns the set of topics the local peer is subscribed to.

Sourceval get_subscribed_topics : Peer.t -> view -> Topic.t list

get_subscribed_topics peer state returns the set of topics that are subscribed by peer

Sourceval get_fanout_peers : Topic.t -> view -> Peer.t list

get_fanout_peers topic state returns the fanout peers of topic.

Sourceval get_peer_score : Peer.t -> view -> Score.value

get_peer_score peer view returns the score of peer.

Sourceval get_peer_ihave_per_heartbeat : Peer.t -> view -> int

get_peer_ihave_per_heartbeat peer view returns the number of IHaves received from peer since the last heartbeat.

Sourceval get_peer_iwant_per_heartbeat : Peer.t -> view -> int

get_peer_iwant_per_heartbeat peer view returns the number of IWants sent to peer since the last heartbeat.

Sourceval get_peer_backoff : Topic.t -> Peer.t -> view -> Time.t option

get_peer_backoff topic peer view returns the backoff time of peer for topic. Returns None if the peer is not backoffed for topic.

Sourceval limits : view -> limits

Sourceval has_joined : Topic.t -> view -> bool

has_joined topic view returns true if and only if the automaton is currently tracking messages for topic. That is, the local peer has joined and hasn't left the topic.

Sourceval in_mesh : Topic.t -> Peer.t -> view -> bool

in_mesh peer topic view returns true if and only if peer is in the mesh of topic.

Sourceval is_direct : Peer.t -> view -> bool

is_direct peer view returns true if and only if peer is a direct peer.

Sourceval is_outbound : Peer.t -> view -> bool

is_outbound peer view returns true if and only if peer has an outbound connection.

Sourceval pp_connection : connection Fmt.t

Sourceval pp_connections : Connections.t Fmt.t

Sourceval pp_scores : Score.value Peer.Map.t Fmt.t

Sourceval pp_peer_map : 'a Fmt.t -> 'a Peer.Map.t Fmt.t

Sourceval pp_message_id_map : 'a Fmt.t -> 'a Message_id.Map.t Fmt.t

Sourceval pp_topic_map : 'a Fmt.t -> 'a Topic.Map.t Fmt.t

Sourceval pp_peer_set : Peer.Set.t Fmt.t

Sourceval pp_topic_set : Topic.Set.t Fmt.t

Install

Dune Dependency

Authors

Maintainers

Sources

doc/octez-libs.tezos-gossipsub/Tezos_gossipsub/Make/Introspection/index.html

Module `Make.Introspection`Source

package octez-libs

Install

Dune Dependency

Authors

Maintainers

Sources

doc/octez-libs.tezos-gossipsub/Tezos_gossipsub/Make/Introspection/index.html

Module Make.IntrospectionSource

Module `Make.Introspection`Source