package rpc_parallel

You can search for identifiers within the package.

in-package search v0.2.0

rpc_parallel
- Rpc_parallel
  - Fd_redirection
  - How_to_run
  - Map_reduce
    
    Config
    
    Make_map_function
    
    S
    
    Worker
    
    Make_map_function_with_init
    
    S
    
    Worker
    
    Make_map_reduce_function
    
    S
    
    Worker
    
    Make_map_reduce_function_with_init
    
    S
    
    Worker
    
    Map_function
    
    Worker
    
    Map_function_spec
    
    Map_function_with_init_spec
    
    Map_reduce_function
    
    Worker
    
    Map_reduce_function_spec
    
    Map_reduce_function_with_init_spec
    
    Worker
  - Parallel
    
    Creator
    
    Expert
    
    Worker_env
    
    For_testing
    
    Function
    
    Direct_pipe
    
    Functions
    
    Make
    
    Connection
    
    Deprecated
    
    For_internal_testing
    
    Spawn_in_foreground_result
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Set
    
    Elt
    
    Named
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Tree
    
    Named
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    S
    
    Connection_state
    
    Functions
    
    C
    
    Worker_state
    
    Shutdown_on
    
    Spawn_in_foreground_exn_result
    
    Spawn_in_foreground_result
    
    State
    
    Worker
    
    Connection
    
    Deprecated
    
    For_internal_testing
    
    Spawn_in_foreground_result
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Set
    
    Elt
    
    Named
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Tree
    
    Named
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Shutdown_on
    
    Spawn_in_foreground_exn_result
    
    Spawn_in_foreground_result
    
    Worker_spec
    
    Connection_state
    
    Functions
    
    C
    
    Worker_state
  - Parallel_managed
    
    Make
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Set
    
    Elt
    
    Named
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Tree
    
    Named
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    S
    
    Connection_state
    
    Functions
    
    C
    
    Worker_state
    
    Worker
    
    Id
    
    Hash_queue
    
    Hash_set
    
    Provide_bin_io
    
    X
    
    Provide_of_sexp
    
    X
    
    Map
    
    Key
    
    Provide_hash
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Set
    
    Elt
    
    Named
    
    Provide_hash
    
    Provide_of_sexp
    
    Elt
    
    Tree
    
    Named
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
  - Prog_and_args
  - Remote_executable
  - Std

Legend:
Library
Module
Module type
Parameter
Class
Class type

State associated with each Worker.t. If this state is mutable, you must think carefully when making multiple connections to the same spawned worker.

type t

type init_arg

val bin_shape_init_arg : Core.Bin_prot.Shape.t

val bin_size_init_arg : init_arg Core.Bin_prot.Size.sizer

val bin_write_init_arg : init_arg Core.Bin_prot.Write.writer

val bin_writer_init_arg : init_arg Core.Bin_prot.Type_class.writer

val bin_read_init_arg : init_arg Core.Bin_prot.Read.reader

val __bin_read_init_arg__ : (int -> init_arg) Core.Bin_prot.Read.reader

val bin_reader_init_arg : init_arg Core.Bin_prot.Type_class.reader

val bin_init_arg : init_arg Core.Bin_prot.Type_class.t