Schema for PGMQ queues.
Summary
Types
@type name() :: String.t()
A PGMQ queue name.
@type t() :: %EctoPGMQ.Queue{ created_at: DateTime.t(), is_partitioned: boolean(), is_unlogged: boolean(), metrics: EctoPGMQ.Metrics.t() | nil, name: name(), notifications: EctoPGMQ.Throttle.t() | nil }
A PGMQ queue.
Functions
@spec query() :: Ecto.Query.t()
Returns a query for all queues.
The returned query joins and populates queue metrics and queue notification throttles.
Examples
iex> queues = Repo.all(query())
iex> Enum.all?(queues, &is_struct(&1, EctoPGMQ.Queue))
true