Api (tests.Tests.Coda_worker

type user_cmd_status = {

expected_deadline : int;

passed_root : unit Async.Ivar.t;

}

type user_cmds_under_inspection =
  ( Mina_base.User_command.t, user_cmd_status ) Core.Hashtbl.t

type restart_type = [

| `Catchup

| `Bootstrap

]

type t = {

`workers : Coda_process.t Core.Array.t;`
`configs : Coda_worker.Input.t list;`
`start_writer : (int * Coda_worker.Input.t * ( unit -> unit ) * ( unit -> unit )) Pipe_lib.Linear_pipe.Writer.t;`
status : [ `On of [ `Synced of user_cmds_under_inspection \| `Catchup ] \| `Off ] Core.Array.t;
`locks : (int Core.ref * unit Async.Condition.t) Core.Array.t;`	(* The int counts the number of ongoing RPCs. when it is 0, it is safe to take the worker offline. `stop` below will set the status to `Off, and we only try doing an RPC if the status is `On, so eventually the counter _must_ become 0, ensuring progress. *)
`root_lengths : int Core.Array.t;`
`restart_signals : (restart_type * unit Async.Ivar.t) Core.Option.t Core.Array.t;`
`precomputed_values : Genesis_proof.Inputs.t;`

}

val create : 
  precomputed_values:Genesis_proof.Inputs.t ->
  Coda_worker.Input.t list ->
  Coda_process.t Core.Array.t ->
  (int * Coda_worker.Input.t * ( unit -> unit ) * ( unit -> unit ))
    Pipe_lib.Linear_pipe.Writer.t ->
  t

val online : t -> int -> bool

val synced : t -> int -> bool

val run_online_worker : 
  f:( Coda_process.t -> 'a Async_kernel__Deferred.t ) ->
  t ->
  int ->
  'b option Async_kernel__Deferred.t

val get_balance : 
  t ->
  int ->
  Mina_base.Account_id.t ->
  Currency.Balance.t option option Async_kernel__Deferred.t

val get_nonce : 
  t ->
  int ->
  Mina_base.Account_id.t ->
  Mina_numbers.Account_nonce.t option option Async_kernel__Deferred.t

val best_path : 
  t ->
  int ->
  Mina_base.State_hash.Stable.Latest.t list option Async_kernel__Deferred.t

val sync_status : 
  t ->
  int ->
  Sync_status.t Pipe_lib.Linear_pipe.Reader.t option Async_kernel__Deferred.t

val new_user_command : 
  t ->
  int ->
  Signature_lib.Public_key.Compressed.t ->
  Mina_base.Signed_command.t Async.Pipe.Reader.t option
    Async_kernel__Deferred.t

val start : t -> int -> unit Async_kernel.Deferred.t

val stop : t -> int -> logger:Logger.t -> unit Async_kernel__Deferred.t

val run_user_command : 
  memo:Mina_base.Signed_command_memo.t ->
  t ->
  int ->
  Signature_lib.Private_key.t ->
  Currency.Fee.t ->
  Mina_numbers.Global_slot.t option ->
  body:Mina_base.Signed_command_payload.Body.t ->
  Mina_base.Signed_command.t Async_kernel__Deferred_option.t

val delegate_stake : 
  t ->
  int ->
  Signature_lib.Private_key.t ->
  Signature_lib.Public_key.Compressed.t ->
  Currency.Fee.t ->
  Mina_numbers.Global_slot.t option ->
  Mina_base.Signed_command.t Async_kernel__Deferred_option.t

val send_payment : 
  t ->
  int ->
  Signature_lib.Private_key.t ->
  Mina_base_import.Public_key.Compressed.Stable.V1.t ->
  Currency.Amount.Stable.V1.t ->
  Currency.Fee.t ->
  Mina_numbers.Global_slot.t option ->
  Mina_base.Signed_command.t Async_kernel__Deferred_option.t

val new_block : 
  t ->
  int ->
  Mina_base.Account.key ->
  ( Filtered_external_transition.t, Mina_base.State_hash.t ) With_hash.t
    Pipe_lib.Linear_pipe.Reader.t
    option
    Async_kernel__Deferred.t

val replace_snark_worker_key : 
  t ->
  int ->
  Signature_lib.Public_key.Compressed.t option ->
  unit option Async_kernel__Deferred.t

val validated_transitions_keyswaptest : 
  t ->
  int ->
  Mina_block.Validated.t Pipe_lib.Linear_pipe.Reader.t option
    Async_kernel__Deferred.t

val new_user_command_and_subscribe : 
  t ->
  int ->
  Mina_base.Account.key ->
  Mina_base.Signed_command.t Async.Pipe.Reader.t option
    Async_kernel__Deferred.t

val teardown : t -> logger:Logger.t -> unit Async_kernel__Deferred1.t

val setup_bootstrap_signal : t -> int -> unit Async.Ivar.t

val setup_catchup_signal : t -> int -> unit Async.Ivar.t