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 | `Retry ]
type copy_out_flags = [ `No_truncate | `Retry ]
exception Plasma_error of Plasma_client.errno
exception Cluster_down of string
exception Datanode_error of exn
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 open_cluster_like :
?same_buffer:bool ->
?same_pref_nodes:bool ->
?same_shm_manager:bool ->
Plasma_client.plasma_cluster ->
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_pref_nodes_of_inode :
Plasma_client.plasma_cluster -> int64 -> string list option -> 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 params_e :
Plasma_client.plasma_cluster -> (string * string) list Uq_engines.engine
val params : Plasma_client.plasma_cluster -> (string * string) list
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 get_dn_info_e :
Plasma_client.plasma_cluster ->
Plasma_rpcapi_aux.dn_info array Uq_engines.engine
val get_dn_info :
Plasma_client.plasma_cluster -> Plasma_rpcapi_aux.dn_info array
val configure_auth :
Plasma_client.plasma_cluster ->
string -> string -> (string -> string) -> unit
val configure_auth_daemon : Plasma_client.plasma_cluster -> unit
val configure_auth_ticket : Plasma_client.plasma_cluster -> string -> unit
val impersonate_e :
Plasma_client.plasma_cluster ->
string ->
string -> string list -> string option -> unit Uq_engines.engine
val impersonate :
Plasma_client.plasma_cluster ->
string -> string -> string list -> string option -> unit
val get_auth_ticket_e :
Plasma_client.plasma_cluster -> string -> string Uq_engines.engine
val get_auth_ticket : Plasma_client.plasma_cluster -> string -> string
val current_user_e :
Plasma_client.plasma_cluster ->
(string * string * string list) Uq_engines.engine
val current_user :
Plasma_client.plasma_cluster -> string * string * string list
val configure_default_user_group :
Plasma_client.plasma_cluster -> string -> string -> unit
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 :
?lazy_validation:bool ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 ->
Plasma_client.strmem ->
int ->
int -> (int * bool * Plasma_rpcapi_aux.inodeinfo) Uq_engines.engine
val read :
?lazy_validation:bool ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
int64 ->
Plasma_client.strmem ->
int -> int -> int * bool * Plasma_rpcapi_aux.inodeinfo
type read_request = int64 * Plasma_client.strmem * int * int
type read_response = int * bool * Plasma_rpcapi_aux.inodeinfo
type multi_read_task =
(Plasma_client.read_request * (Plasma_client.read_response -> unit))
option Uq_engines.engine
val multi_read_e :
?lazy_validation:bool ->
Plasma_client.plasma_cluster ->
Plasma_client.inode ->
Plasma_client.multi_read_task Stream.t -> unit Uq_engines.engine
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 snapshot_e :
?append:bool ->
Plasma_client.plasma_trans -> int64 -> unit Uq_engines.engine
val snapshot : ?append:bool -> Plasma_client.plasma_trans -> int64 -> 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 read_admin_table_e :
Plasma_client.plasma_cluster -> string -> string Uq_engines.engine
val read_admin_table : Plasma_client.plasma_cluster -> string -> string
val write_admin_table_e :
Plasma_client.plasma_cluster ->
string -> string -> unit Uq_engines.engine
val write_admin_table :
Plasma_client.plasma_cluster -> string -> string -> unit
val read_ug_admin_e :
Plasma_client.plasma_cluster -> Plasma_ug.ug_admin Uq_engines.engine
val read_ug_admin : Plasma_client.plasma_cluster -> Plasma_ug.ug_admin
val write_ug_admin_e :
Plasma_client.plasma_cluster ->
Plasma_ug.ug_admin -> unit Uq_engines.engine
val write_ug_admin :
Plasma_client.plasma_cluster -> Plasma_ug.ug_admin -> unit
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
