package rpc_parallel

You can search for identifiers within the package.

in-package search v0.2.0

rpc_parallel
- CHANGES
- LICENSE
- Library rpc_parallel
  - Rpc_parallel
    
    Fd_redirection
    
    How_to_run
    
    Map_reduce
    
    Config
    
    Worker
    
    Map_function
    
    Param
    
    Input
    
    Output
    
    Worker
    
    Map_function_with_init_spec
    
    Param
    
    Input
    
    Output
    
    Make_map_function_with_init
    
    Param
    
    Input
    
    Output
    
    Worker
    
    Map_function_spec
    
    Input
    
    Output
    
    Make_map_function
    
    Param
    
    Input
    
    Output
    
    Worker
    
    Map_reduce_function
    
    Param
    
    Accum
    
    Input
    
    Worker
    
    Map_reduce_function_with_init_spec
    
    Param
    
    Accum
    
    Input
    
    Make_map_reduce_function_with_init
    
    Param
    
    Accum
    
    Input
    
    Worker
    
    Map_reduce_function_spec
    
    Accum
    
    Input
    
    Make_map_reduce_function
    
    Param
    
    Accum
    
    Input
    
    Worker
    
    Prog_and_args
    
    Remote_executable
    
    Rpc_settings
    
    For_internal_testing
    
    Utils
    
    Worker_id
    
    Replace_polymorphic_compare
    
    Map
    
    Key
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Set
    
    Elt
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Table
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_set
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_queue
    
    Worker_type_id
    
    Replace_polymorphic_compare
    
    Map
    
    Key
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Set
    
    Elt
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Table
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_set
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_queue
    
    For_testing
    
    Internal_connection_state
    
    Managed
    
    Worker
    
    Id
    
    Replace_polymorphic_compare
    
    Map
    
    Key
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Set
    
    Elt
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Table
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_set
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_queue
    
    Make
    
    Id
    
    Replace_polymorphic_compare
    
    Map
    
    Key
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Set
    
    Elt
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Table
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_set
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_queue
    
    Function
    
    Backend_and_settings
    
    Backend
    
    Worker
    
    Functions
    
    Creator
    
    Worker_spec
    
    Make
    
    State
    
    For_testing
    
    Expert
    
    Parallel
    
    Function
    
    Direct_pipe
    
    Id
    
    For_internal_testing
    
    Backend_and_settings
    
    Backend
    
    Settings
    
    Worker
    
    Id
    
    Replace_polymorphic_compare
    
    Map
    
    Key
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Set
    
    Elt
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Table
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_set
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_queue
    
    Connection
    
    Shutdown_on
    
    Spawn_in_foreground_result
    
    Spawn_in_foreground_exn_result
    
    Deprecated
    
    For_internal_testing
    
    Spawn_in_foreground_result
    
    Functions
    
    Creator
    
    Worker_spec
    
    Worker_state
    
    Connection_state
    
    Functions
    
    Make
    
    Id
    
    Replace_polymorphic_compare
    
    Map
    
    Key
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Set
    
    Elt
    
    Diff
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Provide_hash
    
    Table
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_set
    
    Provide_of_sexp
    
    Provide_bin_io
    
    Hash_queue
    
    Connection
    
    Shutdown_on
    
    Spawn_in_foreground_result
    
    Spawn_in_foreground_exn_result
    
    Deprecated
    
    For_internal_testing
    
    Spawn_in_foreground_result
    
    State
    
    For_testing
    
    Expert
    
    Worker_env
- Library rpc_parallel.unauthenticated
  - Rpc_parallel_unauthenticated
    
    For_testing
    
    Expert
- Sources
  - rpc_parallel
    
    fd_redirection.ml
    
    for_testing_internal.ml
    
    how_to_run.ml
    
    managed.ml
    
    map_reduce.ml
    
    parallel.ml
    
    parallel_intf.ml
    
    prog_and_args.ml
    
    remote_executable.ml
    
    rpc_parallel.ml
    
    rpc_parallel__.ml
    
    rpc_settings.ml
    
    utils.ml
  - rpc_parallel.unauthenticated
    
    backend.ml
    
    rpc_parallel_unauthenticated.ml
    
    rpc_parallel_unauthenticated__.ml
    
    start_app.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module type `Map_reduce.Map_function_with_init_spec`Source

type state_type

module Param : Core.Binable

module Input : Core.Binable

module Output : Core.Binable

val init : Param.t -> state_type Async.Deferred.t

val map : state_type -> Input.t -> Output.t Async.Deferred.t

package rpc_parallel

Module type Map_reduce.Map_function_with_init_specSource

Module type `Map_reduce.Map_function_with_init_spec`Source