Documentation
¶
Overview ¶
Package pipeline assembles built command segments into a runnable typed-stream pipeline and executes it against the gloo-foo/framework.
Plan folds an ordered list of stages into an Assembly: the first stage chooses the input source (a source command, named files, or stdin) and later stages must be plain filters. Assembly.Run streams the result to an output writer. The package knows how to wire and run segments; it does not know how a segment is built (that is internal/command) nor how a line is parsed (the line domain).
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Assembly ¶
type Assembly struct {
// contains filtered or unexported fields
}
Assembly is the resolved plan for a pipeline: an input source and the ordered transform commands applied to it. It is an immutable value: the add* methods take the assembly by value and return the extended assembly, and Run only reads the finished plan.