filter

Documentation

Index

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

Types

type Filter

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

Filter filter message by rules

func New

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

New returns a new Filter

func (*Filter) Closed

func (f *Filter) Closed() chan struct{}

func (*Filter) Run

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

Run Filter start working

type Option

type Option func(options *Options)

Option function config Options

func WithPipe

func WithPipe(p *pipeline2.Pipeline) Option

WithPipe sets pipeline to Options

type Options

type Options struct {
	Pipe *pipeline2.Pipeline
}

Options is an interface abstraction for dynamic configuration