Skip to main content

Crate awaken_server

Crate awaken_server 

Source
Expand description

HTTP server layer for the awaken agent framework.

Provides an Axum-based server that exposes agents over HTTP with Server-Sent Events (SSE) streaming. Includes routing, protocol adapters (AI SDK, AG-UI), mailbox polling, metrics, and request/response conversion utilities. Enabled via the server feature flag on the awaken facade crate.

Modules§

app
Application state and server startup.
config_routes
durable_message_sink
Host implementation of the runtime’s DurableMessageSink: delivers durable cross-thread send_message messages by enqueuing a background run on the recipient thread via the Mailbox.
error
Canonical API error type for HTTP handlers.
eval_limits
Operator-tunable caps for the /v1/eval/* endpoints. Lifted out of app.rs so adding/changing a knob doesn’t drag the central server config file past its line cap.
eval_router
/v1/eval/* route registration. Lifted out of routes.rs so the eval surface (datasets, runs, online, importers) lives next to its own handlers and stops dominating the central router file.
event_relay
Transport-agnostic event relay pipeline.
http_run
HTTP run execution with SSE relay.
http_sse
SSE response helpers for streaming agent events over HTTP.
mailbox
Mailbox service: persistent run queue, dispatch execution, leasing, and lifecycle management.
message_convert
Shared message conversion for protocol handlers.
metrics
Prometheus metrics endpoint and metric definitions.
outbox_relay
Generic at-least-once outbox relay.
prelude
protocol_fanout
Protocol replay outbox fanout relay.
protocol_projector
Protocol replay projectors backed by ProtocolReplayLog.
protocol_replay_state
Optional ProtocolReplayLog and projector relay attachments.
protocols
query
Shared query-parameter types for paginated endpoints.
request
Request preparation utilities.
routes
Axum router setup — unified route registration.
run_dispatch
scope
services
time
Shared time-conversion helpers.
transport