View Source AshOban.Trigger (ash_oban v0.2.4)

A configured trigger.

Summary

Types

@type t() :: %AshOban.Trigger{
  __identifier__: atom(),
  action: atom(),
  action_input: map(),
  debug?: boolean(),
  log_errors?: boolean(),
  log_final_error?: boolean(),
  max_attempts: pos_integer(),
  max_scheduler_attempts: pos_integer(),
  name: atom(),
  on_error: atom(),
  queue: atom(),
  read_action: atom(),
  read_metadata: (Ash.Resource.record() -> map()),
  record_limit: pos_integer(),
  scheduler: module() | nil,
  scheduler_cron: String.t(),
  scheduler_priority: non_neg_integer(),
  scheduler_queue: atom(),
  state: :active | :paused | :deleted,
  stream_batch_size: pos_integer(),
  where: Ash.Expr.t(),
  worker: module(),
  worker_priority: non_neg_integer(),
  worker_read_action: term()
}

Functions