Module pipeline 

Pipeline abstraction for compiled Ring 0 event processing.

A streaming SQL query decomposes into pipelines (compilable chains of stateless operators) separated by breakers (stateful operators like windows, joins, and aggregations). Each pipeline compiles into a single native function that processes one event at a time with zero allocations.

Types

• Pipeline: A chain of PipelineStages with input/output schemas.
• PipelineBreaker: Stateful operators that cannot be fused.
• CompiledPipeline: A compiled native function with execution stats.
• PipelineAction: Result of executing a compiled pipeline (drop/emit/error).

Structs

CompiledPipeline

A compiled pipeline ready for Ring 0 execution.

Pipeline

A compilable pipeline: a chain of stateless stages with known schemas.

PipelineId

Unique identifier for a pipeline segment.

PipelineStats

Runtime statistics for a compiled pipeline.

Enums

PipelineAction

Result of executing a compiled pipeline on one event row.

PipelineBreaker

Stateful operators that break pipeline fusion.

PipelineStage

A single stage within a compilable pipeline.

Type Aliases

PipelineFn

Function pointer type for a compiled pipeline.