DaemonInterface.PushMessage
type unnamed_union_t =
Libp2p_ipc__Libp2p_ipc_capnp.MakeRPC(Capnp.RPC.None(Capnp.BytesMessage)).Builder.DaemonInterface.PushMessage.unnamed_union_t =
| PeerConnected of PeerConnected.t |
| PeerDisconnected of PeerDisconnected.t |
| GossipReceived of GossipReceived.t |
| IncomingStream of IncomingStream.t |
| StreamLost of StreamLost.t |
| StreamComplete of StreamComplete.t |
| StreamMessageReceived of StreamMessageReceived.t |
| ResourceUpdated of ResourceUpdate.t |
| Undefined of int |
val get : t -> unnamed_union_t
val peer_connected_set_reader :
t ->
PeerConnected.struct_t reader_t ->
PeerConnected.t
val peer_connected_set_builder : t -> PeerConnected.t -> PeerConnected.t
val peer_connected_init : t -> PeerConnected.t
val peer_disconnected_set_reader :
t ->
PeerDisconnected.struct_t reader_t ->
PeerDisconnected.t
val peer_disconnected_set_builder :
t ->
PeerDisconnected.t ->
PeerDisconnected.t
val peer_disconnected_init : t -> PeerDisconnected.t
val gossip_received_set_reader :
t ->
GossipReceived.struct_t reader_t ->
GossipReceived.t
val gossip_received_set_builder : t -> GossipReceived.t -> GossipReceived.t
val gossip_received_init : t -> GossipReceived.t
val incoming_stream_set_reader :
t ->
IncomingStream.struct_t reader_t ->
IncomingStream.t
val incoming_stream_set_builder : t -> IncomingStream.t -> IncomingStream.t
val incoming_stream_init : t -> IncomingStream.t
val stream_lost_set_reader : t -> StreamLost.struct_t reader_t -> StreamLost.t
val stream_lost_set_builder : t -> StreamLost.t -> StreamLost.t
val stream_lost_init : t -> StreamLost.t
val stream_complete_set_reader :
t ->
StreamComplete.struct_t reader_t ->
StreamComplete.t
val stream_complete_set_builder : t -> StreamComplete.t -> StreamComplete.t
val stream_complete_init : t -> StreamComplete.t
val stream_message_received_set_reader :
t ->
StreamMessageReceived.struct_t reader_t ->
StreamMessageReceived.t
val stream_message_received_set_builder :
t ->
StreamMessageReceived.t ->
StreamMessageReceived.t
val stream_message_received_init : t -> StreamMessageReceived.t
val resource_updated_set_reader :
t ->
ResourceUpdate.struct_t reader_t ->
ResourceUpdate.t
val resource_updated_set_builder : t -> ResourceUpdate.t -> ResourceUpdate.t
val resource_updated_init : t -> ResourceUpdate.t
val has_header : t -> bool
val header_get : t -> PushMessageHeader.t
val header_set_reader :
t ->
PushMessageHeader.struct_t reader_t ->
PushMessageHeader.t
val header_set_builder : t -> PushMessageHeader.t -> PushMessageHeader.t
val header_init : t -> PushMessageHeader.t
val init_root : ?message_size:int -> unit -> t