@spec address(String.t(), atom(), atom()) :: Anoma.Node.Registry.Address.t()

I create an address with specified node id, engine name and label.

@spec dump_register() :: [{Anoma.Node.Registry.Address.t(), pid(), any()}]

I return the contents of the registry.

@spec engines_for(String.t()) :: [atom()]

Given a node_id, I return a list of all the engine names I know for this node.

I filter out all the non-engine names based on an allow list.

@spec local_node_id() :: {:ok, any()} | {:error, term()}

Given an engine type, I return the name of the local engine of that type.

If there are multiple engines of that type present, I raise an error.

@spec register(String.t(), atom(), atom()) :: {:ok, pid()} | {:error, term()}

I register the calling process under the name of the engine at the given node id.

@spec via(String.t(), atom(), atom()) ::
  {:via, Registry, {atom(), Anoma.Node.Registry.Address.t()}}

I generate the :via stanza for a process with the given node_id and engine name.

@spec whereis(String.t(), atom(), atom()) :: pid() | nil

Given a node id and engine, I check if there is a process registered with that address and return the pid.