Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDataPipeline ¶
func NewDataPipeline() wf.PipelineInterface
NewDataPipeline creates a pipeline for data processing
func NewProcessDataStep ¶
func NewProcessDataStep() wf.StepInterface
NewProcessDataStep creates a step that processes data
func NewTransformDataStep ¶
func NewTransformDataStep() wf.StepInterface
NewTransformDataStep creates a step that transforms data
func NewValidateDataStep ¶
func NewValidateDataStep() wf.StepInterface
NewValidateDataStep creates a step that validates data
func RunPipelineStateExample ¶
func RunPipelineStateExample() error
RunPipelineStateExample demonstrates the pipeline with state management
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.