aion-server 0.26.0

Aion workflow server library: HTTP, gRPC, WebSocket, and worker endpoints. Run it with the `aion` binary from the aion-cli crate.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

//! Project block-nested sibling steps with an inherited per-item region.
workflow region_scoped_substeps
  input items: [String]
  outcome done: type Result, route success

type Result { value: String }

worker jobs
  action decide() -> Bool
  action mark(item: String) -> String

step wave
  distribute item in items

step member
  fork branch in items
    step fork_choose
      outcome next: else, route fork_finish

    step fork_finish
      outcome again: else, route fork_choose
      max 2 visits
  join

  loop complete = false
    step loop_choose
      outcome next: else, route loop_finish

    step loop_finish
      outcome again: else, route loop_choose
      max 2 visits

    decide() -> complete
    until complete
    max 1

  mark(item: item) -> verdict

  outcome loop_complete: if complete, route gather
  outcome loop_exhausted: else, route gather

step gather
  collect verdict -> results

step finish
  route done(value: "region complete")