Structs

A pipeline which consists of multiple steps. Steps are Processable workloads. Later steps depend on previous ones.
Context which is available to each step within a DataPipeline
Marks the end of a DataPipeline

Enums

Traits

Processes events which happen during the pipeline execution