Anoma.Node.Tables (Anoma v0.31.0)

Summary

Types

table_spec()

A table is typed by a tuple where the first element is the table name, and the second one is a list of keys (i.e., columns).

table_specs()

a list of table specs

Functions

clear_table(table_name)

I clear out the given table.

copy_table_rows(source_table, target_table, cont \\ nil)
create_local_schema()
create_table(name, fields)
create_tables(table_list)
duplicate_table(source_table, target_table)

I duplicate a given table's content to a new table. If the new table does not exist, it is created.

has_data?(node_id)
initialize_storage()

I initialize the mnesia storage for this entire vm.

initialize_tables_for_node(node_id)

I initialize the tables for a given node id. I do this by creating all tables in the mnesia storage.

node_table_name(node_id, name)

Given an atom as table name, I create a node-specific name based on that.

table_blocks(node_id)

I return the table name for the given node its blocks.

table_commitment_tree(node_id \\ "no_node")

I return the table name for the given node its commitment tree. I can be called without a node id too. In that case I use "no_node" as node id.

table_events(node_id)

I return the table name for the given node its event table.

table_exists?(table)

Check if the given table name exists.

table_intents(node_id)

I return the table name for the intents table.

table_updates(node_id)

I return the table name for the given node its updates.

table_values(node_id)

I return the table name for the given node its values.

tables_exist?(table_names)

Check if a given list of tables exists.

Types

Link to this type

table_spec()

@type table_spec() :: {atom(), [atom()]}

A table is typed by a tuple where the first element is the table name, and the second one is a list of keys (i.e., columns).

Link to this type

table_specs()

@type table_specs() :: [table_spec()]

a list of table specs

Functions

Link to this function

clear_table(table_name)

@spec clear_table(atom()) :: :ok | {:error, :failed_to_clear_table}

I clear out the given table.

Link to this function

copy_table_rows(source_table, target_table, cont \\ nil)

@spec copy_table_rows(any(), any(), any()) :: :ok
Link to this function

create_local_schema()

@spec create_local_schema() :: :ok | {:error, :failed_to_create_schema, any()}
Link to this function

create_table(name, fields)

@spec create_table(atom(), [atom()]) ::
  {:ok, :exists | :created} | {:error, :failed_to_create_table, any()}
Link to this function

create_tables(table_list)

@spec create_tables([{atom(), [atom()]}]) ::
  {:ok, {[atom()], [atom()]}}
  | {:error, :failed_to_create_table, atom(), [atom()], any()}
Link to this function

duplicate_table(source_table, target_table)

@spec duplicate_table(atom(), atom()) ::
  {:ok, :table_copied} | {:error, :copy_failed, any()}

I duplicate a given table's content to a new table. If the new table does not exist, it is created.

Link to this function

has_data?(node_id)

@spec has_data?(String.t()) ::
  {:ok, :exists}
  | {:error, :partial_exist | :none_exist | :failed_to_check_tables}
Link to this function

initialize_storage()

@spec initialize_storage() ::
  :ok
  | {:error, :failed_to_initialize_storage}
  | {:error, :failed_to_create_tables}

I initialize the mnesia storage for this entire vm.

Link to this function

initialize_tables_for_node(node_id)

@spec initialize_tables_for_node(String.t()) ::
  {:ok, :existing | :created} | {:error, :failed_to_initialize_tables}

I initialize the tables for a given node id. I do this by creating all tables in the mnesia storage.

I return information whether these tables did not exist, were created, or when I failed to create them.

Link to this function

node_table_name(node_id, name)

@spec node_table_name(String.t(), atom()) :: atom()

Given an atom as table name, I create a node-specific name based on that.

Link to this function

table_blocks(node_id)

@spec table_blocks(String.t()) :: atom()

I return the table name for the given node its blocks.

Link to this function

table_commitment_tree(node_id \\ "no_node")

@spec table_commitment_tree(String.t()) :: atom()

I return the table name for the given node its commitment tree. I can be called without a node id too. In that case I use "no_node" as node id.

Link to this function

table_events(node_id)

@spec table_events(String.t()) :: atom()

I return the table name for the given node its event table.

Link to this function

table_exists?(table)

@spec table_exists?(atom()) :: boolean()

Check if the given table name exists.

Run inside transaction.

Link to this function

table_intents(node_id)

@spec table_intents(String.t()) :: atom()

I return the table name for the intents table.

Link to this function

table_updates(node_id)

@spec table_updates(String.t()) :: atom()

I return the table name for the given node its updates.

Link to this function

table_values(node_id)

@spec table_values(String.t()) :: atom()

I return the table name for the given node its values.

Link to this function

tables_exist?(table_names)

@spec tables_exist?([atom()]) ::
  {:ok, :exists}
  | {:error, :partial_exist | :none_exist | :failed_to_check_tables}

Check if a given list of tables exists.

This function takes a list of tables to avoid waiting for tables multiple times.