EctoPGMQ.Throttle (ecto_pgmq v1.0.0)

Copy Markdown View Source

Schema for PGMQ queue notification throttles.

This schema can be queried directly but throttles are fetched transparently when querying queues via EctoPGMQ.Queue.query/0.

Examples

iex> throttles = Repo.all(EctoPGMQ.Throttle)
iex> Enum.all?(throttles, &is_struct(&1, EctoPGMQ.Throttle))
true

Summary

Types

t()

A PGMQ queue notification throttle.

Types

t()

@type t() :: %EctoPGMQ.Throttle{
  __meta__: term(),
  last_notified_at: DateTime.t() | nil,
  queue: EctoPGMQ.Queue.name(),
  throttle: Duration.t()
}

A PGMQ queue notification throttle.