Opus v0.3.1 Opus.Pipeline.Stage behaviour

Specification of the stage behavior

Link to this section Summary

Functions

handle_run(res, map)

maybe_run(stage, input)

with_retries(arg, fun)

with_retries(arg, fun, map)

Callbacks

run({}, input)

Link to this section Functions

Link to this function handle_run(res, map)

Link to this function maybe_run(stage, input)

Link to this function with_retries(arg, fun)

Link to this function with_retries(arg, fun, map)

Link to this section Callbacks

Link to this callback run({}, input)

run(
  {module :: atom(), type :: atom(), name :: atom(), opts :: %{}},
  input :: any()
) :: {:cont | :halt, any()}