Crate courier 

Courier — async pipelines composed as Source → Transform* → Sink[].

Nodes communicate via tokio::mpsc channels of Envelope. Each node runs as its own task; the shared CancellationToken triggers a graceful drain on SIGINT/Ctrl+C.

Re-exports

pub use registry::Registry;

pub use registry::register_builtin;

pub use retry::ExhaustedPolicy;

pub use retry::RetryPolicy;

pub use sinks::ManagedSink;

Modules

cli

config

envelope

observability

Observability primitives for the Courier runtime.

pipeline

registry

Runtime component registry.

retry

sinks

sources

transforms

Structs

Courier

Top-level runtime. Owns every pipeline; run blocks until all of them exit (cancellation, upstream closure, or unrecoverable error).