sig
type plasma_cluster
type plasma_trans
type inode = int64
type errno =
[ `eaccess
| `econflict
| `ecoord
| `eexist
| `efailed
| `efailedcommit
| `efbig
| `efhier
| `einval
| `eio
| `elongtrans
| `enametoolong
| `enoent
| `enoient
| `enonode
| `enospc
| `enotrans
| `eperm
| `erofs
| `etbusy ]
type topology = [ `Chain | `Star ]
exception Plasma_error of Plasma_client.errno
exception Cluster_down of string
val open_cluster :
string ->
(string * int) list ->
Unixqueue.event_system -> Plasma_client.plasma_cluster
val open_cluster_cc :
Plasma_client_config.client_config ->
Unixqueue.event_system -> Plasma_client.plasma_cluster
val buffer_stats : Plasma_client.plasma_cluster -> string
val close_cluster : Plasma_client.plasma_cluster -> unit
val abort_cluster : Plasma_client.plasma_cluster -> unit
val cluster_name : Plasma_client.plasma_cluster -> string
val cluster_namenodes : Plasma_client.plasma_cluster -> (string * int) list
val configure_buffer : Plasma_client.plasma_cluster -> int -> unit
val configure_pref_nodes :
Plasma_client.plasma_cluster -> string list -> unit
val configure_shm_manager :
Plasma_client.plasma_cluster -> Plasma_shm.shm_manager -> unit
val shm_manager : Plasma_client.plasma_cluster -> Plasma_shm.shm_manager
val blocksize_e : Plasma_client.plasma_cluster -> int Uq_engines.engine
val blocksize : Plasma_client.plasma_cluster -> int
val fsstat_e :
Plasma_client.plasma_cluster ->
Plasma_rpcapi_aux.fsstat Uq_engines.engine
val fsstat : Plasma_client.plasma_cluster -> Plasma_rpcapi_aux.fsstat
val local_identities_e :
Plasma_client.plasma_cluster -> string list Uq_engines.engine
val local_identities : Plasma_client.plasma_cluster -> string list
val start_e :
Plasma_client.plasma_cluster ->
Plasma_client.plasma_trans Uq_engines.engine
val start : Plasma_client.plasma_cluster -> Plasma_client.plasma_trans
val commit_e : Plasma_client.plasma_trans -> unit Uq_engines.engine
val commit : Plasma_client.plasma_trans -> unit
val abort_e : Plasma_client.plasma_trans -> unit Uq_engines.engine
val abort : Plasma_client.plasma_trans -> unit
val cluster : Plasma_client.plasma_trans -> Plasma_client.plasma_cluster
val create_inode_e :
Plasma_client.plasma_trans ->
Plasma_rpcapi_aux.inodeinfo -> Plasma_client.inode Uq_engines.engine
val create_inode :
Plasma_client.plasma_trans ->
Plasma_rpcapi_aux.inodeinfo -> Plasma_client.inode
val delete_inode_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> unit Uq_engines.engine
val delete_inode :
Plasma_client.plasma_trans -> Plasma_client.inode -> unit
val get_inodeinfo_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> Plasma_rpcapi_aux.inodeinfo Uq_engines.engine
val get_inodeinfo :
Plasma_client.plasma_trans ->
Plasma_client.inode -> Plasma_rpcapi_aux.inodeinfo
val set_inodeinfo_e :
Plasma_client.plasma_trans ->
Plasma_client.inode ->
Plasma_rpcapi_aux.inodeinfo -> unit Uq_engines.engine
val set_inodeinfo :
Plasma_client.plasma_trans ->
Plasma_client.inode -> Plasma_rpcapi_aux.inodeinfo -> unit
val copy_in_e :
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 ->
Unix.file_descr ->
int64 -> Plasma_client.topology -> unit Uq_engines.engine
val copy_in :
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 -> Unix.file_descr -> int64 -> Plasma_client.topology -> unit
val copy_out_e :
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 -> Unix.file_descr -> int64 -> unit Uq_engines.engine
val copy_out :
Plasma_client.plasma_cluster ->
Plasma_client.inode -> int64 -> Unix.file_descr -> int64 -> unit
type strmem = [ `Memory of Netsys_mem.memory | `String of string ]
val read_e :
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 ->
Plasma_client.strmem ->
int ->
int -> (int * bool * Plasma_rpcapi_aux.inodeinfo) Uq_engines.engine
val read :
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 ->
Plasma_client.strmem ->
int -> int -> int * bool * Plasma_rpcapi_aux.inodeinfo
val write_e :
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 -> Plasma_client.strmem -> int -> int -> int Uq_engines.engine
val write :
Plasma_client.plasma_cluster ->
Plasma_client.inode -> int64 -> Plasma_client.strmem -> int -> int -> int
val flush_e :
Plasma_client.plasma_cluster ->
Plasma_client.inode -> int64 -> int64 -> unit Uq_engines.engine
val flush :
Plasma_client.plasma_cluster ->
Plasma_client.inode -> int64 -> int64 -> unit
val drop_inode :
Plasma_client.plasma_cluster -> Plasma_client.inode -> unit
val flush_all_e : Plasma_client.plasma_cluster -> unit Uq_engines.engine
val flush_all : Plasma_client.plasma_cluster -> unit
val lookup_e :
Plasma_client.plasma_trans ->
string -> Plasma_client.inode Uq_engines.engine
val lookup : Plasma_client.plasma_trans -> string -> Plasma_client.inode
val dir_lookup_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> string -> Plasma_client.inode Uq_engines.engine
val dir_lookup :
Plasma_client.plasma_trans ->
Plasma_client.inode -> string -> Plasma_client.inode
val rev_lookup_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> string list Uq_engines.engine
val rev_lookup :
Plasma_client.plasma_trans -> Plasma_client.inode -> string list
val link_count_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> int Uq_engines.engine
val link_count : Plasma_client.plasma_trans -> Plasma_client.inode -> int
val link_e :
Plasma_client.plasma_trans ->
string -> Plasma_client.inode -> unit Uq_engines.engine
val link :
Plasma_client.plasma_trans -> string -> Plasma_client.inode -> unit
val unlink_e :
Plasma_client.plasma_trans -> string -> unit Uq_engines.engine
val unlink : Plasma_client.plasma_trans -> string -> unit
val list_inode_e :
Plasma_client.plasma_trans ->
Plasma_client.inode ->
(string * Plasma_client.inode) list Uq_engines.engine
val list_inode :
Plasma_client.plasma_trans ->
Plasma_client.inode -> (string * Plasma_client.inode) list
val list_e :
Plasma_client.plasma_trans ->
string -> (string * Plasma_client.inode) list Uq_engines.engine
val list :
Plasma_client.plasma_trans ->
string -> (string * Plasma_client.inode) list
val create_file_e :
Plasma_client.plasma_trans ->
string ->
Plasma_rpcapi_aux.inodeinfo -> Plasma_client.inode Uq_engines.engine
val create_file :
Plasma_client.plasma_trans ->
string -> Plasma_rpcapi_aux.inodeinfo -> Plasma_client.inode
val mkdir_e :
Plasma_client.plasma_trans ->
string ->
Plasma_rpcapi_aux.inodeinfo -> Plasma_client.inode Uq_engines.engine
val mkdir :
Plasma_client.plasma_trans ->
string -> Plasma_rpcapi_aux.inodeinfo -> Plasma_client.inode
val regular_ii :
Plasma_client.plasma_cluster -> int -> Plasma_rpcapi_aux.inodeinfo
val symlink_ii :
Plasma_client.plasma_cluster -> string -> Plasma_rpcapi_aux.inodeinfo
val dir_ii :
Plasma_client.plasma_cluster -> int -> Plasma_rpcapi_aux.inodeinfo
val get_blocklist_e :
Plasma_client.plasma_trans ->
Plasma_client.inode ->
int64 -> int -> Plasma_rpcapi_aux.blockinfo list Uq_engines.engine
val get_blocklist :
Plasma_client.plasma_trans ->
Plasma_client.inode -> int64 -> int -> Plasma_rpcapi_aux.blockinfo list
val retry : string -> int -> ('a -> 'b) -> 'a -> 'b
end
