pipeline

package

v0.32.6 Latest Latest Go to latest Published: Oct 9, 2025 License: Apache-2.0 Imports: 5 Imported by: 5

Details

This section is empty.

This section is empty.

This section is empty.

type Pipeline struct {
	// contains filtered or unexported fields
}

func New() *Pipeline

func (p *Pipeline) AddFilter(filter plugin.Plugin)

func (p *Pipeline) AddInput(input plugin.Plugin)

func (p *Pipeline) AddOutput(output plugin.Plugin)

func (p *Pipeline) ErrorChan() <-chan error

ErrorChan is read-only

func (p *Pipeline) Start() error

Start initiates the configured plugins and starts the necessary background processes to run the pipeline

func (p *Pipeline) Stop() error

Stop shuts down the pipeline and all plugins Stop is idempotent and safe to call multiple times A stopped pipeline cannot be restarted