sig
type plasma_cluster
type plasma_trans
type inode = int64
type errno =
[ `eaccess
| `ebadpath
| `econflict
| `ecoord
| `eexist
| `efailed
| `efailedcommit
| `efbig
| `efhier
| `einval
| `eio
| `eisdir
| `elongtrans
| `eloop
| `enametoolong
| `enoent
| `enonode
| `enospc
| `enotdir
| `enotempty
| `enotrans
| `eperm
| `erofs
| `estale
| `etbusy ]
type topology = [ `Chain | `Star ]
type copy_in_flags = [ `Late_datasync | `No_datasync ]
type copy_out_flags = [ `No_truncate ]
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 event_system : Plasma_client.plasma_cluster -> Unixqueue.event_system
val sync : ('a -> 'b Uq_engines.engine) -> 'a -> 'b
val dump_buffers : Plasma_client.plasma_cluster -> unit
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 get_cached_inodeinfo_e :
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
bool -> Plasma_rpcapi_aux.inodeinfo Uq_engines.engine
val get_cached_inodeinfo :
Plasma_client.plasma_cluster ->
Plasma_client.inode -> bool -> 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 truncate_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> int64 -> unit Uq_engines.engine
val truncate :
Plasma_client.plasma_trans -> Plasma_client.inode -> int64 -> unit
val copy_in_e :
?flags:Plasma_client.copy_in_flags list ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 ->
Unix.file_descr ->
int64 -> Plasma_client.topology -> int64 Uq_engines.engine
val copy_in :
?flags:Plasma_client.copy_in_flags list ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 -> Unix.file_descr -> int64 -> Plasma_client.topology -> int64
val copy_in_from_buf_e :
?flags:Plasma_client.copy_in_flags list ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 ->
Netsys_mem.memory ->
int -> Plasma_client.topology -> int Uq_engines.engine
val copy_in_from_buf :
?flags:Plasma_client.copy_in_flags list ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 -> Netsys_mem.memory -> int -> Plasma_client.topology -> int
val copy_out_e :
?flags:Plasma_client.copy_out_flags list ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 -> Unix.file_descr -> int64 -> int64 Uq_engines.engine
val copy_out :
?flags:Plasma_client.copy_out_flags list ->
Plasma_client.plasma_cluster ->
Plasma_client.inode -> int64 -> Unix.file_descr -> int64 -> int64
val copy_out_to_buf_e :
?flags:Plasma_client.copy_out_flags list ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 -> Netsys_mem.memory -> int -> int Uq_engines.engine
val copy_out_to_buf :
?flags:Plasma_client.copy_out_flags list ->
Plasma_client.plasma_cluster ->
Plasma_client.inode -> int64 -> Netsys_mem.memory -> int -> int
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 get_write_eof :
Plasma_client.plasma_cluster -> Plasma_client.inode -> int64
val get_write_mtime :
Plasma_client.plasma_cluster ->
Plasma_client.inode -> Plasma_rpcapi_aux.time
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 -> bool -> Plasma_client.inode Uq_engines.engine
val lookup :
Plasma_client.plasma_trans -> string -> bool -> Plasma_client.inode
val dir_lookup_e :
Plasma_client.plasma_trans ->
Plasma_client.inode ->
string -> bool -> Plasma_client.inode Uq_engines.engine
val dir_lookup :
Plasma_client.plasma_trans ->
Plasma_client.inode -> string -> bool -> 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 rev_lookup_dir_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> string Uq_engines.engine
val rev_lookup_dir :
Plasma_client.plasma_trans -> Plasma_client.inode -> string
val namelock_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> string -> unit Uq_engines.engine
val namelock :
Plasma_client.plasma_trans -> Plasma_client.inode -> string -> unit
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 link_at_e :
Plasma_client.plasma_trans ->
Plasma_client.inode ->
string -> Plasma_client.inode -> unit Uq_engines.engine
val link_at :
Plasma_client.plasma_trans ->
Plasma_client.inode -> 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 unlink_at_e :
Plasma_client.plasma_trans ->
Plasma_client.inode -> string -> unit Uq_engines.engine
val unlink_at :
Plasma_client.plasma_trans -> Plasma_client.inode -> string -> unit
val rename_e :
Plasma_client.plasma_trans -> string -> string -> unit Uq_engines.engine
val rename : Plasma_client.plasma_trans -> string -> string -> unit
val rename_at_e :
Plasma_client.plasma_trans ->
Plasma_client.inode ->
string -> Plasma_client.inode -> string -> unit Uq_engines.engine
val rename_at :
Plasma_client.plasma_trans ->
Plasma_client.inode -> string -> Plasma_client.inode -> 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 ->
int64 -> bool -> Plasma_rpcapi_aux.blockinfo list Uq_engines.engine
val get_blocklist :
Plasma_client.plasma_trans ->
Plasma_client.inode ->
int64 -> int64 -> bool -> Plasma_rpcapi_aux.blockinfo list
val with_trans_e :
Plasma_client.plasma_cluster ->
(Plasma_client.plasma_trans -> 'a Uq_engines.engine) ->
'a Uq_engines.engine
val with_trans :
Plasma_client.plasma_cluster -> (Plasma_client.plasma_trans -> 'a) -> 'a
val retry_e :
Plasma_client.plasma_cluster ->
string -> ('a -> 'b Uq_engines.engine) -> 'a -> 'b Uq_engines.engine
val retry :
Plasma_client.plasma_cluster -> string -> ('a -> 'b) -> 'a -> 'b
end
