pipeline

package

v0.32.5 Latest Latest Go to latest Published: Sep 24, 2025 License: Apache-2.0 Imports: 4 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

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