sig
module Make'Datanode :
functor (U'C : Rpc_client.USE_CLIENT) ->
sig
module V1 :
sig
type t = U'C.t
val _program : Rpc_program.t
val null :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'null'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'null'res
val null'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'null'res) -> unit) ->
unit
val identity :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'identity'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'identity'res
val identity'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'identity'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'identity'res) -> unit) ->
unit
val size :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'size'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'size'res
val size'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'size'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'size'res) -> unit) ->
unit
val blocksize :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'blocksize'res
val blocksize'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'blocksize'res) ->
unit) ->
unit
val clustername :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'clustername'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'clustername'res
val clustername'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'clustername'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'clustername'res) ->
unit) ->
unit
val read :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'read'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'read'res
val read'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'read'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'read'res) -> unit) ->
unit
val write :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'write'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'write'res
val write'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'write'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'write'res) -> unit) ->
unit
val copy :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'copy'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'copy'res
val copy'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'copy'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'copy'res) -> unit) ->
unit
val zero :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'zero'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'zero'res
val zero'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'zero'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'zero'res) -> unit) ->
unit
val sync :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'sync'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'sync'res
val sync'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'sync'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'sync'res) -> unit) ->
unit
val alloc_shm_if_local :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res
val alloc_shm_if_local'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
((unit ->
Plasma_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res) ->
unit) ->
unit
val udsocket_if_local :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res
val udsocket_if_local'async :
U'C.t ->
Plasma_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res) ->
unit) ->
unit
end
end
module Datanode :
sig
module V1 :
sig
type t = Rpc_client.t
val create_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
val create_portmapped_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
string -> Rpc.protocol -> Rpc_client.t
val create_client2 :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
val _program : Rpc_program.t
val null :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'null'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'null'res
val null'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'null'res) -> unit) ->
unit
val identity :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'identity'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'identity'res
val identity'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'identity'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'identity'res) -> unit) ->
unit
val size :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'size'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'size'res
val size'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'size'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'size'res) -> unit) ->
unit
val blocksize :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'blocksize'res
val blocksize'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'blocksize'res) -> unit) ->
unit
val clustername :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'clustername'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'clustername'res
val clustername'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'clustername'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'clustername'res) ->
unit) ->
unit
val read :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'read'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'read'res
val read'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'read'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'read'res) -> unit) ->
unit
val write :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'write'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'write'res
val write'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'write'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'write'res) -> unit) ->
unit
val copy :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'copy'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'copy'res
val copy'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'copy'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'copy'res) -> unit) ->
unit
val zero :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'zero'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'zero'res
val zero'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'zero'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'zero'res) -> unit) ->
unit
val sync :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'sync'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'sync'res
val sync'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'sync'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'sync'res) -> unit) ->
unit
val alloc_shm_if_local :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res
val alloc_shm_if_local'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res) ->
unit) ->
unit
val udsocket_if_local :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
Plasma_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res
val udsocket_if_local'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
((unit -> Plasma_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res) ->
unit) ->
unit
end
end
module Make'Filesystem :
functor (U'C : Rpc_client.USE_CLIENT) ->
sig
module V1 :
sig
type t = U'C.t
val _program : Rpc_program.t
val null :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'null'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'null'res
val null'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'null'res) -> unit) ->
unit
val begin_transaction :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'begin_transaction'res
val begin_transaction'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
((unit ->
Plasma_rpcapi_aux.t_Filesystem'V1'begin_transaction'res) ->
unit) ->
unit
val commit_transaction :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'commit_transaction'res
val commit_transaction'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
((unit ->
Plasma_rpcapi_aux.t_Filesystem'V1'commit_transaction'res) ->
unit) ->
unit
val abort_transaction :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'abort_transaction'res
val abort_transaction'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
((unit ->
Plasma_rpcapi_aux.t_Filesystem'V1'abort_transaction'res) ->
unit) ->
unit
val get_inodeinfo :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res
val get_inodeinfo'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res) ->
unit) ->
unit
val allocate_inode :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_inode'res
val allocate_inode'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'allocate_inode'res) ->
unit) ->
unit
val update_inodeinfo :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res
val update_inodeinfo'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
((unit ->
Plasma_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res) ->
unit) ->
unit
val delete_inode :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'delete_inode'res
val delete_inode'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'delete_inode'res) ->
unit) ->
unit
val get_blocks :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocks'res
val get_blocks'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'get_blocks'res) ->
unit) ->
unit
val allocate_blocks :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res
val allocate_blocks'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res) ->
unit) ->
unit
val free_blocks :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'free_blocks'res
val free_blocks'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'free_blocks'res) ->
unit) ->
unit
val get_fsstat :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_fsstat'res
val get_fsstat'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'get_fsstat'res) ->
unit) ->
unit
val rereplicate :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'rereplicate'res
val rereplicate'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'rereplicate'res) ->
unit) ->
unit
val get_blocksize :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocksize'res
val get_blocksize'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'get_blocksize'res) ->
unit) ->
unit
val lookup :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'lookup'res
val lookup'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'lookup'res) -> unit) ->
unit
val rev_lookup :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'rev_lookup'res
val rev_lookup'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'rev_lookup'res) ->
unit) ->
unit
val link_count :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'link_count'res
val link_count'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'link_count'res) ->
unit) ->
unit
val link :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'link'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'link'res
val link'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'link'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'link'res) -> unit) ->
unit
val unlink :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'unlink'res
val unlink'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'unlink'res) -> unit) ->
unit
val list :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'list'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'list'res
val list'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'list'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'list'res) -> unit) ->
unit
val set_block_checksum :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res
val set_block_checksum'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
((unit ->
Plasma_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res) ->
unit) ->
unit
val iterate :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'iterate'res
val iterate'async :
U'C.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'iterate'res) ->
unit) ->
unit
end
end
module Filesystem :
sig
module V1 :
sig
type t = Rpc_client.t
val create_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
val create_portmapped_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
string -> Rpc.protocol -> Rpc_client.t
val create_client2 :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
val _program : Rpc_program.t
val null :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'null'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'null'res
val null'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'null'res) -> unit) ->
unit
val begin_transaction :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'begin_transaction'res
val begin_transaction'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'begin_transaction'res) ->
unit) ->
unit
val commit_transaction :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'commit_transaction'res
val commit_transaction'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
((unit ->
Plasma_rpcapi_aux.t_Filesystem'V1'commit_transaction'res) ->
unit) ->
unit
val abort_transaction :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'abort_transaction'res
val abort_transaction'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'abort_transaction'res) ->
unit) ->
unit
val get_inodeinfo :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res
val get_inodeinfo'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res) ->
unit) ->
unit
val allocate_inode :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_inode'res
val allocate_inode'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'allocate_inode'res) ->
unit) ->
unit
val update_inodeinfo :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res
val update_inodeinfo'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res) ->
unit) ->
unit
val delete_inode :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'delete_inode'res
val delete_inode'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'delete_inode'res) ->
unit) ->
unit
val get_blocks :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocks'res
val get_blocks'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'get_blocks'res) ->
unit) ->
unit
val allocate_blocks :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res
val allocate_blocks'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res) ->
unit) ->
unit
val free_blocks :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'free_blocks'res
val free_blocks'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'free_blocks'res) ->
unit) ->
unit
val get_fsstat :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_fsstat'res
val get_fsstat'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'get_fsstat'res) ->
unit) ->
unit
val rereplicate :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'rereplicate'res
val rereplicate'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'rereplicate'res) ->
unit) ->
unit
val get_blocksize :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocksize'res
val get_blocksize'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'get_blocksize'res) ->
unit) ->
unit
val lookup :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'lookup'res
val lookup'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'lookup'res) -> unit) ->
unit
val rev_lookup :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'rev_lookup'res
val rev_lookup'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'rev_lookup'res) ->
unit) ->
unit
val link_count :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'link_count'res
val link_count'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'link_count'res) ->
unit) ->
unit
val link :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'link'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'link'res
val link'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'link'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'link'res) -> unit) ->
unit
val unlink :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'unlink'res
val unlink'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'unlink'res) -> unit) ->
unit
val list :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'list'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'list'res
val list'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'list'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'list'res) -> unit) ->
unit
val set_block_checksum :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res
val set_block_checksum'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
((unit ->
Plasma_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res) ->
unit) ->
unit
val iterate :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
Plasma_rpcapi_aux.t_Filesystem'V1'iterate'res
val iterate'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
((unit -> Plasma_rpcapi_aux.t_Filesystem'V1'iterate'res) -> unit) ->
unit
end
end
module Make'Coordination :
functor (U'C : Rpc_client.USE_CLIENT) ->
sig
module V1 :
sig
type t = U'C.t
val _program : Rpc_program.t
val null :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'null'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'null'res
val null'async :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Coordination'V1'null'res) -> unit) ->
unit
val find_coordinator :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'find_coordinator'res
val find_coordinator'async :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
((unit ->
Plasma_rpcapi_aux.t_Coordination'V1'find_coordinator'res) ->
unit) ->
unit
val find_namenodes :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'find_namenodes'res
val find_namenodes'async :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
((unit ->
Plasma_rpcapi_aux.t_Coordination'V1'find_namenodes'res) ->
unit) ->
unit
val is_coordinator :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'is_coordinator'res
val is_coordinator'async :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
((unit ->
Plasma_rpcapi_aux.t_Coordination'V1'is_coordinator'res) ->
unit) ->
unit
val clustername :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'clustername'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'clustername'res
val clustername'async :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'clustername'arg ->
((unit -> Plasma_rpcapi_aux.t_Coordination'V1'clustername'res) ->
unit) ->
unit
val find_inodecaches :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_inodecaches'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'find_inodecaches'res
val find_inodecaches'async :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_inodecaches'arg ->
((unit ->
Plasma_rpcapi_aux.t_Coordination'V1'find_inodecaches'res) ->
unit) ->
unit
val local_identities :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'local_identities'res
val local_identities'async :
U'C.t ->
Plasma_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
((unit ->
Plasma_rpcapi_aux.t_Coordination'V1'local_identities'res) ->
unit) ->
unit
end
end
module Coordination :
sig
module V1 :
sig
type t = Rpc_client.t
val create_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
val create_portmapped_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
string -> Rpc.protocol -> Rpc_client.t
val create_client2 :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
val _program : Rpc_program.t
val null :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'null'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'null'res
val null'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Coordination'V1'null'res) -> unit) ->
unit
val find_coordinator :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'find_coordinator'res
val find_coordinator'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
((unit ->
Plasma_rpcapi_aux.t_Coordination'V1'find_coordinator'res) ->
unit) ->
unit
val find_namenodes :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'find_namenodes'res
val find_namenodes'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
((unit -> Plasma_rpcapi_aux.t_Coordination'V1'find_namenodes'res) ->
unit) ->
unit
val is_coordinator :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'is_coordinator'res
val is_coordinator'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
((unit -> Plasma_rpcapi_aux.t_Coordination'V1'is_coordinator'res) ->
unit) ->
unit
val clustername :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'clustername'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'clustername'res
val clustername'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'clustername'arg ->
((unit -> Plasma_rpcapi_aux.t_Coordination'V1'clustername'res) ->
unit) ->
unit
val find_inodecaches :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_inodecaches'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'find_inodecaches'res
val find_inodecaches'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'find_inodecaches'arg ->
((unit ->
Plasma_rpcapi_aux.t_Coordination'V1'find_inodecaches'res) ->
unit) ->
unit
val local_identities :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
Plasma_rpcapi_aux.t_Coordination'V1'local_identities'res
val local_identities'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
((unit ->
Plasma_rpcapi_aux.t_Coordination'V1'local_identities'res) ->
unit) ->
unit
end
end
module Make'Dn_admin :
functor (U'C : Rpc_client.USE_CLIENT) ->
sig
module V1 :
sig
type t = U'C.t
val _program : Rpc_program.t
val null :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'null'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'null'res
val null'async :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'null'res) -> unit) ->
unit
val add_datanode :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'add_datanode'res
val add_datanode'async :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'add_datanode'res) ->
unit) ->
unit
val enable_datanode :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res
val enable_datanode'async :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res) ->
unit) ->
unit
val disable_datanode :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res
val disable_datanode'async :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res) ->
unit) ->
unit
val is_enabled :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'is_enabled'res
val is_enabled'async :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'is_enabled'res) ->
unit) ->
unit
val lookup :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'lookup'res
val lookup'async :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'lookup'res) -> unit) ->
unit
val datanodes :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'datanodes'res
val datanodes'async :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'datanodes'res) ->
unit) ->
unit
val destroy_datanode :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res
val destroy_datanode'async :
U'C.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res) ->
unit) ->
unit
end
end
module Dn_admin :
sig
module V1 :
sig
type t = Rpc_client.t
val create_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
val create_portmapped_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
string -> Rpc.protocol -> Rpc_client.t
val create_client2 :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
val _program : Rpc_program.t
val null :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'null'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'null'res
val null'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'null'res) -> unit) ->
unit
val add_datanode :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'add_datanode'res
val add_datanode'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'add_datanode'res) ->
unit) ->
unit
val enable_datanode :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res
val enable_datanode'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res) ->
unit) ->
unit
val disable_datanode :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res
val disable_datanode'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res) ->
unit) ->
unit
val is_enabled :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'is_enabled'res
val is_enabled'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'is_enabled'res) -> unit) ->
unit
val lookup :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'lookup'res
val lookup'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'lookup'res) -> unit) ->
unit
val datanodes :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'datanodes'res
val datanodes'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'datanodes'res) -> unit) ->
unit
val destroy_datanode :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
Plasma_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res
val destroy_datanode'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
((unit -> Plasma_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res) ->
unit) ->
unit
end
end
module Make'Inode_cache :
functor (U'C : Rpc_client.USE_CLIENT) ->
sig
module V1 :
sig
type t = U'C.t
val _program : Rpc_program.t
val null :
U'C.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'null'arg ->
Plasma_rpcapi_aux.t_Inode_cache'V1'null'res
val null'async :
U'C.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Inode_cache'V1'null'res) -> unit) ->
unit
val is_up_to_date :
U'C.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'arg ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'res
val is_up_to_date'async :
U'C.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'arg ->
((unit -> Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'res) ->
unit) ->
unit
val is_up_to_date_seqno :
U'C.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'arg ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'res
val is_up_to_date_seqno'async :
U'C.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'arg ->
((unit ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'res) ->
unit) ->
unit
end
end
module Inode_cache :
sig
module V1 :
sig
type t = Rpc_client.t
val create_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
Rpc_client.connector -> Rpc.protocol -> Rpc_client.t
val create_portmapped_client :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 ->
string -> Rpc.protocol -> Rpc_client.t
val create_client2 :
?esys:Unixqueue.event_system ->
?program_number:Rtypes.uint4 ->
?version_number:Rtypes.uint4 -> Rpc_client.mode2 -> Rpc_client.t
val _program : Rpc_program.t
val null :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'null'arg ->
Plasma_rpcapi_aux.t_Inode_cache'V1'null'res
val null'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'null'arg ->
((unit -> Plasma_rpcapi_aux.t_Inode_cache'V1'null'res) -> unit) ->
unit
val is_up_to_date :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'arg ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'res
val is_up_to_date'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'arg ->
((unit -> Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date'res) ->
unit) ->
unit
val is_up_to_date_seqno :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'arg ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'res
val is_up_to_date_seqno'async :
Rpc_client.t ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'arg ->
((unit ->
Plasma_rpcapi_aux.t_Inode_cache'V1'is_up_to_date_seqno'res) ->
unit) ->
unit
end
end
end
