Functions (tests.Tests.Coda_worker.T.Functions)

Parameters

module C : 
  Rpc_parallel.Creator
    with type worker_state := Worker_state.t
     and type connection_state := Connection_state.t

Signature

val peers_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  Network_peer.Peer.t list Async.Deferred.t

val verified_transitions_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  state_hashes Async.Pipe.Reader.t Async.Deferred.t

val sync_status_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  Sync_status.t Async.Pipe.Reader.t Async.Deferred.t

val new_user_command_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  Signature_lib.Public_key.Compressed.t ->
  Mina_base.Signed_command.t Async.Pipe.Reader.t Async.Deferred.t

val root_diff_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  Mina_lib.Root_diff.t Async.Pipe.Reader.t Async.Deferred.t

val initialization_finish_signal_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  unit Async.Pipe.Reader.t Async.Deferred.t

val get_balance_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  Mina_base.Account_id.t ->
  Currency.Balance.t option Async.Deferred.t

val root_length_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  int Async.Deferred.t

val get_nonce_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  Mina_base.Account_id.t ->
  Mina_numbers.Account_nonce.t option Async.Deferred.t

val send_payment_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  Send_payment_input.t ->
  Mina_base.Signed_command.t Core.Or_error.t Async.Deferred.t

val process_user_command_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  User_command_input.t ->
  Mina_base.Signed_command.t Core.Or_error.t Async.Deferred.t

val new_block_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  Mina_base.Account.key ->
  ( Filtered_external_transition.t, Mina_base.State_hash.t ) With_hash.t
    Async.Pipe.Reader.t
    Async.Deferred.t

val start_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  unit Async.Deferred.t

val dump_tf_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  string Async.Deferred.t

val best_path_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  Mina_base.State_hash.t list Async.Deferred.t

val stop_snark_worker_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  unit Async.Deferred.t

val replace_snark_worker_key_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  Signature_lib.Public_key.Compressed.t option ->
  unit Async.Deferred.t

val validated_transitions_keyswaptest_impl : 
  worker_state:coda_functions ->
  conn_state:unit ->
  unit ->
  Mina_block.Validated.t Async.Pipe.Reader.t Async.Deferred.t

val peers : 
  ( C.worker,
    Core.Unit.t,
    Network_peer.Peer.Stable.Latest.t Core_kernel__.Import.list )
    Rpc_parallel__Parallel.Function.t

val start : 
  ( C.worker, Core.Unit.t, Core.Unit.t ) Rpc_parallel__Parallel.Function.t

val get_balance : 
  ( C.worker,
    Mina_base.Account_id.t,
    Currency.Balance.Stable.Latest.t Core_kernel__.Import.option )
    Rpc_parallel__Parallel.Function.t

val get_nonce : 
  ( C.worker,
    Mina_base.Account_id.t,
    Mina_numbers.Account_nonce.Stable.Latest.t Core_kernel__.Import.option )
    Rpc_parallel__Parallel.Function.t

val root_length : 
  ( C.worker, Core.Unit.t, Core.Int.t ) Rpc_parallel__Parallel.Function.t

val new_block : 
  ( C.worker,
    Mina_base.Account.key,
    ( Filtered_external_transition.t, Mina_base.State_hash.t ) With_hash.t
      Async.Pipe.Reader.t )
    Rpc_parallel__Parallel.Function.t

val send_user_command : 
  ( C.worker,
    Send_payment_input.t,
    Mina_base.Signed_command.t Core.Or_error.t )
    Rpc_parallel__Parallel.Function.t

val process_user_command : 
  ( C.worker,
    User_command_input.t,
    Mina_base.Signed_command.t Core.Or_error.t )
    Rpc_parallel__Parallel.Function.t

val verified_transitions : 
  ( C.worker, Core.Unit.t, state_hashes Async.Pipe.Reader.t )
    Rpc_parallel__Parallel.Function.t

val root_diff : 
  ( C.worker, Core.Unit.t, Mina_lib.Root_diff.t Async.Pipe.Reader.t )
    Rpc_parallel__Parallel.Function.t

val initialization_finish_signal : 
  ( C.worker, Core.Unit.t, Core.Unit.t Async.Pipe.Reader.t )
    Rpc_parallel__Parallel.Function.t

val sync_status : 
  ( C.worker, Core.Unit.t, Sync_status.t Async.Pipe.Reader.t )
    Rpc_parallel__Parallel.Function.t

val new_user_command : 
  ( C.worker,
    Signature_lib.Public_key.Compressed.t,
    Mina_base.Signed_command.t Async.Pipe.Reader.t )
    Rpc_parallel__Parallel.Function.t

val dump_tf : 
  ( C.worker, Core.Unit.t, Core.String.t ) Rpc_parallel__Parallel.Function.t

val best_path : 
  ( C.worker,
    Core.Unit.t,
    Mina_base.State_hash.Stable.Latest.t Core_kernel__.Import.list )
    Rpc_parallel__Parallel.Function.t

val validated_transitions_keyswaptest : 
  ( C.worker, Core.Unit.t, Mina_block.Validated.t Async.Pipe.Reader.t )
    Rpc_parallel__Parallel.Function.t

val replace_snark_worker_key : 
  ( C.worker,
    Signature_lib.Public_key.Compressed.Stable.Latest.t
      Core_kernel__.Import.option,
    Core.Unit.t )
    Rpc_parallel__Parallel.Function.t

val stop_snark_worker : 
  ( C.worker, Core.Unit.t, Core.Unit.t ) Rpc_parallel__Parallel.Function.t

val functions : C.worker functions

val init_worker_state : Input.t -> coda_functions Async_kernel__Deferred.t

val init_connection_state : 
  connection:'a ->
  worker_state:'b ->
  'c ->
  'c Async_kernel__Deferred.t