View Source Ash.Resource.Change behaviour (ash v2.18.2)

The behaviour for an action-specific resource change.

init/1 is defined automatically by use Ash.Resource.Change, but can be implemented if you want to validate/transform any options passed to the module.

The main function is change/3. It takes the changeset, any options that were provided when this change was configured on a resource, and the context, which currently only has the actor.

Summary

Types

context()

ref()

t()

Callbacks

after_atomic(t, t, record, context)

after_batch(changesets_and_results, opts, context)

Runs on each batch result after it is dispatched to the data layer.

atomic(t, t, context)

batch_change(changesets, opts, context)

Replaces change/3 for batch actions, allowing to optimize changes for bulk actions.

before_batch(changesets, opts, context)

Runs on each batch before it is dispatched to the data layer.

change(changeset, opts, context)

init(opts)

Types

context()

@type context() :: %{
  optional(:actor) => Ash.Resource.record() | nil,
  optional(:tenant) => String.t() | nil,
  optional(:authorize?) => boolean() | nil,
  optional(:tracer) => Ash.Tracer.t() | [Ash.Tracer.t()] | nil,
  optional(any()) => any()
}

ref()

@type ref() :: {module(), Keyword.t()} | module()

t()

@type t() :: %Ash.Resource.Change{
  always_atomic?: term(),
  change: term(),
  description: term(),
  on: term(),
  only_when_valid?: term(),
  where: term()
}

Callbacks

after_atomic(t, t, record, context)

(optional)

@callback after_atomic(Ash.Changeset.t(), Keyword.t(), Ash.Resource.record(), context()) ::
  {:ok, Ash.Resource.record()} | {:error, term()}

after_batch(changesets_and_results, opts, context)

(optional)

@callback after_batch(
  changesets_and_results :: [{Ash.Changeset.t(), Ash.Resource.record()}],
  opts :: Keyword.t(),
  context :: context()
) ::
  Enumerable.t(
    {:ok, Ash.Resource.record()}
    | {:error, Ash.Error.t()}
    | Ash.Notifier.Notification.t()
  )

Runs on each batch result after it is dispatched to the data layer.

atomic(t, t, context)

(optional)

@callback atomic(Ash.Changeset.t(), Keyword.t(), context()) ::
  {:atomic, %{required(atom()) => Ash.Expr.t()}}
  | :not_atomic
  | :ok
  | {:error, term()}

batch_change(changesets, opts, context)

(optional)

@callback batch_change(
  changesets :: [Ash.Changeset.t()],
  opts :: Keyword.t(),
  context :: context()
) :: Enumerable.t(Ash.Changeset.t() | Ash.Notifier.Notification.t())

Replaces change/3 for batch actions, allowing to optimize changes for bulk actions.

before_batch(changesets, opts, context)

(optional)

@callback before_batch(
  changesets :: [Ash.Changeset.t()],
  opts :: Keyword.t(),
  context :: context()
) :: Enumerable.t(Ash.Changeset.t() | Ash.Notifier.Notification.t())

Runs on each batch before it is dispatched to the data layer.

change(changeset, opts, context)

(optional)

@callback change(
  changeset :: Ash.Changeset.t(),
  opts :: Keyword.t(),
  context :: context()
) ::
  Ash.Changeset.t()

init(opts)

@callback init(opts :: Keyword.t()) :: {:ok, Keyword.t()} | {:error, term()}