Module Libp2p_ipc

module MessageWrapper : sig ... end
type 'cap message_t = 'cap MessageWrapper.Message.t
module Reader : sig ... end
module Builder : sig ... end
module Client : sig ... end
module Service : sig ... end
type libp2p_config = Reader.Libp2pConfig.t
type gating_config = Reader.GatingConfig.t
type multiaddr = Builder.Multiaddr.t
type sequence_number = Reader.SequenceNumber.t
type validation_id = Reader.ValidationId.t
type subscription_id = Reader.SubscriptionId.t
type peer_id = Reader.PeerId.t
type peer_info = Reader.PeerInfo.t
type stream_id = Reader.StreamId.t
type validation_result = Builder.ValidationResult.t
type rpc_request_body = Builder.Libp2pHelperInterface.RpcRequest.unnamed_union_t
type rpc_response_body = Reader.Libp2pHelperInterface.RpcResponseSuccess.unnamed_union_t
type incoming_message = Reader.DaemonInterface.Message.t
type topic_level = Builder.TopicLevel.t
module Rpcs : module type of Rpcs
module Build : module type of Build
exception Received_undefined_union of string * int
module Sequence_number : sig ... end
module Subscription_id : sig ... end
val undefined_union : context:string -> int -> unit
val unsafe_parse_peer_id : peer_id -> Network_peer.Peer.Id.t
val unsafe_parse_peer : peer_info -> Network_peer.Peer.t
val stream_id_to_string : stream_id -> string
val multiaddr_to_string : Reader.Multiaddr.t -> string
val unix_nano_to_time_span : Reader.UnixNano.t -> Core.Time_ns.t
val create_multiaddr : string -> multiaddr
val create_peer_id : string -> Builder.PeerId.t
val create_libp2p_config : private_key:string -> statedir:string -> listen_on:multiaddr list -> ?metrics_port:int -> external_multiaddr:multiaddr -> network_id:string -> unsafe_no_trust_ip:bool -> flood:bool -> direct_peers:multiaddr list -> seed_peers:multiaddr list -> known_private_ip_nets:string list -> peer_exchange:bool -> peer_protection_ratio:float -> min_connections:int -> max_connections:int -> validation_queue_size:int -> gating_config:gating_config -> topic_config:string list list -> libp2p_config
val create_gating_config : banned_ips:string list -> banned_peers:Builder.PeerId.t list -> trusted_ips:string list -> trusted_peers:Builder.PeerId.t list -> isolate:bool -> gating_config
val create_rpc_request : sequence_number:sequence_number -> rpc_request_body -> rpc_request
val rpc_response_to_or_error : rpc_response -> rpc_response_body Core.Or_error.t
val rpc_request_to_outgoing_message : rpc_request -> outgoing_message
val create_validation_push_message : validation_id:validation_id -> validation_result:validation_result -> push_message
val create_add_resource_push_message : tag:int -> data:string -> push_message
val create_heartbeat_peer_push_message : peer_id:Network_peer.Peer.Id.t -> push_message
val push_message_to_outgoing_message : push_message -> outgoing_message
val read_incoming_messages : string Pipe_lib.Strict_pipe.Reader.t -> incoming_message Core.Or_error.t Pipe_lib.Strict_pipe.Reader.t
val write_outgoing_message : Async.Writer.t -> outgoing_message -> unit