aion/workflow

Workflow authoring surface.

This module is an aggregator only: it forwards declarations from the workflow submodules and contains no workflow business logic. run is the only recorded activity dispatch surface in this brief; deterministic time and random values come from AD through aion/internal/ffi.

Types

ChildHandle

</>

pub type ChildHandle(output, workflow_error) =
  child.ChildHandle(output, workflow_error)

SignalRef

</>

pub type SignalRef(payload) =
  signal.SignalRef(payload)

TimerRef

</>

pub type TimerRef =
  timer.TimerRef

Timestamp

</>

pub type Timestamp =
  run.Timestamp

WorkflowDefinition

</>

pub type WorkflowDefinition(input, output, workflow_error) =
  define.WorkflowDefinition(input, output, workflow_error)

Values

all

</>

pub fn all(
  activities: List(activity.Activity(input, output)),
) -> Result(List(output), error.ActivityError)

cancel_timer

</>

pub fn cancel_timer(
  reference: timer.TimerRef,
) -> Result(Nil, error.EngineError)

continue_as_new

</>

pub fn continue_as_new(
  input: a,
  input_codec: codec.Codec(a),
) -> Result(Nil, error.WorkflowError)

define

</>

pub fn define(
  name: String,
  input_codec: codec.Codec(input),
  output_codec: codec.Codec(output),
  error_codec: codec.Codec(workflow_error),
  entry_fn: fn(input) -> Result(output, workflow_error),
) -> define.WorkflowDefinition(input, output, workflow_error)

entry_fn

</>

pub fn entry_fn(
  definition: define.WorkflowDefinition(
    input,
    output,
    workflow_error,
  ),
) -> fn(input) -> Result(output, workflow_error)

error_codec

</>

pub fn error_codec(
  definition: define.WorkflowDefinition(
    input,
    output,
    workflow_error,
  ),
) -> codec.Codec(workflow_error)

input_codec

</>

pub fn input_codec(
  definition: define.WorkflowDefinition(
    input,
    output,
    workflow_error,
  ),
) -> codec.Codec(input)

map

</>

pub fn map(
  items: List(value),
  to_activity: fn(value) -> activity.Activity(input, output),
) -> Result(List(output), error.ActivityError)

name

</>

pub fn name(
  definition: define.WorkflowDefinition(
    input,
    output,
    workflow_error,
  ),
) -> String

now

</>

pub fn now() -> Result(run.Timestamp, error.EngineError)

output_codec

</>

pub fn output_codec(
  definition: define.WorkflowDefinition(
    input,
    output,
    workflow_error,
  ),
) -> codec.Codec(output)

race

</>

pub fn race(
  activities: List(activity.Activity(input, output)),
) -> Result(output, error.ActivityError)

random

</>

pub fn random() -> Result(Float, error.EngineError)

random_int

</>

pub fn random_int(
  min: Int,
  max: Int,
) -> Result(Int, error.EngineError)

receive

</>

pub fn receive(
  reference: signal.SignalRef(payload),
) -> Result(payload, error.ReceiveError)

run

</>

pub fn run(
  activity: activity.Activity(input, output),
) -> Result(output, error.ActivityError)

sleep

</>

pub fn sleep(
  duration: duration.Duration,
) -> Result(Nil, error.EngineError)

spawn

</>

pub fn spawn(
  name: String,
  workflow_fn: fn(input) -> Result(output, workflow_error),
  input: input,
  input_codec: codec.Codec(input),
  output_codec: codec.Codec(output),
  error_codec: codec.Codec(workflow_error),
) -> Result(
  child.ChildHandle(output, workflow_error),
  error.EngineError,
)

spawn_and_wait

</>

pub fn spawn_and_wait(
  name: String,
  workflow_fn: fn(input) -> Result(output, workflow_error),
  input: input,
  input_codec: codec.Codec(input),
  output_codec: codec.Codec(output),
  error_codec: codec.Codec(workflow_error),
) -> Result(output, error.ChildError(workflow_error))

start_timer

</>

pub fn start_timer(
  name: String,
  duration: duration.Duration,
) -> Result(timer.TimerRef, error.EngineError)

timer_id

</>

pub fn timer_id(reference: timer.TimerRef) -> String

timestamp_to_milliseconds

</>

pub fn timestamp_to_milliseconds(timestamp: run.Timestamp) -> Int

with_timeout

</>

pub fn with_timeout(
  operation: fn() -> Result(value, inner_error),
  deadline: duration.Duration,
) -> Result(value, error.TimeoutResultError(inner_error))