Documentation ¶
Overview ¶
Package pipeline provides a framework for creating pipelines.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IPipeline ¶
type IPipeline[In any, Out any] interface { shared.IMeta[In] Run(ctx context.Context, in []In) (out []Out, err error) }
IPipeline defines what a `Pipeline` must do.
type Number ¶
type Number struct { // Numbers to be processed. Numbers []int `json:"numbers"` }
Number is a simple struct to be used in the tests.
type Pipeline ¶
type Pipeline[In any, Out any] struct { // Description of the processor. Description string `json:"description"` // Name of the processor. Name string `json:"name"` // Adapters to be used in the pipeline. Adapters map[string]adapter.IAdapter[In] `json:"adapters"` // Control the pipeline. Control chan string `json:"-"` // Progress of the pipeline. Progress int `json:"progress"` // Stages to be used in the pipeline. Stages []Stage[In, Out] `json:"stages"` // State of the pipeline. State status.Status `json:"state"` }
Pipeline definition.
func (*Pipeline[In, Out]) GetDescription ¶
GetDescription returns the `Description` of the processor.
Click to show internal directories.
Click to hide internal directories.