Libp2pHelperInterface.RpcRequest
type unnamed_union_t =
Libp2p_ipc__Libp2p_ipc_capnp.MakeRPC(Capnp.RPC.None(Capnp.BytesMessage)).Reader.Libp2pHelperInterface.RpcRequest.unnamed_union_t =
| Configure of Configure.Request.t |
| SetGatingConfig of SetGatingConfig.Request.t |
| Listen of Listen.Request.t |
| GetListeningAddrs of GetListeningAddrs.Request.t |
| BeginAdvertising of BeginAdvertising.Request.t |
| AddPeer of AddPeer.Request.t |
| ListPeers of ListPeers.Request.t |
| GenerateKeypair of GenerateKeypair.Request.t |
| Publish of Publish.Request.t |
| Subscribe of Subscribe.Request.t |
| Unsubscribe of Unsubscribe.Request.t |
| AddStreamHandler of AddStreamHandler.Request.t |
| RemoveStreamHandler of RemoveStreamHandler.Request.t |
| OpenStream of OpenStream.Request.t |
| CloseStream of CloseStream.Request.t |
| ResetStream of ResetStream.Request.t |
| SendStream of SendStream.Request.t |
| SetNodeStatus of SetNodeStatus.Request.t |
| GetPeerNodeStatus of GetPeerNodeStatus.Request.t |
| BandwidthInfo of BandwidthInfo.Request.t |
| TestDecodeBitswapBlocks of TestDecodeBitswapBlocks.Request.t |
| TestEncodeBitswapBlocks of TestEncodeBitswapBlocks.Request.t |
| Undefined of int |
val get : t -> unnamed_union_t
val has_header : t -> bool
val header_get : t -> RpcMessageHeader.t
val header_get_pipelined :
struct_t MessageWrapper.StructRef.t ->
RpcMessageHeader.struct_t MessageWrapper.StructRef.t