package tezos-dal-node-lib

You can search for identifiers within the package.

in-package search v0.2.0

tezos-dal-node-lib
- Tezos_dal_node_lib
  - Dal_node_client
    
    cctxt
    
    unix_cctxt
  - Dal_plugin
    
    T
    
    Proto
    
    Mempool
tezos-dal-node-lib.gossipsub
- Tezos_dal_node_lib_gossipsub
  - Gossipsub
    
    Transport_layer
    
    Default_parameters
    
    P2p_config
    
    P2p_limits
    
    P2p_reconnection_config
    
    Interface
    
    Transport_layer_hooks
    
    Worker
    
    Config
    
    GS
    
    Introspection
    
    Connections
    
    Message_cache
    
    Internal_for_tests
    
    Introspection
    
    Map
    
    Message
    
    Message_id
    
    Map
    
    Set
    
    Peer
    
    Map
    
    Set
    
    Time
    
    Topic
    
    Map
    
    Set
    
    Message
    
    Message_id
    
    Map
    
    Set
    
    Peer
    
    Map
    
    Set
    
    Score
    
    Internal_for_tests
    
    Introspection
    
    Span
    
    Time
    
    Topic
    
    Map
    
    Set
    
    Monad
    
    Stream
    
    Default_parameters
    
    Limits
    
    Peer_filter
    
    Score
    
    Topic_score
    
    GS
    
    Introspection
    
    Connections
    
    Message_cache
    
    Internal_for_tests
    
    Introspection
    
    Map
    
    Message
    
    Message_id
    
    Map
    
    Set
    
    Peer
    
    Map
    
    Set
    
    Time
    
    Topic
    
    Map
    
    Set
    
    Message
    
    Message_id
    
    Map
    
    Set
    
    Peer
    
    Map
    
    Set
    
    Score
    
    Internal_for_tests
    
    Introspection
    
    Span
    
    Time
    
    Topic
    
    Map
    
    Set
    
    Introspection
    
    Logging
    
    Monad
    
    Stream
    
    Validate_message_hook
  - Gs_default_parameters
    
    Limits
    
    Peer_filter
    
    Score
    
    Topic_score
  - Gs_interface
    
    Validate_message_hook
    
    Worker_config
    
    GS
    
    Introspection
    
    Connections
    
    Message_cache
    
    Internal_for_tests
    
    Introspection
    
    Map
    
    Message
    
    Message_id
    
    Map
    
    Set
    
    Peer
    
    Map
    
    Set
    
    Time
    
    Topic
    
    Map
    
    Set
    
    Message
    
    Message_id
    
    Map
    
    Set
    
    Peer
    
    Map
    
    Set
    
    Score
    
    Internal_for_tests
    
    Introspection
    
    Span
    
    Time
    
    Topic
    
    Map
    
    Set
    
    Monad
    
    Stream
    
    Worker_instance
    
    GS
    
    Introspection
    
    Connections
    
    Message_cache
    
    Internal_for_tests
    
    Introspection
    
    Map
    
    Message
    
    Message_id
    
    Map
    
    Set
    
    Peer
    
    Map
    
    Set
    
    Time
    
    Topic
    
    Map
    
    Set
    
    Message
    
    Message_id
    
    Map
    
    Set
    
    Peer
    
    Map
    
    Set
    
    Score
    
    Internal_for_tests
    
    Introspection
    
    Span
    
    Time
    
    Topic
    
    Map
    
    Set
    
    Introspection
    
    Monad
    
    Stream
  - Gs_logging
  - Gs_transport_connection
  - Transport_layer_default_parameters
    
    P2p_config
    
    P2p_limits
    
    P2p_reconnection_config
  - Transport_layer_interface

Legend:
Library
Module
Module type
Parameter
Class
Class type

val activate : 
  Gs_interface.Worker_instance.t ->
  (Transport_layer_interface.p2p_message,
    Tezos_dal_node_services.Types.P2P.Metadata.Peer.t,
    Tezos_dal_node_services.Types.P2P.Metadata.Connection.t)
    Tezos_p2p.P2p.t ->
  app_messages_callback:
    (Tezos_dal_node_services.Types.Message.t ->
      Tezos_dal_node_services.Types.Message_id.t ->
      unit Tezos_base.TzPervasives.tzresult Lwt.t) ->
  unit Lwt.t

activate gs_worker transport_layer ~app_messages_handler connects the given gs_worker and transport_layer. (Dis)connections and messages of the transport layer are forwarded to the GS worker. P2P output messages and (dis)connection requests are forwarded from the GS worker to the transport layer.

The app_messages_handler is invoked when some application messages are put by the Gossipsub worker in the application output stream.