Anoma.Node.Transaction.Storage (Anoma v0.25.0)

abstorage genserver

Summary

Types

bare_key()
qualified_key()
t()

Functions

abwrite(flag, arg, state)
append(node_id, arg)
block_spawn(height, call, node_id)
blocking_write(node_id, height, kvlist, from)
blocks_table(node_id)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

commit(node_id, block_round, writes)
init(args)

Callback implementation for GenServer.init/1.

init_tables(node_id, rocks)
read(node_id, arg)
read_in_past(height, key, state)
start_link(args \\ [])
updates_table(node_id)
values_table(node_id)
write(node_id, arg)

Types

Link to this type

bare_key()

@type bare_key() :: [String.t()]
Link to this type

qualified_key()

@type qualified_key() :: {integer(), bare_key()}
Link to this type

t()

@type t() :: %Anoma.Node.Transaction.Storage{
  node_id: String.t(),
  uncommitted: %{required(qualified_key()) => term()},
  uncommitted_height: integer(),
  uncommitted_updates: %{required(bare_key()) => [integer()]}
}

Functions

Link to this function

abwrite(flag, arg, state)

@spec abwrite(:append | :write, {non_neg_integer(), [any()]}, t()) :: t()
Link to this function

append(node_id, arg)

@spec append(
  String.t(),
  {non_neg_integer(), [any()]}
) :: :ok
Link to this function

block_spawn(height, call, node_id)

Link to this function

blocking_write(node_id, height, kvlist, from)

Link to this function

blocks_table(node_id)

Link to this function

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

commit(node_id, block_round, writes)

@spec commit(
  String.t(),
  non_neg_integer(),
  [Anoma.Node.Transaction.Mempool.Tx.t()] | nil
) :: :ok
Link to this function

init(args)

@spec init([startup_options()]) :: {:ok, t()}

Callback implementation for GenServer.init/1.

Link to this function

init_tables(node_id, rocks)

@spec init_tables(atom(), bool()) :: any()
Link to this function

read(node_id, arg)

@spec read(
  String.t(),
  {non_neg_integer(), any()}
) :: :absent | any()
Link to this function

read_in_past(height, key, state)

@spec read_in_past(non_neg_integer(), any(), t()) :: :absent | :error | {:ok, term()}
Link to this function

start_link(args \\ [])

@spec start_link([startup_options()]) :: GenServer.on_start()
Link to this function

updates_table(node_id)

Link to this function

values_table(node_id)

Link to this function

write(node_id, arg)

@spec write(
  String.t(),
  {non_neg_integer(), [any()]}
) :: :ok