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

abordering genserver

Summary

Types

t()

Functions

append(node_id, arg)
block(from, tx_id, call, node_id)
block_spawn(id, call, node_id)
blocking_read(node_id, arg, from)
blocking_write(node_id, arg, from)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

init(args)

Callback implementation for GenServer.init/1.

order(node_id, txs)
read(node_id, arg)
start_link(args \\ [])
this_module_filter()
tx_id_filter(tx_id)
write(node_id, arg)

Types

Link to this type

t()

@type t() :: %Anoma.Node.Transaction.Ordering{
  next_height: integer(),
  node_id: String.t(),
  tx_id_to_height: %{required(binary()) => integer()}
}

Functions

Link to this function

append(node_id, arg)

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

block(from, tx_id, call, node_id)

@spec block(GenServer.from(), binary(), (-> any()), String.t()) :: :ok
Link to this function

block_spawn(id, call, node_id)

Link to this function

blocking_read(node_id, arg, from)

@spec blocking_read(String.t(), {binary(), any()}, GenServer.from()) :: :ok
Link to this function

blocking_write(node_id, arg, from)

@spec blocking_write(String.t(), {binary(), [any()]}, GenServer.from()) :: :ok
Link to this function

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

init(args)

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

Callback implementation for GenServer.init/1.

Link to this function

order(node_id, txs)

@spec order(String.t(), [binary()]) :: :ok
Link to this function

read(node_id, arg)

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

start_link(args \\ [])

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

this_module_filter()

Link to this function

tx_id_filter(tx_id)

Link to this function

write(node_id, arg)

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