63 lines
2.1 KiB
OCaml
63 lines
2.1 KiB
OCaml
|
(**************************************************************************)
|
||
|
|
(* *)
|
||
|
|
(* Copyright (c) 2014 - 2018. *)
|
||
|
|
(* Dynamic Ledger Solutions, Inc. <contact@tezos.com> *)
|
||
|
|
(* *)
|
||
|
|
(* All rights reserved. No warranty, explicit or implicit, provided. *)
|
||
|
|
(* *)
|
||
|
|
(**************************************************************************)
|
||
|
|
|
||
|
|
open Error_monad
|
||
|
|
|
||
|
|
class type simple = object
|
||
|
|
method call_service :
|
||
|
|
'm 'p 'q 'i 'o.
|
||
|
|
([< Resto.meth ] as 'm, unit, 'p, 'q, 'i, 'o) RPC_service.t ->
|
||
|
|
'p -> 'q -> 'i -> 'o tzresult Lwt.t
|
||
|
|
end
|
||
|
|
|
||
|
|
class type streamed = object
|
||
|
|
method call_streamed_service :
|
||
|
|
'm 'p 'q 'i 'o.
|
||
|
|
([< Resto.meth ] as 'm, unit, 'p, 'q, 'i, 'o) RPC_service.t ->
|
||
|
|
on_chunk: ('o -> unit) ->
|
||
|
|
on_close: (unit -> unit) ->
|
||
|
|
'p -> 'q -> 'i -> (unit -> unit) tzresult Lwt.t
|
||
|
|
end
|
||
|
|
|
||
|
|
class type t = object
|
||
|
|
inherit simple
|
||
|
|
inherit streamed
|
||
|
|
end
|
||
|
|
|
||
|
|
val of_directory : unit RPC_directory.t -> t
|
||
|
|
|
||
|
|
type error +=
|
||
|
|
| Not_found of { meth: RPC_service.meth ;
|
||
|
|
uri: Uri.t }
|
||
|
|
| Generic_error of { meth: RPC_service.meth ;
|
||
|
|
uri: Uri.t }
|
||
|
|
|
||
|
|
val make_call :
|
||
|
|
([< Resto.meth ], unit, 'p, 'q, 'i, 'o) RPC_service.t ->
|
||
|
|
#simple -> 'p -> 'q -> 'i -> 'o tzresult Lwt.t
|
||
|
|
|
||
|
|
val make_call1 :
|
||
|
|
([< Resto.meth ], unit, unit * 'a, 'q, 'i, 'o) RPC_service.t ->
|
||
|
|
#simple -> 'a -> 'q -> 'i -> 'o tzresult Lwt.t
|
||
|
|
|
||
|
|
val make_call2 :
|
||
|
|
([< Resto.meth ], unit, (unit * 'a) * 'b, 'q, 'i, 'o) RPC_service.t ->
|
||
|
|
#simple -> 'a -> 'b -> 'q -> 'i -> 'o tzresult Lwt.t
|
||
|
|
|
||
|
|
val make_call3 :
|
||
|
|
([< Resto.meth ], unit, ((unit * 'a) * 'b) * 'c, 'q, 'i, 'o) RPC_service.t ->
|
||
|
|
#simple -> 'a -> 'b -> 'c -> 'q -> 'i -> 'o tzresult Lwt.t
|
||
|
|
|
||
|
|
type stopper = unit -> unit
|
||
|
|
|
||
|
|
val make_streamed_call :
|
||
|
|
([< Resto.meth ], unit, 'p, 'q, 'i, 'o) RPC_service.t ->
|
||
|
|
#streamed -> 'p -> 'q -> 'i ->
|
||
|
|
('o Lwt_stream.t * stopper) tzresult Lwt.t
|