Anoma.Node.Examples.EEvent (Anoma v0.31.0)

I contain logic to send node events and wait for node events.

These events are not generic events such as apps/event_broker/lib/examples/e_event_broker.ex. Rather, these are specific node events.

Summary

Functions

block_event(enode \\ ENode.start_node())

I create a block event for the given transaction id and the given result. The transaction should be a tuple with an id and an expected result.

block_event(enode, transaction, order)
consensus_event(enode \\ ENode.start_node(), transaction_ids \\ [])

I create a consensus event for the given transaction ids.

execution_event(enode \\ ENode.start_node())

I create an execution event for the given transaction id and the given result. The transaction should be a tuple with an id and an expected result. E.g., {{:ok, [["key" | 0]]}, "id 1"}

execution_event(enode, transaction)
new_block_event(transaction_ids, round)

I create a new block event. For this I need the round of the block as well as the order of the transactions in that block.

new_consensus_event(transaction_ids)

I create a new consensus event.

new_execution_event(results)

I create a new execution event. I expect a list of tuples that contain a transaction id and a result of the execution eof that transaction.

new_order_event(transaction_id)

I create a new order event.

new_tx_event(arg, id)

Given a transaction and an id, I create a transaction event.

order_event(enode \\ ENode.start_node(), transaction_id \\ nil)

I create an order event for the given transaction id.

send_block_event(enode \\ ENode.start_node(), event \\ nil)

I send the block event. If no event was given, I send a default event.

send_consensus_event(enode \\ ENode.start_node(), event \\ nil)

I send the consensus event. If no event was given, I send a default event.

send_execution_event(enode \\ ENode.start_node(), event \\ nil)

I send the execution event. If no event was given, I send a default event.

send_order_event(enode \\ ENode.start_node(), event \\ nil)

I send the order event. If no event was given, I send a default event.

send_transaction_event(enode \\ ENode.start_node(), event \\ nil)

I send the given transaction event. If no event was given, I send a default event.

transaction_event(enode \\ ENode.start_node())
transaction_event(enode, transaction)
wait_for_event(event)

I wait for a specific event.

Functions

Link to this function

block_event(enode \\ ENode.start_node())

@spec block_event(Anoma.Node.Examples.ENode.t()) :: EventBroker.Event.t()

I create a block event for the given transaction id and the given result. The transaction should be a tuple with an id and an expected result.

Link to this function

block_event(enode, transaction, order)

@spec block_event(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t(),
  non_neg_integer()
) :: EventBroker.Event.t()
Link to this function

consensus_event(enode \\ ENode.start_node(), transaction_ids \\ [])

@spec consensus_event(Anoma.Node.Examples.ENode.t(), [String.t()]) ::
  EventBroker.Event.t()

I create a consensus event for the given transaction ids.

Link to this function

execution_event(enode \\ ENode.start_node())

@spec execution_event(Anoma.Node.Examples.ENode.t()) :: EventBroker.Event.t()

I create an execution event for the given transaction id and the given result. The transaction should be a tuple with an id and an expected result. E.g., {{:ok, [["key" | 0]]}, "id 1"}

  {[error: "id 1"], "id 1"}
Link to this function

execution_event(enode, transaction)

@spec execution_event(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) ::
  EventBroker.Event.t()
Link to this function

new_block_event(transaction_ids, round)

@spec new_block_event([String.t()], non_neg_integer()) ::
  Anoma.Node.Transaction.Mempool.BlockEvent.t()

I create a new block event. For this I need the round of the block as well as the order of the transactions in that block.

Link to this function

new_consensus_event(transaction_ids)

@spec new_consensus_event([String.t()]) ::
  Anoma.Node.Transaction.Mempool.ConsensusEvent.t()

I create a new consensus event.

Link to this function

new_execution_event(results)

@spec new_execution_event([{any(), String.t()}]) ::
  Anoma.Node.Transaction.Executor.ExecutionEvent.t()

I create a new execution event. I expect a list of tuples that contain a transaction id and a result of the execution eof that transaction.

E.g., {"id 1", {:ok, [["key" | 0]]}}

  {"id 1", [error: "id 1"]}
Link to this function

new_order_event(transaction_id)

@spec new_order_event(String.t()) :: Anoma.Node.Transaction.Ordering.OrderEvent.t()

I create a new order event.

Link to this function

new_tx_event(arg, id)

@spec new_tx_event(
  {Anoma.Node.Transaction.Backends.backend(), Noun.t()},
  String.t()
) :: Anoma.Node.Transaction.Mempool.TxEvent.t()

Given a transaction and an id, I create a transaction event.

Link to this function

order_event(enode \\ ENode.start_node(), transaction_id \\ nil)

@spec order_event(Anoma.Node.Examples.ENode.t(), String.t() | nil) ::
  EventBroker.Event.t()

I create an order event for the given transaction id.

Link to this function

send_block_event(enode \\ ENode.start_node(), event \\ nil)

@spec send_block_event(Anoma.Node.Examples.ENode.t(), EventBroker.Event.t() | nil) ::
  {Anoma.Node.Examples.ENode.t(), EventBroker.Event.t()}

I send the block event. If no event was given, I send a default event.

Link to this function

send_consensus_event(enode \\ ENode.start_node(), event \\ nil)

@spec send_consensus_event(Anoma.Node.Examples.ENode.t(), EventBroker.Event.t() | nil) ::
  {Anoma.Node.Examples.ENode.t(), EventBroker.Event.t()}

I send the consensus event. If no event was given, I send a default event.

Link to this function

send_execution_event(enode \\ ENode.start_node(), event \\ nil)

@spec send_execution_event(Anoma.Node.Examples.ENode.t(), EventBroker.Event.t() | nil) ::
  {Anoma.Node.Examples.ENode.t(), EventBroker.Event.t()}

I send the execution event. If no event was given, I send a default event.

Link to this function

send_order_event(enode \\ ENode.start_node(), event \\ nil)

@spec send_order_event(Anoma.Node.Examples.ENode.t(), EventBroker.Event.t() | nil) ::
  {Anoma.Node.Examples.ENode.t(), EventBroker.Event.t()}

I send the order event. If no event was given, I send a default event.

Link to this function

send_transaction_event(enode \\ ENode.start_node(), event \\ nil)

@spec send_transaction_event(
  Anoma.Node.Examples.ENode.t(),
  EventBroker.Event.t() | nil
) ::
  {Anoma.Node.Examples.ENode.t(), EventBroker.Event.t()}

I send the given transaction event. If no event was given, I send a default event.

Link to this function

transaction_event(enode \\ ENode.start_node())

Link to this function

transaction_event(enode, transaction)

@spec transaction_event(
  Anoma.Node.Examples.ENode.t(),
  Anoma.Node.Examples.ETransaction.t()
) ::
  EventBroker.Event.t()
Link to this function

wait_for_event(event)

@spec wait_for_event(EventBroker.Event.t()) :: :ok

I wait for a specific event.