filter

Documentation

Index

• type Controller
• type Filter
  • func New(opts ...Option) (filter *Filter, err error)
  • func (f *Filter) Context() context.Context
  • func (f *Filter) Run(ctx context.Context) (err error)
• type Option
  • func WithPipe(p *pipeline2.Pipeline) Option
• type Options

Types

type Controller

type Controller struct {
}

type Filter

type Filter struct {
	InChan  chan *message2.Message
	OutChan chan *message2.Message
	Options *Options
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) (filter *Filter, err error)

func (*Filter) Context

func (f *Filter) Context() context.Context

func (*Filter) Run

func (f *Filter) Run(ctx context.Context) (err error)

type Option

type Option func(options *Options)

func WithPipe

func WithPipe(p *pipeline2.Pipeline) Option

type Options

type Options struct {
	Pipe *pipeline2.Pipeline
}