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 ->
Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'null'res) -> unit) ->
unit
val identity :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'identity'res
val identity'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'identity'res) -> unit) ->
unit
val size :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'size'res
val size'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'size'res) -> unit) ->
unit
val blocksize :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res
val blocksize'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res) -> unit) ->
unit
val clustername :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'clustername'res
val clustername'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'clustername'res) -> unit) ->
unit
val read :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'read'res
val read'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'read'res) -> unit) ->
unit
val write :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'write'res
val write'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'write'res) -> unit) ->
unit
val copy :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'copy'res
val copy'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'copy'res) -> unit) ->
unit
val zero :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'zero'res
val zero'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'zero'res) -> unit) ->
unit
val sync :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'sync'res
val sync'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'sync'res) -> unit) ->
unit
val alloc_shm_if_local :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res
val alloc_shm_if_local'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res) ->
unit) ->
unit
val udsocket_if_local :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res
val udsocket_if_local'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
((unit -> Pfs_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 ->
Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'null'res) -> unit) -> unit
val identity :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'identity'res
val identity'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'identity'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'identity'res) -> unit) ->
unit
val size :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'size'res
val size'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'size'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'size'res) -> unit) -> unit
val blocksize :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res
val blocksize'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'blocksize'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'blocksize'res) -> unit) ->
unit
val clustername :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'clustername'res
val clustername'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'clustername'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'clustername'res) -> unit) ->
unit
val read :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'read'res
val read'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'read'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'read'res) -> unit) -> unit
val write :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'write'res
val write'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'write'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'write'res) -> unit) ->
unit
val copy :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'copy'res
val copy'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'copy'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'copy'res) -> unit) -> unit
val zero :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'zero'res
val zero'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'zero'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'zero'res) -> unit) -> unit
val sync :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'sync'res
val sync'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'sync'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'sync'res) -> unit) -> unit
val alloc_shm_if_local :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res
val alloc_shm_if_local'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'alloc_shm_if_local'res) ->
unit) ->
unit
val udsocket_if_local :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res
val udsocket_if_local'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode'V1'udsocket_if_local'res) ->
unit) ->
unit
end
end
module Make'Datanode_ctrl :
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 ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res) -> unit) ->
unit
val reset_all_safetrans :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res
val reset_all_safetrans'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
((unit ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res) ->
unit) ->
unit
val cancel_safetrans :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res
val cancel_safetrans'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
((unit ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res) ->
unit) ->
unit
val safetrans :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res
val safetrans'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res) ->
unit) ->
unit
end
end
module Datanode_ctrl :
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 ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'null'res) -> unit) ->
unit
val reset_all_safetrans :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res
val reset_all_safetrans'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'arg ->
((unit ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'reset_all_safetrans'res) ->
unit) ->
unit
val cancel_safetrans :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res
val cancel_safetrans'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'cancel_safetrans'res) ->
unit) ->
unit
val safetrans :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res
val safetrans'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_ctrl'V1'safetrans'res) ->
unit) ->
unit
end
end
module Make'Datanode_io :
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 ->
Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'null'res) -> unit) ->
unit
val read :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read'res
val read'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'read'res) -> unit) ->
unit
val read_shm :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res
val read_shm'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res) -> unit) ->
unit
val write :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write'res
val write'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'write'res) -> unit) ->
unit
val write_shm :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res
val write_shm'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res) ->
unit) ->
unit
val copy :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res
val copy'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res) -> unit) ->
unit
val sync :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res
val sync'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res) -> unit) ->
unit
val size :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'size'res
val size'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'size'res) -> unit) ->
unit
val identity :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res
val identity'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res) -> unit) ->
unit
end
end
module Datanode_io :
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 ->
Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'null'res) -> unit) ->
unit
val read :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read'res
val read'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'read'res) -> unit) ->
unit
val read_shm :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res
val read_shm'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'read_shm'res) -> unit) ->
unit
val write :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write'res
val write'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'write'res) -> unit) ->
unit
val write_shm :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res
val write_shm'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'write_shm'res) -> unit) ->
unit
val copy :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res
val copy'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'copy'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'copy'res) -> unit) ->
unit
val sync :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res
val sync'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'sync'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'sync'res) -> unit) ->
unit
val size :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'size'res
val size'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'size'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'size'res) -> unit) ->
unit
val identity :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res
val identity'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_io'V1'identity'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_io'V1'identity'res) -> unit) ->
unit
end
end
module Make'Datanode_discover :
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 ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_discover'V1'null'res) ->
unit) ->
unit
val identity :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'arg ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'res
val identity'async :
U'C.t ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'res) ->
unit) ->
unit
end
end
module Datanode_discover :
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 ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'null'arg ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_discover'V1'null'res) -> unit) ->
unit
val identity :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'arg ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'res
val identity'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'arg ->
((unit -> Pfs_rpcapi_aux.t_Datanode_discover'V1'identity'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 ->
Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'null'res) -> unit) ->
unit
val begin_transaction :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res
val begin_transaction'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res) ->
unit) ->
unit
val commit_transaction :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res
val commit_transaction'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res) ->
unit) ->
unit
val abort_transaction :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res
val abort_transaction'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res) ->
unit) ->
unit
val get_inodeinfo :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res
val get_inodeinfo'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res) ->
unit) ->
unit
val allocate_inode :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res
val allocate_inode'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res) ->
unit) ->
unit
val update_inodeinfo :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res
val update_inodeinfo'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res) ->
unit) ->
unit
val delete_inode :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res
val delete_inode'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res) ->
unit) ->
unit
val get_blocks :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res
val get_blocks'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res) ->
unit) ->
unit
val allocate_blocks :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res
val allocate_blocks'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res) ->
unit) ->
unit
val free_blocks :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res
val free_blocks'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res) ->
unit) ->
unit
val get_fsstat :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res
val get_fsstat'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res) ->
unit) ->
unit
val rereplicate :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res
val rereplicate'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res) ->
unit) ->
unit
val get_blocksize :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res
val get_blocksize'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res) ->
unit) ->
unit
val get_params :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_params'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_params'res
val get_params'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_params'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_params'res) ->
unit) ->
unit
val lookup :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res
val lookup'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res) -> unit) ->
unit
val rev_lookup :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res
val rev_lookup'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res) ->
unit) ->
unit
val rev_lookup_dir :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'res
val rev_lookup_dir'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'res) ->
unit) ->
unit
val link_count :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res
val link_count'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res) ->
unit) ->
unit
val link :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'link'res
val link'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link'res) -> unit) ->
unit
val link_at :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_at'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_at'res
val link_at'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_at'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link_at'res) -> unit) ->
unit
val unlink :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res
val unlink'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res) -> unit) ->
unit
val unlink_at :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'res
val unlink_at'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'res) -> unit) ->
unit
val list :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'list'res
val list'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'list'res) -> unit) ->
unit
val rename :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename'res
val rename'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rename'res) -> unit) ->
unit
val rename_at :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'res
val rename_at'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'res) -> unit) ->
unit
val namelock :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'namelock'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'namelock'res
val namelock'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'namelock'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'namelock'res) -> unit) ->
unit
val set_block_checksum :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res
val set_block_checksum'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res) ->
unit) ->
unit
val iterate :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res
val iterate'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res) -> unit) ->
unit
val impersonate :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'res
val impersonate'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'res) ->
unit) ->
unit
val get_auth_ticket :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'res
val get_auth_ticket'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'res) ->
unit) ->
unit
val renew_auth_ticket :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'res
val renew_auth_ticket'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'res) ->
unit) ->
unit
val read_admin_table :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'res
val read_admin_table'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'res) ->
unit) ->
unit
val write_admin_table :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'res
val write_admin_table'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'res) ->
unit) ->
unit
val is_up_to_date :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'res
val is_up_to_date'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'res) ->
unit) ->
unit
val is_up_to_date_seqno :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'res
val is_up_to_date_seqno'async :
U'C.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'arg ->
((unit ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'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 ->
Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'null'res) -> unit) ->
unit
val begin_transaction :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res
val begin_transaction'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'begin_transaction'res) ->
unit) ->
unit
val commit_transaction :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res
val commit_transaction'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'commit_transaction'res) ->
unit) ->
unit
val abort_transaction :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res
val abort_transaction'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'abort_transaction'res) ->
unit) ->
unit
val get_inodeinfo :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res
val get_inodeinfo'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_inodeinfo'res) ->
unit) ->
unit
val allocate_inode :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res
val allocate_inode'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'allocate_inode'res) ->
unit) ->
unit
val update_inodeinfo :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res
val update_inodeinfo'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'update_inodeinfo'res) ->
unit) ->
unit
val delete_inode :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res
val delete_inode'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'delete_inode'res) ->
unit) ->
unit
val get_blocks :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res
val get_blocks'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_blocks'res) -> unit) ->
unit
val allocate_blocks :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res
val allocate_blocks'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'allocate_blocks'res) ->
unit) ->
unit
val free_blocks :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res
val free_blocks'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'free_blocks'res) -> unit) ->
unit
val get_fsstat :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res
val get_fsstat'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_fsstat'res) -> unit) ->
unit
val rereplicate :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res
val rereplicate'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rereplicate'res) -> unit) ->
unit
val get_blocksize :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res
val get_blocksize'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_blocksize'res) ->
unit) ->
unit
val get_params :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_params'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_params'res
val get_params'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_params'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_params'res) -> unit) ->
unit
val lookup :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res
val lookup'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'lookup'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'lookup'res) -> unit) ->
unit
val rev_lookup :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res
val rev_lookup'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup'res) -> unit) ->
unit
val rev_lookup_dir :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'res
val rev_lookup_dir'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rev_lookup_dir'res) ->
unit) ->
unit
val link_count :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res
val link_count'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_count'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link_count'res) -> unit) ->
unit
val link :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'link'res
val link'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link'res) -> unit) ->
unit
val link_at :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_at'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_at'res
val link_at'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'link_at'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'link_at'res) -> unit) ->
unit
val unlink :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res
val unlink'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'unlink'res) -> unit) ->
unit
val unlink_at :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'res
val unlink_at'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'unlink_at'res) -> unit) ->
unit
val list :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'list'res
val list'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'list'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'list'res) -> unit) ->
unit
val rename :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename'res
val rename'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rename'res) -> unit) ->
unit
val rename_at :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'res
val rename_at'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'rename_at'res) -> unit) ->
unit
val namelock :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'namelock'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'namelock'res
val namelock'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'namelock'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'namelock'res) -> unit) ->
unit
val set_block_checksum :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res
val set_block_checksum'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'set_block_checksum'res) ->
unit) ->
unit
val iterate :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res
val iterate'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'iterate'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'iterate'res) -> unit) ->
unit
val impersonate :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'res
val impersonate'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'impersonate'res) -> unit) ->
unit
val get_auth_ticket :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'res
val get_auth_ticket'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'get_auth_ticket'res) ->
unit) ->
unit
val renew_auth_ticket :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'res
val renew_auth_ticket'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'renew_auth_ticket'res) ->
unit) ->
unit
val read_admin_table :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'res
val read_admin_table'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'read_admin_table'res) ->
unit) ->
unit
val write_admin_table :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'res
val write_admin_table'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'write_admin_table'res) ->
unit) ->
unit
val is_up_to_date :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'res
val is_up_to_date'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date'res) ->
unit) ->
unit
val is_up_to_date_seqno :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'arg ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'res
val is_up_to_date_seqno'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'arg ->
((unit -> Pfs_rpcapi_aux.t_Filesystem'V1'is_up_to_date_seqno'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 ->
Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'null'res) -> unit) ->
unit
val find_coordinator :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res
val find_coordinator'async :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res) ->
unit) ->
unit
val find_namenodes :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res
val find_namenodes'async :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res) ->
unit) ->
unit
val is_coordinator :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res
val is_coordinator'async :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res) ->
unit) ->
unit
val clustername :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'clustername'res
val clustername'async :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'clustername'res) ->
unit) ->
unit
val local_identities :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'local_identities'res
val local_identities'async :
U'C.t ->
Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
((unit -> Pfs_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 ->
Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'null'res) -> unit) ->
unit
val find_coordinator :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res
val find_coordinator'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'find_coordinator'res) ->
unit) ->
unit
val find_namenodes :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res
val find_namenodes'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'find_namenodes'res) ->
unit) ->
unit
val is_coordinator :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res
val is_coordinator'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'is_coordinator'res) ->
unit) ->
unit
val clustername :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'clustername'res
val clustername'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'clustername'arg ->
((unit -> Pfs_rpcapi_aux.t_Coordination'V1'clustername'res) ->
unit) ->
unit
val local_identities :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
Pfs_rpcapi_aux.t_Coordination'V1'local_identities'res
val local_identities'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Coordination'V1'local_identities'arg ->
((unit -> Pfs_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 ->
Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'null'res) -> unit) ->
unit
val add_datanode :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res
val add_datanode'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res) ->
unit) ->
unit
val enable_datanode :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res
val enable_datanode'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res) ->
unit) ->
unit
val disable_datanode :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res
val disable_datanode'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res) ->
unit) ->
unit
val is_enabled :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res
val is_enabled'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res) -> unit) ->
unit
val is_alive :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'res
val is_alive'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'res) -> unit) ->
unit
val fsstat :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'res
val fsstat'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'res) -> unit) ->
unit
val lookup :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res
val lookup'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res) -> unit) ->
unit
val datanodes :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res
val datanodes'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res) -> unit) ->
unit
val destroy_datanode :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res
val destroy_datanode'async :
U'C.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
((unit -> Pfs_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 ->
Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'null'res) -> unit) -> unit
val add_datanode :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res
val add_datanode'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'add_datanode'res) -> unit) ->
unit
val enable_datanode :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res
val enable_datanode'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'enable_datanode'res) ->
unit) ->
unit
val disable_datanode :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res
val disable_datanode'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'disable_datanode'res) ->
unit) ->
unit
val is_enabled :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res
val is_enabled'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'is_enabled'res) -> unit) ->
unit
val is_alive :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'res
val is_alive'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'is_alive'res) -> unit) ->
unit
val fsstat :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'res
val fsstat'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'fsstat'res) -> unit) ->
unit
val lookup :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res
val lookup'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'lookup'res) -> unit) ->
unit
val datanodes :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res
val datanodes'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'datanodes'res) -> unit) ->
unit
val destroy_datanode :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res
val destroy_datanode'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'arg ->
((unit -> Pfs_rpcapi_aux.t_Dn_admin'V1'destroy_datanode'res) ->
unit) ->
unit
end
end
module Make'Elect :
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 ->
Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
Pfs_rpcapi_aux.t_Elect'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Elect'V1'null'res) -> unit) -> unit
val announce :
U'C.t ->
Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
Pfs_rpcapi_aux.t_Elect'V1'announce'res
val announce'async :
U'C.t ->
Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
((unit -> Pfs_rpcapi_aux.t_Elect'V1'announce'res) -> unit) ->
unit
val set_coordinator :
U'C.t ->
Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res
val set_coordinator'async :
U'C.t ->
Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
((unit -> Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res) ->
unit) ->
unit
end
end
module Elect :
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 ->
Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
Pfs_rpcapi_aux.t_Elect'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Elect'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Elect'V1'null'res) -> unit) -> unit
val announce :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
Pfs_rpcapi_aux.t_Elect'V1'announce'res
val announce'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Elect'V1'announce'arg ->
((unit -> Pfs_rpcapi_aux.t_Elect'V1'announce'res) -> unit) ->
unit
val set_coordinator :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res
val set_coordinator'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'arg ->
((unit -> Pfs_rpcapi_aux.t_Elect'V1'set_coordinator'res) -> unit) ->
unit
end
end
module Make'Nameslave :
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 ->
Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'null'res) -> unit) ->
unit
val begin_transaction :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res
val begin_transaction'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res) ->
unit) ->
unit
val prepare_commit :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res
val prepare_commit'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res) ->
unit) ->
unit
val commit :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'commit'res
val commit'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'commit'res) -> unit) ->
unit
val set_ds_cache :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'res
val set_ds_cache'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'res) ->
unit) ->
unit
val push_inode_ins :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res
val push_inode_ins'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res) ->
unit) ->
unit
val push_inode_upd :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res
val push_inode_upd'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res) ->
unit) ->
unit
val push_inode_upd_time :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res
val push_inode_upd_time'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res) ->
unit) ->
unit
val push_inode_set_anonymous :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'res
val push_inode_set_anonymous'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'arg ->
((unit ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'res) ->
unit) ->
unit
val push_inode_del :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res
val push_inode_del'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res) ->
unit) ->
unit
val push_blockalloc_upd :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res
val push_blockalloc_upd'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res) ->
unit) ->
unit
val push_datastore_upd :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res
val push_datastore_upd'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res) ->
unit) ->
unit
val push_datastore_del :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res
val push_datastore_del'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res) ->
unit) ->
unit
val push_revision_upd :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res
val push_revision_upd'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res) ->
unit) ->
unit
val push_inodeblocks_ins :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res
val push_inodeblocks_ins'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
((unit ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res) ->
unit) ->
unit
val push_inodeblocks_del :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res
val push_inodeblocks_del'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
((unit ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res) ->
unit) ->
unit
val push_names_ins :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res
val push_names_ins'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res) ->
unit) ->
unit
val push_names_del :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res
val push_names_del'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res) ->
unit) ->
unit
val push_admin_table :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'res
val push_admin_table'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'res) ->
unit) ->
unit
val push_revision_clear :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'res
val push_revision_clear'async :
U'C.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'res) ->
unit) ->
unit
end
end
module Nameslave :
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 ->
Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'null'res) -> unit) ->
unit
val begin_transaction :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res
val begin_transaction'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'begin_transaction'res) ->
unit) ->
unit
val prepare_commit :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res
val prepare_commit'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'prepare_commit'res) ->
unit) ->
unit
val commit :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'commit'res
val commit'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'commit'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'commit'res) -> unit) ->
unit
val set_ds_cache :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'res
val set_ds_cache'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'set_ds_cache'res) -> unit) ->
unit
val push_inode_ins :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res
val push_inode_ins'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_ins'res) ->
unit) ->
unit
val push_inode_upd :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res
val push_inode_upd'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd'res) ->
unit) ->
unit
val push_inode_upd_time :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res
val push_inode_upd_time'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_upd_time'res) ->
unit) ->
unit
val push_inode_set_anonymous :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'res
val push_inode_set_anonymous'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'arg ->
((unit ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_set_anonymous'res) ->
unit) ->
unit
val push_inode_del :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res
val push_inode_del'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inode_del'res) ->
unit) ->
unit
val push_blockalloc_upd :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res
val push_blockalloc_upd'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_blockalloc_upd'res) ->
unit) ->
unit
val push_datastore_upd :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res
val push_datastore_upd'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_upd'res) ->
unit) ->
unit
val push_datastore_del :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res
val push_datastore_del'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_datastore_del'res) ->
unit) ->
unit
val push_revision_upd :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res
val push_revision_upd'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_upd'res) ->
unit) ->
unit
val push_inodeblocks_ins :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res
val push_inodeblocks_ins'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_ins'res) ->
unit) ->
unit
val push_inodeblocks_del :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res
val push_inodeblocks_del'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_inodeblocks_del'res) ->
unit) ->
unit
val push_names_ins :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res
val push_names_ins'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_names_ins'res) ->
unit) ->
unit
val push_names_del :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res
val push_names_del'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_names_del'res) ->
unit) ->
unit
val push_admin_table :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'res
val push_admin_table'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_admin_table'res) ->
unit) ->
unit
val push_revision_clear :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'arg ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'res
val push_revision_clear'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'arg ->
((unit -> Pfs_rpcapi_aux.t_Nameslave'V1'push_revision_clear'res) ->
unit) ->
unit
end
end
module Make'Monitor :
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 ->
Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
Pfs_rpcapi_aux.t_Monitor'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Monitor'V1'null'res) -> unit) ->
unit
val start :
U'C.t ->
Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
Pfs_rpcapi_aux.t_Monitor'V1'start'res
val start'async :
U'C.t ->
Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
((unit -> Pfs_rpcapi_aux.t_Monitor'V1'start'res) -> unit) ->
unit
end
end
module Monitor :
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 ->
Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
Pfs_rpcapi_aux.t_Monitor'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Monitor'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Monitor'V1'null'res) -> unit) -> unit
val start :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
Pfs_rpcapi_aux.t_Monitor'V1'start'res
val start'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Monitor'V1'start'arg ->
((unit -> Pfs_rpcapi_aux.t_Monitor'V1'start'res) -> unit) -> unit
end
end
module Make'Auth :
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 ->
Pfs_rpcapi_aux.t_Auth'V1'null'arg ->
Pfs_rpcapi_aux.t_Auth'V1'null'res
val null'async :
U'C.t ->
Pfs_rpcapi_aux.t_Auth'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Auth'V1'null'res) -> unit) -> unit
val get_auth_ticket :
U'C.t ->
Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'arg ->
Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'res
val get_auth_ticket'async :
U'C.t ->
Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'arg ->
((unit -> Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'res) -> unit) ->
unit
end
end
module Auth :
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 ->
Pfs_rpcapi_aux.t_Auth'V1'null'arg ->
Pfs_rpcapi_aux.t_Auth'V1'null'res
val null'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Auth'V1'null'arg ->
((unit -> Pfs_rpcapi_aux.t_Auth'V1'null'res) -> unit) -> unit
val get_auth_ticket :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'arg ->
Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'res
val get_auth_ticket'async :
Rpc_client.t ->
Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'arg ->
((unit -> Pfs_rpcapi_aux.t_Auth'V1'get_auth_ticket'res) -> unit) ->
unit
end
end
end
