EctoJob.Producer.State (ecto_job v3.1.0) View Source

Internal state of the Producer GenStage

Link to this section Summary

Link to this section Types

Specs

t() :: %EctoJob.Producer.State{
  clock: (() -> DateTime.t()),
  demand: integer(),
  execution_timeout: EctoJob.Producer.timeout_ms(),
  notifications_listen_timeout: EctoJob.Producer.timeout_ms(),
  notifier: EctoJob.Producer.notifier(),
  poll_interval: non_neg_integer(),
  repo: EctoJob.Producer.repo(),
  reservation_timeout: EctoJob.Producer.timeout_ms(),
  schema: EctoJob.Producer.schema()
}