0.1.0-beta.1 ยท provisional API
Courier
Async Rust framework for composable data pipelines.
Source → Transform* → Sink[], declared in TOML, wired at runtime.
[[pipelines]]
name = "api->kafka"
[pipelines.source]
type = "api_poll"
url = "https://api.example.com/v1/events"
interval_secs = 3
[[pipelines.transforms]]
type = "script"
runtime = "rhai"
script = """
fn transform(env) {
env.payload["seen"] = true;
env
}
"""
[[pipelines.sinks]]
type = "kafka"
brokers = "localhost:9092"
topic = "events"