Coda_worker (tests.Tests.Coda

module Input : sig ... end

module Send_payment_input : sig ... end

module T : sig ... end

type t = Rpc_parallel__Parallel.Make(T).t

val bin_size_t : t Bin_prot.Size.sizer

val bin_write_t : t Bin_prot.Write.writer

val bin_read_t : t Bin_prot.Read.reader

val __bin_read_t__ : ( int -> t ) Bin_prot.Read.reader

val bin_shape_t : Bin_prot.Shape.t

val bin_writer_t : t Bin_prot.Type_class.writer

val bin_reader_t : t Bin_prot.Type_class.reader

val bin_t : t Bin_prot.Type_class.t

val sexp_of_t : t -> Ppx_sexp_conv_lib.Sexp.t

type worker = t

val functions : t T.functions

module Id : sig ... end

val id : t -> Id.t

val serve : 
  ?max_message_size:int ->
  ?handshake_timeout:Core.Time.Span.t ->
  ?heartbeat_config:Async.Rpc.Connection.Heartbeat_config.t ->
  T.Worker_state.init_arg ->
  worker Async.Deferred.t

module Connection : sig ... end

module Shutdown_on (M : Core.T1) : sig ... end

type !'a with_spawn_args =
  ?how:Rpc_parallel__.How_to_run.t ->
  ?name:string ->
  ?env:(string * string) list ->
  ?connection_timeout:Core.Time.Span.t ->
  ?cd:string ->
  on_failure:( Core.Error.t -> unit ) ->
  'a

val spawn : 
  ( ?umask:int ->
    shutdown_on:'a Shutdown_on(Core.Or_error).t ->
    redirect_stdout:Rpc_parallel__.Fd_redirection.t ->
    redirect_stderr:Rpc_parallel__.Fd_redirection.t ->
    T.Worker_state.init_arg ->
    'a )
    with_spawn_args

val spawn_exn : 
  ( ?umask:int ->
    shutdown_on:'a Shutdown_on(Core.Monad.Ident).t ->
    redirect_stdout:Rpc_parallel__.Fd_redirection.t ->
    redirect_stderr:Rpc_parallel__.Fd_redirection.t ->
    T.Worker_state.init_arg ->
    'a )
    with_spawn_args

module Spawn_in_foreground_result : sig ... end

val spawn_in_foreground : 
  ( shutdown_on:'a Shutdown_on(Spawn_in_foreground_result).t ->
    T.Worker_state.init_arg ->
    'a )
    with_spawn_args

module Spawn_in_foreground_exn_result : sig ... end

val spawn_in_foreground_exn : 
  ( shutdown_on:'a Shutdown_on(Spawn_in_foreground_exn_result).t ->
    T.Worker_state.init_arg ->
    'a )
    with_spawn_args

val shutdown : t -> unit Core.Or_error.t Async.Deferred.t

module Deprecated : sig ... end

module For_internal_testing : sig ... end