tidemarkIn progress
Exactly-Once Stream Processing in Go
- Go
- Pebble
- Stream Processing
- Nexmark
- Event-time stream processing engine in Go: watermarks propagate through the dataflow graph as the minimum across input channels, so a window fires only after every upstream partition has passed it.
- Chandy-Lamport barrier checkpointing with Pebble-backed operator state. Sinks commit only once a checkpoint is confirmed, so a run that fails mid-job and recovers ends with the same sink contents as a clean run.
- Faults are injected at deterministic logical positions, never on a wall clock, and a chaos suite runs seeded fault schedules across five Nexmark queries with windowed results checked against a batch oracle.