Plasma GitLab Archive
Projects Blog Knowledge

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 : ('-> 'Uq_engines.engine) -> '-> '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 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 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 -> 'Uq_engines.engine) ->
    'Uq_engines.engine
  val with_trans :
    Plasma_client.plasma_cluster -> (Plasma_client.plasma_trans -> 'a) -> 'a
  val retry_e :
    Plasma_client.plasma_cluster ->
    string -> ('-> 'Uq_engines.engine) -> '-> 'Uq_engines.engine
  val retry :
    Plasma_client.plasma_cluster -> string -> ('-> 'b) -> '-> 'b
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml