Module execution

Module execution 

Source
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§

ExecutionEngine
A configurable execution engine for in-memory DataSet pipelines.
ExecutionMetrics
Real-time metrics for an execution run.
ExecutionMetricsSnapshot
Immutable snapshot of ExecutionMetrics.
ExecutionOptions
Configuration for the ExecutionEngine.
StdErrExecutionObserver
A simple stderr logger for execution events.

Enums§

ExecutionEvent
Execution events emitted by the engine.

Traits§

ExecutionObserver
Observer hook for execution events.