pipeline

Documentation

Index

• Constants
• type Option
  • func OptionPipeline(option *pipeline.Pipeline) Option
  • func OptionPosition(option *pipeline.Position) Option
• type Options
• type Pipeline
  • func New(opt ...Option) (p *Pipeline, err error)
  • func (p *Pipeline) Run(ctx context.Context)

Constants

const (
	STATUS_RUN  status = 1
	STATUS_STOP status = 2
)

Types

type Option

type Option func(*Options)

Option is a function for configure Options

func OptionPipeline

func OptionPipeline(option *pipeline.Pipeline) Option

OptionPipeline sets pipeline

func OptionPosition

func OptionPosition(option *pipeline.Position) Option

OptionPosition sets position

type Options

type Options struct {
	Pipeline *pipeline.Pipeline
	Position *pipeline.Position
}

Options for pipeline

type Pipeline

type Pipeline struct {
	Input   *input.Input
	Output  *output.Output
	Filter  *filter.Filter
	Options Options
	// contains filtered or unexported fields
}

Pipeline for handle message contains input, filter, output

func New

func New(opt ...Option) (p *Pipeline, err error)

New returns a new pipeline

func (*Pipeline) Run

func (p *Pipeline) Run(ctx context.Context)

Run pipeline start working