Expand description
Execution engine for running processing pipelines with configurable parallelism.
This module sits “above” crate::processing and provides:
- Parallel (chunked) execution for filter/map
- Resource limits / throttling (e.g., in-flight chunks)
- Real-time metrics + observer hooks for monitoring
Structs§
- Execution
Engine - A configurable execution engine for in-memory
DataSetpipelines. - Execution
Metrics - Real-time metrics for an execution run.
- Execution
Metrics Snapshot - Immutable snapshot of
ExecutionMetrics. - Execution
Options - Configuration for the
ExecutionEngine. - StdErr
Execution Observer - A simple stderr logger for execution events.
Enums§
- Execution
Event - Execution events emitted by the engine.
Traits§
- Execution
Observer - Observer hook for execution events.