tezos-dal-node-lib 19.0 · OCaml Package

module Peer : sig ... end

module Topic : sig ... end

module Message_id : sig ... end

module Message : sig ... end

module Time : sig ... end

module Span : sig ... end

module Score : sig ... end

type message = Message.t

type span = Span.t

type state

type add_peer = {

direct : bool;
outbound : bool;
peer : Peer.t;

}

type remove_peer = {

peer : Peer.t;

}

type ihave = {

peer : Peer.t;
topic : Topic.t;
message_ids : Message_id.t list;

}

type iwant = {

peer : Peer.t;
message_ids : Message_id.t list;

}

type graft = {

peer : Peer.t;
topic : Topic.t;

}

type prune = {

peer : Peer.t;
topic : Topic.t;
px : Peer.t Tezos_base.TzPervasives.Seq.t;
backoff : span;

}

type publish_message = {

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

}

type receive_message = {

sender : Peer.t;
topic : Topic.t;
message_id : Message_id.t;
message : message;

}

type join = {

topic : Topic.t;

}

type leave = {

topic : Topic.t;

}

type subscribe = {

topic : Topic.t;
peer : Peer.t;

}

type unsubscribe = {

topic : Topic.t;
peer : Peer.t;

}

type set_application_score = {

peer : Peer.t;
score : float;

}

type !_ output =

| Ihave_from_peer_with_low_score : {
1. score : Score.t;
2. threshold : float;
} -> [ `IHave ] output
| Too_many_recv_ihave_messages : {
1. count : int;
2. max : int;
} -> [ `IHave ] output
| Too_many_sent_iwant_messages : {
1. count : int;
2. max : int;
} -> [ `IHave ] output
| Message_topic_not_tracked : [ `IHave ] output
| Message_requested_message_ids : Message_id.t list -> [ `IHave ] output
| Invalid_message_id : [ `IHave ] output
| Iwant_from_peer_with_low_score : {
1. score : Score.t;
2. threshold : float;
} -> [ `IWant ] output
| On_iwant_messages_to_route : {
1. routed_message_ids : [ `Ignored | `Message of message | `Not_found | `Too_many_requests ] Message_id.Map.t;
} -> [ `IWant ] output
| Peer_filtered : [ `Graft ] output
| Unsubscribed_topic : [ `Graft ] output
| Peer_already_in_mesh : [ `Graft ] output
| Grafting_direct_peer : [ `Graft ] output
| Unexpected_grafting_peer : [ `Graft ] output
| Grafting_peer_with_negative_score : [ `Graft ] output
| Grafting_successfully : [ `Graft ] output
| Peer_backed_off : [ `Graft ] output
| Mesh_full : [ `Graft ] output
| Prune_topic_not_tracked : [ `Prune ] output
| Peer_not_in_mesh : [ `Prune ] output
| Ignore_PX_score_too_low : Score.t -> [ `Prune ] output
| No_PX : [ `Prune ] output
| PX : Peer.Set.t -> [ `Prune ] output
| Publish_message : {
1. to_publish : Peer.Set.t;
} -> [ `Publish_message ] output
| Already_published : [ `Publish_message ] output
| Route_message : {
1. to_route : Peer.Set.t;
} -> [ `Receive_message ] output
| Already_received : [ `Receive_message ] output
| Not_subscribed : [ `Receive_message ] output
| Invalid_message : [ `Receive_message ] output
| Unknown_validity : [ `Receive_message ] output
| Already_joined : [ `Join ] output
| Joining_topic : {
1. to_graft : Peer.Set.t;
} -> [ `Join ] output
| Not_joined : [ `Leave ] output
| Leaving_topic : {
1. to_prune : Peer.Set.t;
2. noPX_peers : Peer.Set.t;
} -> [ `Leave ] output
| Heartbeat : {
1. to_graft : Topic.Set.t Peer.Map.t;
2. to_prune : Topic.Set.t Peer.Map.t;
3. noPX_peers : Peer.Set.t;
} -> [ `Heartbeat ] output
| Peer_added : [ `Add_peer ] output
| Peer_already_known : [ `Add_peer ] output
| Removing_peer : [ `Remove_peer ] output
| Subscribed : [ `Subscribe ] output
| Subscribe_to_unknown_peer : [ `Subscribe ] output
| Unsubscribed : [ `Unsubscribe ] output
| Unsubscribe_from_unknown_peer : [ `Unsubscribe ] output
| Set_application_score : [ `Set_application_score ] output

val make : 
  Random.State.t ->
  (Topic.t, Peer.t, Message_id.t, span) Tezos_gossipsub__Gossipsub_intf.limits ->
  (Peer.t, Message_id.t) Tezos_gossipsub__Gossipsub_intf.parameters ->
  state

val add_peer : add_peer -> state -> state * [ `Add_peer ] output

val remove_peer : remove_peer -> state -> state * [ `Remove_peer ] output

val handle_subscribe : subscribe -> state -> state * [ `Subscribe ] output

val handle_unsubscribe : 
  unsubscribe ->
  state ->
  state * [ `Unsubscribe ] output

val handle_ihave : ihave -> state -> state * [ `IHave ] output

val handle_iwant : iwant -> state -> state * [ `IWant ] output

val handle_graft : graft -> state -> state * [ `Graft ] output

val handle_prune : prune -> state -> state * [ `Prune ] output

val handle_receive_message : 
  receive_message ->
  state ->
  state * [ `Receive_message ] output

val publish_message : 
  publish_message ->
  state ->
  state * [ `Publish_message ] output

val heartbeat : state -> state * [ `Heartbeat ] output

val join : join -> state -> state * [ `Join ] output

val leave : leave -> state -> state * [ `Leave ] output

val set_application_score : 
  set_application_score ->
  state ->
  state * [ `Set_application_score ] output

val select_px_peers : 
  state ->
  peer_to_prune:Peer.t ->
  Topic.t ->
  noPX_peers:Peer.Set.t ->
  Peer.t list

val select_gossip_messages : state -> ihave list

val pp_add_peer : Format.formatter -> add_peer -> unit

val pp_remove_peer : Format.formatter -> remove_peer -> unit

val pp_ihave : Format.formatter -> ihave -> unit

val pp_iwant : Format.formatter -> iwant -> unit

val pp_graft : Format.formatter -> graft -> unit

val pp_prune : Format.formatter -> prune -> unit

val pp_receive_message : Format.formatter -> receive_message -> unit

val pp_publish_message : Format.formatter -> publish_message -> unit

val pp_join : Format.formatter -> join -> unit

val pp_leave : Format.formatter -> leave -> unit

val pp_subscribe : Format.formatter -> subscribe -> unit

val pp_unsubscribe : Format.formatter -> unsubscribe -> unit

val pp_set_application_score : 
  Format.formatter ->
  set_application_score ->
  unit

val pp_output : Format.formatter -> 'a output -> unit

module Introspection : sig ... end

package tezos-dal-node-lib