Anoma.Node.Replay (Anoma v0.31.0)
I contain logic to replay storage.
When a node starts, it can start with an empty database, a "fresh" node. If there was pre-existing data present, it's called an an "existing node".
In case of a fresh node, the node can start up without any ceremony. The database is created and the node starts up.
In case of an existing node, the exising data needs to be verified for correctness. The replay mechanism assures that the present data is correct.
Correct data means that the data in the values and events table is correct and does not lead to errors.
A replay uses the previous data to start up a temporary node with the existing data. If that node starts up succesfully, the data is considered valid. The real node can continue starting up using the old data. The mock node is removed from the system.
Summary
Functions
Given a node id, I will create the tables for the node and initialize them with the data used to replay. I do not start a node, I only set up its tables.
I attempt to replay the data for a given node id.
I create a temporary node and return its node id. Ensure that the tables have been copied before creating the temporary node.
Types
block_info()
consensi()
@type consensi() :: [[binary()]]
mempool_args()
@type mempool_args() :: [ transactions: [any()], round: non_neg_integer(), consensus: [any()] ]
ordering_args()
@type ordering_args() :: [{:next_height, non_neg_integer()}]
replay_data()
@type replay_data() :: {consensi(), round(), block_info(), transactions()}
round()
@type round() :: integer()
storage_args()
@type storage_args() :: [{:uncommitted_height, non_neg_integer()}]
transactions()
@type transactions() :: [Anoma.Node.Transaction.Backends.transaction()]
Functions
init_tables_node(from_node_id, to_node_id)
@spec init_tables_node(any(), binary()) :: {:error, :failed_to_create_replay_node | :target_node_existed} | {:ok, :data_initialized}
Given a node id, I will create the tables for the node and initialize them with the data used to replay. I do not start a node, I only set up its tables.
replay_for(node_id)
@spec replay_for(String.t()) :: {:ok, :replay_succeeded} | {:error, :replay_failed}
I attempt to replay the data for a given node id.
temporary_node_id()
@spec temporary_node_id() :: String.t()
I create a temporary node and return its node id. Ensure that the tables have been copied before creating the temporary node.