Anoma.Node.Transaction.Mempool (Anoma v0.25.0)

@type t() :: %Anoma.Node.Transaction.Mempool{
  node_id: String.t() | nil,
  round: non_neg_integer(),
  transactions: %{required(binary()) => Anoma.Node.Transaction.Mempool.Tx.t()}
}

tx_result()

@type tx_result() :: {:ok, any()} | :error | :in_progress

vm_result()

@type vm_result() :: {:ok, Noun.t()} | :error | :in_progress

Functions

block_event(id_list, round, node_id)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

consensus_event(id_list, node_id)

execute(node_id, ordered_list_of_txs)

@spec execute(String.t(), [binary()]) :: :ok

filter_for_mempool()

init(args)

@spec init([startup_options()]) :: {:ok, t()}

Callback implementation for GenServer.init/1.

start_link(args \\ [])

@spec start_link([startup_options()]) :: GenServer.on_start()

tx(node_id, tx_w_backend)

@spec tx(
  String.t(),
  {Anoma.Node.Transaction.Backends.backend(), Noun.t()}
) :: :ok

tx(node_id, tx_w_backend, id)

@spec tx(String.t(), {Anoma.Node.Transaction.Backends.backend(), Noun.t()}, binary()) ::
  :ok

tx_dump(node_id)

@spec tx_dump(String.t()) :: [Anoma.Node.Transaction.Mempool.Tx.t()]

tx_event(tx_id, value, node_id)