Headrace

OTel-native, stateful stream processing in a single Rust binary. Run stateful, event-time aggregations over OpenTelemetry and forward the aggregated metrics to your backend, not every datapoint.

Run it in-process for dev and the edge, or scale it across a cluster over a partitioned backend. Same pipeline, either way.

Start here

• Install - get the binary from source, Docker, or Helm.
• Getting started - run your first pipeline in a minute.
• Concepts - the pipeline graph, the record, event time, and run modes.

Build a pipeline

• Sources - OTLP, stdin, generator.
• Transforms - filter, map, window, join.
• Sinks - stdout, OTLP.

Reference

• CLI and self-metrics.
• Troubleshooting - late records, dropped records, validation errors.
• Design - how it works, end to end.