Expand description
Incremental merge of ChunkTelemetry into RunningAggregateStateV1.
Re-exportsยง
pub use emit::emit_result_snapshot;pub use emit::emit_timeline_snapshot;
Modulesยง
Structsยง
- Merge
Error - Error produced while merging a chunk into the running state.
Enumsยง
- Merge
Error ๐Kind
Functionsยง
- merge_
chunk - Incrementally merge a
ChunkTelemetryintoRunningAggregateStateV1. - new_
running_ state - Build a zeroed
RunningAggregateStateV1sized forchunks_totalchunks. - validate_
chunk - Validate a chunk against the running state before merging it in.