AshOban.Trigger (ash_oban v0.6.0)

View Source

A configured trigger.

Summary

Types

t()

@type t() :: %AshOban.Trigger{
  __identifier__: atom(),
  __spark_metadata__: term(),
  action: atom(),
  action_input: map(),
  actor_persister: module() | :none | nil,
  backoff: pos_integer() | (map() -> pos_integer()) | :exponential,
  debug?: boolean(),
  extra_args: map() | (map() -> map()),
  list_tenants: term(),
  lock_for_update?: boolean(),
  log_errors?: boolean(),
  log_final_error?: boolean(),
  max_attempts: pos_integer(),
  max_scheduler_attempts: pos_integer(),
  name: atom(),
  on_error: atom(),
  on_error_fails_job?: boolean(),
  queue: atom(),
  read_action: atom(),
  read_metadata: (Ash.Resource.record() -> map()),
  record_limit: pos_integer(),
  scheduler: module() | nil,
  scheduler_cron: String.t(),
  scheduler_module_name: module() | nil,
  scheduler_priority: non_neg_integer(),
  scheduler_queue: atom(),
  shared_context?: boolean(),
  sort: term(),
  state: :active | :paused | :deleted,
  stream_batch_size: pos_integer(),
  stream_with: :keyset | :offset | :full_read,
  timeout: pos_integer() | (map() -> pos_integer()) | :infinity,
  trigger_once?: boolean(),
  use_tenant_from_record?: boolean(),
  where: Ash.Expr.t(),
  worker: module(),
  worker_module_name: module() | nil,
  worker_opts: keyword(),
  worker_priority: non_neg_integer(),
  worker_read_action: term()
}

Functions

transform(trigger)