Electric.Shapes.ConsumerRegistry (electric v1.2.4)

Summary

shape_handle()

stack_id()

stack_ref()

t()

Calls many GenServers asynchronously with the same message and waits for their responses before returning.

@type shape_handle() :: Electric.ShapeCacheBehaviour.shape_handle()

@type stack_id() :: Electric.stack_id()

@type stack_ref() :: stack_id() | [{:stack_id, stack_id()}] | %{stack_id: stack_id()}

@type t() :: %Electric.Shapes.ConsumerRegistry{
  stack_id: stack_id(),
  table: :ets.table()
}

@spec active_consumer_count(stack_id()) :: non_neg_integer()

@spec broadcast([pid()], term()) :: :ok

Calls many GenServers asynchronously with the same message and waits for their responses before returning.

Returns :ok once all GenServers have responded or have died.

There is no timeout so if the GenServers do not respond or die, this function will block indefinitely.

@spec publish([shape_handle()], term(), t()) :: :ok

@spec register_consumer(shape_handle(), pid(), stack_id()) :: {:ok, non_neg_integer()}

@spec register_consumer(shape_handle(), pid(), t()) :: {:ok, non_neg_integer()}

@spec register_consumer(shape_handle(), pid(), :ets.table()) ::
  {:ok, non_neg_integer()}

@spec remove_consumer(shape_handle(), t()) :: :ok

@spec whereis(stack_ref(), shape_handle()) :: pid() | nil