Plasma GitLab Archive
Projects Blog Knowledge

sig
  type read_flag = [ `Binary | `Dummy | `Skip of int64 | `Streaming ]
  type read_file_flag =
      [ `Binary | `Destination of string | `Dummy | `Temp of string * string ]
  type write_flag =
      [ `Binary
      | `Create
      | `Dummy
      | `Exclusive
      | `Location of string list
      | `Repl of int
      | `Streaming
      | `Truncate ]
  type write_file_flag =
      [ `Binary
      | `Create
      | `Dummy
      | `Exclusive
      | `Link
      | `Location of string list
      | `Repl of int
      | `Truncate ]
  type write_common =
      [ `Binary
      | `Create
      | `Dummy
      | `Exclusive
      | `Location of string list
      | `Repl of int
      | `Truncate ]
  type size_flag = [ `Dummy ]
  type test_flag = [ `Dummy | `Link ]
  type remove_flag = [ `Dummy | `Recursive ]
  type rename_flag = [ `Dummy ]
  type symlink_flag = [ `Dummy ]
  type readdir_flag = [ `Dummy ]
  type readlink_flag = [ `Dummy ]
  type mkdir_flag = [ `Dummy | `Nonexcl | `Path ]
  type rmdir_flag = [ `Dummy ]
  type copy_flag = [ `Dummy | `Location of string list | `Repl of int ]
  type link_flag = [ `Dummy ]
  type test_type = [ `D | `E | `F | `H | `N | `R | `S | `W | `X ]
  class type local_file =
    object method close : unit -> unit method filename : string end
  class type filesystem =
    object
      method blocklist : string -> Plasma_rpcapi_aux.blockinfo list
      method blocksize : string -> int
      method cancel : unit -> unit
      method close : unit -> unit
      method commit_files : (string * string) list -> unit
      method copy : Mapred_fs.copy_flag list -> string -> string -> unit
      method copy_in_from_buf :
        string -> int64 -> Netsys_mem.memory -> int -> unit
      method copy_out_to_buf :
        string -> int64 -> Netsys_mem.memory -> int -> unit
      method have_link : string -> bool
      method link : Mapred_fs.link_flag list -> string -> string -> unit
      method local_root : string -> string option
      method location_info : string -> (Unix.inet_addr * string) list
      method mkdir : Mapred_fs.mkdir_flag list -> string -> unit
      method nominal_dot_dot : bool
      method open_cluster :
        string ->
        Unixqueue.event_system -> Plasma_client.plasma_cluster option
      method open_filesystem : unit -> Mapred_fs.filesystem
      method path_encoding : Netconversion.encoding option
      method path_exclusions : (int * int) list
      method read :
        Mapred_fs.read_flag list -> string -> Netchannels.in_obj_channel
      method read_file :
        Mapred_fs.read_file_flag list -> string -> Mapred_fs.local_file
      method readdir : Mapred_fs.readdir_flag list -> string -> string list
      method readlink : Mapred_fs.readlink_flag list -> string -> string
      method remove : Mapred_fs.remove_flag list -> string -> unit
      method rename : Mapred_fs.rename_flag list -> string -> string -> unit
      method rmdir : Mapred_fs.rmdir_flag list -> string -> unit
      method set_aside : unit -> unit
      method size : Mapred_fs.size_flag list -> string -> int64
      method symlink :
        Mapred_fs.symlink_flag list -> string -> string -> unit
      method test :
        Mapred_fs.test_flag list -> string -> Mapred_fs.test_type -> bool
      method test_list :
        Mapred_fs.test_flag list ->
        string -> Mapred_fs.test_type list -> bool list
      method write :
        Mapred_fs.write_flag list -> string -> Netchannels.out_obj_channel
      method write_file :
        Mapred_fs.write_file_flag list ->
        string -> Mapred_fs.local_file -> unit
    end
  val plasma_filesystem :
    ?plasma_root:string ->
    Plasma_client_config.client_config ->
    (Plasma_client.plasma_cluster -> unit) -> Mapred_fs.filesystem
  val local_filesystem : string -> Mapred_fs.filesystem
  val multi_tree :
    (string * Mapred_fs.filesystem) list -> string -> Mapred_fs.filesystem
  val standard_fs :
    ?custom:(string * Mapred_fs.filesystem) list ->
    ?default:string ->
    ?configure_cluster:(Plasma_client.plasma_cluster -> unit) ->
    Mapred_config.mapred_config -> Mapred_fs.filesystem
  val standard_fs_cc :
    ?custom:(string * Mapred_fs.filesystem) list ->
    ?default:string ->
    ?configure_cluster:(Plasma_client.plasma_cluster -> unit) ->
    ?client_config:Plasma_client_config.client_config ->
    ?file_root:string -> ?plasma_root:string -> unit -> Mapred_fs.filesystem
end
This web site is published by Informatikbüro Gerd Stolpmann
Powered by Caml