aion-server 0.30.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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

//! axum HTTP/JSON workflow facade.
//!
//! Module layout:
//! - [`router`] — public router construction (the only public surface).
//! - `workflows` — workflow management handlers.
//! - `children` — authorized direct-child projection for one parent run.
//! - `schedules` — schedule management handlers.
//! - `events` — websocket event-subscription handlers.
//! - `deploy` — operator deploy handlers (mounted only when `[deploy].enabled`).
//! - `awl_deployed` — the read-only deployed-AWL studio surface (mounted only
//!   when `[deploy].enabled`, alongside the deploy read model it reflects).
//! - `authoring` — server-side Gleam authoring (mounted only when `[authoring].gleam_path` is set).
//! - `dev_ui` — local dev-server surface (mounted only when `[dev].enabled`).
//! - `auth` — caller-identity extraction from request headers.
//! - `routing` — shard-owner forwarding for HTTP writes (clustered builds).
//! - `visibility` — visibility query-string parsing and namespace scoping.
//! - `payload` — HTTP body/payload encode-decode shapes and conversions.
//! - `build` — `GET /build`, the server's own revision.
//! - `update_status` — `GET /update-status`, the installed version joined
//!   with the last completed manual update check.
//! - `describe_live` — the mid-step join: current step + attempt liveness +
//!   progress note + transcript tail, in one read.
//! - `assistant` — `GET /assistant`, the harness catalogue, tool wiring,
//!   session availability and grant standing this binary carries.
//! - `assistant_sessions` — `/assistant/sessions`, the caller's own
//!   conversations with an agent harness this server owns.
//! - `assistant_socket` — `GET /assistant/sessions/{id}/events`, one session's
//!   transcript replayed and then streamed live.
//! - `queues` — the fleet-wide unserved-queue read.
//! - `managed_workers` — `GET /workers/managed`, the supervision status join,
//!   and the `POST /workers/managed/{name}/{start,stop,restart}` lifecycle
//!   commands (mounted only when `[deploy].enabled`, like the gRPC
//!   `DeployService` counterparts they mirror).
//! - `unrecoverable` — the fleet-wide degraded-residency read.
//! - `clean_dtos` — clean JSON request/response DTOs for the workflow POST endpoints.
//! - `error` — wire-error-to-HTTP response mapping.

mod assistant;
mod assistant_sessions;
mod assistant_socket;
pub(crate) mod auth;
mod authoring;
mod awl;
mod awl_deployed;
mod awl_graph;
mod build;
mod changelog;
mod children;
mod clean_dtos;
mod cluster_command;
mod deploy;
mod describe_live;
mod dev_ui;
mod error;
mod events;
mod history;
mod intervene;
mod managed_workers;
mod outbox;
mod payload;
mod queues;
mod router;
mod routing;
mod schedules;
mod transcripts;
mod unrecoverable;
mod update_status;
mod whoami;
mod worker_deployments;
mod workers;
mod workflow_document;
mod workflows;

#[cfg(test)]
mod children_tests;
#[cfg(test)]
mod events_filter_integration_tests;
#[cfg(test)]
mod history_tests;
#[cfg(test)]
pub(crate) mod test_support;
#[cfg(test)]
mod transcripts_tests;

pub use router::{http_router, workflow_router};