Anoma.Node.Replay.State (Anoma v0.31.0)

I define logic that determines the startup state for the node.

When a node starts and data is present in the database, specific arguments have to be passed to the supervision tree in order for the node to pick up where it left off.

In particular, the following data must be restored.

The pending transactions waiting for an ordering.
Consensi in the mempool that have not been turned into a block.
The height of the ordering engine.
The committed height of the storage engine.

Summary

Types

block_table_summary()

events_table_summary()

mempool_args()

ordering_args()

startup_args()

storage_args()

Functions

block_table_summary(table)

I return a summary of all the required information from the blocks table.

events_table_summary(table)

initialize_storage(node_id)

Given a node id, I determine if there is existing data for this node.

mempool_arguments(node_id)

ordering_arguments(node_id)

startup_arguments(node_id)

startup_arguments_or_default(node_id)

Given a node id, I will determine the startup arguments for the node depending on the data found in the database.

storage_arguments(node_id)

Types

block_table_summary()

@type block_table_summary() :: %{
  last_round: non_neg_integer(),
  transaction_count: non_neg_integer()
}

events_table_summary()

@type events_table_summary() :: %{
  transactions: [any()],
  next_round: non_neg_integer(),
  consensus: [[String.t()]]
}

mempool_args()

@type mempool_args() :: [
  transactions: [any()],
  next_round: non_neg_integer(),
  consensus: [any()]
]

ordering_args()

@type ordering_args() :: [{:next_height, non_neg_integer()}]

startup_args()

@type startup_args() :: [
  mempool: mempool_args(),
  storage: storage_args(),
  ordering: ordering_args()
]

storage_args()

@type storage_args() :: [{:uncommitted_height, non_neg_integer()}]

Functions

block_table_summary(table)

@spec block_table_summary(atom()) ::
  {:ok, block_table_summary()} | {:error, :block_summary_failed}

I return a summary of all the required information from the blocks table.

events_table_summary(table)

@spec events_table_summary(any()) ::
  {:error, :events_summary_failed} | {:ok, events_table_summary()}

initialize_storage(node_id)

@spec initialize_storage(String.t()) :: {:ok, :existing_node | :new_node}

Given a node id, I determine if there is existing data for this node.

mempool_arguments(node_id)

@spec mempool_arguments(String.t()) ::
  {:ok, mempool_args()} | {:error, :storage_args_failed}

ordering_arguments(node_id)

@spec ordering_arguments(binary()) ::
  {:ok, ordering_args()} | {:error, :ordering_args_failed}

startup_arguments(node_id)

@spec startup_arguments(String.t()) ::
  {:ok, startup_args()} | {:error, :startup_arguments_failed}

startup_arguments_or_default(node_id)

@spec startup_arguments_or_default(String.t()) :: {:ok, startup_args() | nil}

Given a node id, I will determine the startup arguments for the node depending on the data found in the database.

If no data exists, the empty list is returned. There is no initial state.

storage_arguments(node_id)

@spec storage_arguments(String.t()) ::
  {:ok, storage_args()} | {:error, :storage_args_failed}