Tx_queue_events (octez-evm-node-libs.Evm_node_lib_dev.Tx_queue

val is_ready : unit -> unit Lwt.t

is_ready () advertises that the Tx_queue is ready to receive transactions.

val shutdown : unit -> unit Lwt.t

shutdown () advertises that the Tx_queue is shutting down.

val cleared : unit -> unit Lwt.t

cleared () advertises that the Tx_queue finished clearing.

val injecting_transactions : int -> unit Lwt.t

injecting_transactions nb advertises nb transactions are about to be injected to the relay endpoint with a batch of eth_sendRawTransaction.

val add_transaction : 
  Evm_node_lib_dev_encoding.Ethereum_types.hash ->
  unit Lwt.t

add_transaction tx_hash Advertises tx_hash was added to the tx queue.

val transaction_dropped : 
  Evm_node_lib_dev_encoding.Ethereum_types.hash ->
  unit Lwt.t

transaction_dropped tx_hash Advertises tx_hash was dropped to the tx queue.

val transaction_confirmed : 
  Evm_node_lib_dev_encoding.Ethereum_types.hash ->
  unit Lwt.t

transaction_confirmed tx_hash Advertises tx_hash was confirmed to the tx queue.

val rpc_error : Rpc_encodings.JSONRPC.error -> unit Lwt.t

rpc_error error advertises an RPC produced the error error.

val missing_tx_object : 
  Evm_node_lib_dev_encoding.Ethereum_types.hash ->
  unit Lwt.t

missing_tx_object hash Advertises that it fails to find the tx_object associated to hash.

val callback_error__dont_wait__use_with_care : 
  Tezos_base.TzPervasives.tztrace ->
  unit

callback_error__dont_wait__use_with_care error advertises an RPC produced the error error without waiting.

val callback_error : Tezos_base.TzPervasives.tztrace -> unit Lwt.t

callback_error error advertises an RPC produced the error error.