Stream
Transit
Message Streaming System
Rust-first message streaming with object storage as a first-class persistence layer. Native tiered storage, stream lineage, and explicit branch-and-merge semantics built for AI traces and agent runtimes.
Highlights
- →Object storage as the default architecture — tiered storage is native, not optional archival; designed for workloads where provenance and replay are non-negotiable.
- →DAG-based stream lineage — explicit branching and merging with O(1) branch creation; no data copying, no silent history rewrites.
- →Embedded and server modes — single storage engine deployable in-process or as a networked daemon with the same API surface.
- →AI/agent workload native — purpose-built for replayable traces, retries, forks, and evaluation provenance; handles divergence tracking without losing lineage.
- →Integrity verification — staged checksums, manifest roots, and cryptographic lineage checkpoints at every persistence boundary.
- →Failover stack — leader election, lease fencing, and quorum-based durability controls with incremental materialization via Prolly Tree snapshots.