package rpc_parallel

You can search for identifiers within the package.

in-package search v0.2.0

On This Page

Parameters
Signature

rpc_parallel
- Rpc_parallel
  - Executable_location
  - Fd_redirection
  - Map_reduce
    
    Config
    
    Make_map_function
    
    Input
    
    Output
    
    Param
    
    S
    
    Input
    
    Output
    
    Worker
    
    Make_map_function_with_init
    
    Input
    
    Output
    
    Param
    
    S
    
    Input
    
    Output
    
    Param
    
    Worker
    
    Make_map_reduce_function
    
    Accum
    
    Input
    
    Param
    
    S
    
    Accum
    
    Input
    
    Worker
    
    Make_map_reduce_function_with_init
    
    Accum
    
    Input
    
    Param
    
    S
    
    Accum
    
    Input
    
    Param
    
    Worker
    
    Map_function
    
    Input
    
    Output
    
    Param
    
    Worker
    
    Map_function_spec
    
    Input
    
    Output
    
    Map_function_with_init_spec
    
    Input
    
    Output
    
    Param
    
    Map_reduce_function
    
    Accum
    
    Input
    
    Param
    
    Worker
    
    Map_reduce_function_spec
    
    Accum
    
    Input
    
    Map_reduce_function_with_init_spec
    
    Accum
    
    Input
    
    Param
    
    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_bin_io
    
    Key
    
    Provide_hash
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Replace_polymorphic_compare
    
    Set
    
    Elt
    
    Named
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Elt
    
    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
    
    M
    
    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_bin_io
    
    Key
    
    Provide_hash
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Replace_polymorphic_compare
    
    Set
    
    Elt
    
    Named
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Elt
    
    Provide_of_sexp
    
    Elt
    
    Tree
    
    Named
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Shutdown_on
    
    M
    
    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_bin_io
    
    Key
    
    Provide_hash
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Replace_polymorphic_compare
    
    Set
    
    Elt
    
    Named
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Elt
    
    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_bin_io
    
    Key
    
    Provide_hash
    
    Key
    
    Provide_of_sexp
    
    Key
    
    Tree
    
    Provide_of_sexp
    
    K
    
    Replace_polymorphic_compare
    
    Set
    
    Elt
    
    Named
    
    Provide_bin_io
    
    Elt
    
    Provide_hash
    
    Elt
    
    Provide_of_sexp
    
    Elt
    
    Tree
    
    Named
    
    Provide_of_sexp
    
    Elt
    
    Table
    
    Provide_bin_io
    
    Key
    
    Provide_of_sexp
    
    Key
  - Remote_executable
  - Std

Legend:
Library
Module
Module type
Parameter
Class
Class type

Parameters

module M : Core.T1

Signature

type _ t =

| Disconnect : (connection_state_init_arg:S.Connection_state.init_arg -> Connection.t M.t Async.Deferred.t) t
(*
An initial connection to the worker is established. The worker shuts itself down when Rpc.Connection.close_finished on this connection.
*)
| Heartbeater_timeout : worker M.t Async.Deferred.t t
(*
A "heartbeater" connection is established between the worker and its master. The worker shuts itself down when Rpc.Connection.close_finished on this connection, which is likely when the master process exits.
*)
| Called_shutdown_function : worker M.t Async.Deferred.t t
(*
WARNING! Worker's spawned with this variant do not shutdown when the master process exits. The worker only shuts itself down on an explicit shutdown request.
*)