regex

Documentation

Index

• type Filter
  • func NewFilter(opts FilterOptions) *Filter
  • func (r *Filter) Process(ctx context.Context, args selina.ProcessArgs) error
• type FilterOptions
  • func (o FilterOptions) Check() error

Types

type Filter

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

Filter Worker read []byte from input channel, apply regular expresion if []byte match against Pattern , []byte is sent to output

func NewFilter

func NewFilter(opts FilterOptions) *Filter

NewFilter create a new Filter Worker with specified options

func (*Filter) Process

func (r *Filter) Process(ctx context.Context, args selina.ProcessArgs) error

Process implements Worker interface

type FilterOptions

type FilterOptions struct {
	//Pattern valid regular expresion
	Pattern string
}

FilterOptions customize Filter Worker

func (FilterOptions) Check

func (o FilterOptions) Check() error

Check if a combination of options is valid