pipeline

Documentation

Index

• type Pipeline
  • 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
  • func (p *Pipeline) Stop() error

Types

type Pipeline

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

func New

func New() *Pipeline

func (*Pipeline) AddFilter

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

func (*Pipeline) AddInput

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

func (*Pipeline) AddOutput

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

func (*Pipeline) ErrorChan

func (p *Pipeline) ErrorChan() chan error

func (*Pipeline) Start

func (p *Pipeline) Start() error

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

func (*Pipeline) Stop

func (p *Pipeline) Stop() error

Stop shuts down the pipeline and all plugins