proxima-lib 0.1.0

A sans-IO core where everything is a Pipe — one async In -> Result<Out, Err> trait worn four ways (transform, source, sink, observe), composed into proxies, gateways, caches, codecs and telemetry pipelines. Config-driven, runtime-agnostic: the same pipe runs on the from-scratch Prime per-core runtime, on tokio, or on no_std bare metal.
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

//! Pipeline executor: a DAG of stages, each one a child process, run
//! atop the `ProcessUpstream` + `ProcessEventBridge` composition.
//! `PipelineExecutor::run` consumes a `PipelineSpec`, allocates per-stage
//! `InteractionId`s, and emits universal `RecordingEvent`s into the
//! configured sink. See `executor.rs` for execution semantics and
//! `spec.rs` for the declarative shape.

pub mod control_plane;
pub mod dag;
pub mod executor;
pub mod explain;
pub mod fs_control_plane;
pub mod http_routes;
pub mod replay;
pub mod spec;

pub use control_plane::{
    DynPipelineControlPlane, EventFilter, EventStream, InMemoryPipelineControlPlane, ListFilter,
    PipelineControlPlane, PipelineRecord, PipelineStatus, PipelineSubmission, PipelineSummary,
};
pub use dag::topological_order;
pub use executor::{PipelineExecutor, PipelineRunReport, StageReport};
pub use explain::{ExplainStep, explain_stage};
pub use fs_control_plane::FsPipelineControlPlane;
pub use http_routes::PipelineControlPlanePipe;
pub use replay::{ReplayReport, replay_pipeline};
pub use spec::{PipelineSpec, StageSpec};