Module Network_peer.Rpc_intf

type state = Peer.t
type ('query, 'response) rpc_fn = state -> version:int -> 'query -> 'response Async.Deferred.t
type 'r rpc_response =
| Failed_to_connect of Core.Error.t
| Connected of 'r Core.Or_error.t Envelope.Incoming.t
module type Rpc_implementation_intf = sig ... end
type ('query, 'response) rpc_implementation = (module Rpc_implementation_intf with type query = 'query and type response = 'response)
module type Rpc_interface_intf = sig ... end