View Source Reactor.Executor.StepRunner (reactor v0.10.1)

Run an individual step, including compensation if possible.

Summary

Functions

run(reactor, state, step, concurrency_key)

Collect the arguments and and run a step, with compensation if required.

run_async(reactor, state, step, concurrency_key, process_contexts)

Run a step inside a task.

undo(reactor, state, step, value, concurrency_key)

Undo a step if possible.

Functions

run(reactor, state, step, concurrency_key)

@spec run(
  Reactor.t(),
  Reactor.Executor.State.t(),
  Reactor.Step.t(),
  Reactor.Executor.ConcurrencyTracker.pool_key()
) ::
  {:ok, any(), [Reactor.Step.t()]}
  | :retry
  | {:retry, any()}
  | {:error | :halt, any()}

Collect the arguments and and run a step, with compensation if required.

run_async(reactor, state, step, concurrency_key, process_contexts)

@spec run_async(
  Reactor.t(),
  Reactor.Executor.State.t(),
  Reactor.Step.t(),
  Reactor.Executor.ConcurrencyTracker.pool_key(),
  map()
) ::
  {:ok, any(), [Reactor.Step.t()]}
  | :retry
  | {:retry, any()}
  | {:error | :halt, any()}

Run a step inside a task.

This is a simple wrapper around run/4 except that it emits more events.

undo(reactor, state, step, value, concurrency_key)

@spec undo(
  Reactor.t(),
  Reactor.Executor.State.t(),
  Reactor.Step.t(),
  any(),
  Reactor.Executor.ConcurrencyTracker.pool_key()
) :: :ok | {:error, any()}

Undo a step if possible.