Anoma.Node.Examples.Mempool (Anoma v0.32.0)

I contain examples on how to interact with the mempool.

Summary

Functions

add_error_transaction(enode \\ ENode.start_node())

I add a transaction to the mempool that errors when executed.

add_error_transaction(enode, transaction)
add_multiple_transactions(enode \\ ENode.start_node())

I add multiple transactions to the mempool.

add_multiple_transactions(enode, transactions)
add_transaction(enode \\ ENode.start_node())

I add a transaction to the mempool.

add_transaction(enode, transaction)
complete_ten_transactions(enode \\ ENode.start_node())

I run a list of transactions and create a block for each of them.

complete_ten_transactions(enode, transactions)
complete_transaction(enode \\ ENode.start_node(), round \\ 1)

I run a transaction and let it complete. I expect a transaction description with the following values

complete_transaction(enode, transaction, round)
execute_multiple_transactions(enode \\ ENode.start_node())

I add a transaction to the mempool that fails when executed. I execute this transaction.

execute_multiple_transactions(enode, transactions)
execute_transaction(enode \\ ENode.start_node())

I add a transaction to the mempool that executes properly. I execute this transaction.

execute_transaction(enode, transaction)
make_block(enode \\ ENode.start_node())

I run a transaction and execute it to create a block.

make_block(enode, transaction)
wait_for_consensus_write(enode \\ ENode.start_node(), transaction)

Given a node id and a transaction list, I wait until these transactions have been written into the events table its consensus column.

wait_for_transaction_in_table(enode \\ ENode.start_node(), transaction)

Given a node id and a transaction list, I wait until these transactions have been written into the events table its consensus column.

wait_for_transaction_removed(enode \\ ENode.start_node(), transaction)

Given a node id and a transaction, I wait until this transaction is removed from the events table.

Functions

Link to this function

add_error_transaction(enode \\ ENode.start_node())

@spec add_error_transaction(Anoma.Node.Examples.ENode.t()) ::
  {Anoma.Node.Examples.ENode.t(), Anoma.Node.Examples.ETransaction.t()}

I add a transaction to the mempool that errors when executed.

Link to this function

add_error_transaction(enode, transaction)

@spec add_error_transaction(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) ::
  {Anoma.Node.Examples.ENode.t(), Anoma.Node.Examples.ETransaction.t()}
Link to this function

add_multiple_transactions(enode \\ ENode.start_node())

@spec add_multiple_transactions(Anoma.Node.Examples.ENode.t()) ::
  {Anoma.Node.Examples.ENode.t(), [Anoma.Node.Examples.ETransaction.t()]}

I add multiple transactions to the mempool.

Link to this function

add_multiple_transactions(enode, transactions)

@spec add_multiple_transactions(Anoma.Node.Examples.ENode.t(), [
  Anoma.Node.Examples.ETransaction.t()
]) ::
  {Anoma.Node.Examples.ENode.t(), [Anoma.Node.Examples.ETransaction.t()]}
Link to this function

add_transaction(enode \\ ENode.start_node())

@spec add_transaction(Anoma.Node.Examples.ENode.t()) ::
  {Anoma.Node.Examples.ENode.t(), Anoma.Node.Examples.ETransaction.t()}

I add a transaction to the mempool.

Link to this function

add_transaction(enode, transaction)

@spec add_transaction(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) ::
  {Anoma.Node.Examples.ENode.t(), Anoma.Node.Examples.ETransaction.t()}
Link to this function

complete_ten_transactions(enode \\ ENode.start_node())

@spec complete_ten_transactions(Anoma.Node.Examples.ENode.t()) ::
  {Anoma.Node.Examples.ENode.t(), [Anoma.Node.Examples.ETransaction.t()]}

I run a list of transactions and create a block for each of them.

Link to this function

complete_ten_transactions(enode, transactions)

@spec complete_ten_transactions(Anoma.Node.Examples.ENode.t(), [
  Anoma.Node.Examples.ETransaction.t()
]) ::
  {Anoma.Node.Examples.ENode.t(), [Anoma.Node.Examples.ETransaction.t()]}
Link to this function

complete_transaction(enode \\ ENode.start_node(), round \\ 1)

I run a transaction and let it complete. I expect a transaction description with the following values:

  • {backend, noun}: the transaction and noun
  • The expected result of executing the transaction E.g., {:ok, {:read_value, [["key" | 0] | 0]}}
  • The id of the transaction
Link to this function

complete_transaction(enode, transaction, round)

@spec complete_transaction(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t(),
  non_neg_integer()
) :: {Anoma.Node.Examples.ENode.t(), Anoma.Node.Examples.ETransaction.t()}
Link to this function

execute_multiple_transactions(enode \\ ENode.start_node())

@spec execute_multiple_transactions(Anoma.Node.Examples.ENode.t()) ::
  {Anoma.Node.Examples.ENode.t(), [Anoma.Node.Examples.ETransaction.t()]}

I add a transaction to the mempool that fails when executed. I execute this transaction.

Link to this function

execute_multiple_transactions(enode, transactions)

Link to this function

execute_transaction(enode \\ ENode.start_node())

I add a transaction to the mempool that executes properly. I execute this transaction.

Link to this function

execute_transaction(enode, transaction)

@spec execute_transaction(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) ::
  {Anoma.Node.Examples.ENode.t(), Anoma.Node.Examples.ETransaction.t()}
Link to this function

make_block(enode \\ ENode.start_node())

I run a transaction and execute it to create a block.

I do not wait for the events of the block creation.

Link to this function

make_block(enode, transaction)

@spec make_block(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) :: {Anoma.Node.Examples.ENode.t(), Anoma.Node.Examples.ETransaction.t()}
Link to this function

wait_for_consensus_write(enode \\ ENode.start_node(), transaction)

@spec wait_for_consensus_write(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) ::
  Anoma.Node.Examples.ENode.t()

Given a node id and a transaction list, I wait until these transactions have been written into the events table its consensus column.

Link to this function

wait_for_transaction_in_table(enode \\ ENode.start_node(), transaction)

@spec wait_for_transaction_in_table(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) ::
  Anoma.Node.Examples.ENode.t()

Given a node id and a transaction list, I wait until these transactions have been written into the events table its consensus column.

Link to this function

wait_for_transaction_removed(enode \\ ENode.start_node(), transaction)

@spec wait_for_transaction_removed(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) ::
  Anoma.Node.Examples.ENode.t()

Given a node id and a transaction, I wait until this transaction is removed from the events table.