NewImmutablePipeMessage creates a new ImmutablePipeEvent.

NewOrchestrator creates a new Orchestrator.

NewPipeline creates a new pipeline including the stages as configured.

Config holds the configuration for each pipeline, including its input and output channels, and the number of workers.

A ImmutablePipeEvent is a wrapper for a payload (consisting of a body and attributes) and internal message attributes.

Orchestrator orchestrates multiple pipelines, each with its own input and output channels and a configurable number of workers.

A Pipeline helps orchestrate multiple pipeline steps.

PipeEvent - pipeline message payload interface.

Stage describes a pipeline stage a message can be routed through.

Status Define the Pipeline Status enum.