package async_rpc_kernel
On This Page
package async_rpc_kernel
-
async_rpc_kernel
-
Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
Parameters
module Model : sig ... endSignature
module type Version_shared = sig ... endmodule Register_raw (Version_i : sig ... end) : sig ... endRegister_raw is like Register except you get the whole pipe to deal with.
include S
with type caller_query := Model.Caller.query
with type caller_state := Model.Caller.state
with type caller_update := Model.Caller.update
with type caller_error := Model.Caller.error
with type callee_query := Model.Callee.query
with type callee_state := Model.Callee.state
with type callee_update := Model.Callee.update
with type callee_error := Model.Callee.error
val dispatch_multi :
Connection_with_menu.t ->
Model.Caller.query ->
(Model.Caller.state
* Model.Caller.update Core_kernel.Or_error.t Async_kernel.Pipe.Reader.t
* Rpc.State_rpc.Metadata.t,
Model.Caller.error)
Core_kernel.Result.t
Core_kernel.Or_error.t
Async_kernel.Deferred.tmulti-version dispatch
val implement_multi :
?log_not_previously_seen_version:(name:string -> int -> unit) ->
('state ->
version:int ->
Model.Callee.query ->
(Model.Callee.state * Model.Callee.update Async_kernel.Pipe.Reader.t,
Model.Callee.error)
Core_kernel.Result.t
Async_kernel.Deferred.t) ->
'state Rpc.Implementation.t listimplement multiple versions at once
val rpcs : unit -> Rpc.Any.t listAll supported rpcs.
val versions : unit -> Core_kernel.Int.Set.tAll supported versions. Useful for detecting old versions that may be pruned.
On This Page