sig
type read_flag = [ `Binary | `Dummy | `Skip of int64 | `Streaming ]
type read_file_flag = [ `Binary | `Dummy ]
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 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_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 -> unit -> Mapred_fs.filesystem
end
