pipeline

Documentation

Index

• type BasePipeline
  • func NewBasePipeline() *BasePipeline
  • func (p *BasePipeline) ApplyProcessors(msg *core.Message) (skip bool, err error)
  • func (p *BasePipeline) Configure(config core.StringMap) (err error)
  • func (p *BasePipeline) GetInput() core.Input
  • func (p *BasePipeline) GetProcessors() []core.Processor
  • func (p *BasePipeline) GetState() ([]byte, bool)
  • func (p *BasePipeline) SetInput(input core.Input)
  • func (p *BasePipeline) SetProcessors(processors []core.Processor)
  • func (p *BasePipeline) SetState(state []byte) (err error)
  • func (p *BasePipeline) Start() (err error)
  • func (p *BasePipeline) Stop()
• type BasePipelineLifeCycle

Types

type BasePipeline

type BasePipeline struct {
	*core.BaseInput

	LifeCycleFunctor BasePipelineLifeCycle
	// contains filtered or unexported fields
}

func NewBasePipeline

func NewBasePipeline() *BasePipeline

func (*BasePipeline) ApplyProcessors

func (p *BasePipeline) ApplyProcessors(msg *core.Message) (skip bool, err error)

func (*BasePipeline) Configure

func (p *BasePipeline) Configure(config core.StringMap) (err error)

func (*BasePipeline) GetInput

func (p *BasePipeline) GetInput() core.Input

func (*BasePipeline) GetProcessors

func (p *BasePipeline) GetProcessors() []core.Processor

func (*BasePipeline) GetState

func (p *BasePipeline) GetState() ([]byte, bool)

func (*BasePipeline) SetInput

func (p *BasePipeline) SetInput(input core.Input)

func (*BasePipeline) SetProcessors

func (p *BasePipeline) SetProcessors(processors []core.Processor)

func (*BasePipeline) SetState

func (p *BasePipeline) SetState(state []byte) (err error)

func (*BasePipeline) Start

func (p *BasePipeline) Start() (err error)

func (*BasePipeline) Stop

func (p *BasePipeline) Stop()

type BasePipelineLifeCycle

type BasePipelineLifeCycle interface {
	StartPipeline() error
	StopPipeline()
}