pipe_tool

Documentation

Index

• func FilterVerify(f *pipeline.Filter) bool
• func FilterVerifyStr(s string) bool
• type Filter
  • func NewFilter(filters []*pipeline.Filter) (f *Filter)
  • func (t *Filter) IsFilter(msg *message.Message) bool
  • func (t *Filter) IsFilterWithName(name string) (bool, error)

Functions

func FilterVerify

func FilterVerify(f *pipeline.Filter) bool

func FilterVerifyStr

func FilterVerifyStr(s string) bool

Types

type Filter

type Filter struct {
	DBBlack    map[string]bool
	TableBlack map[string]bool
	DBWhite    map[string]bool
	TableWhite map[string]bool
}

func NewFilter

func NewFilter(filters []*pipeline.Filter) (f *Filter)

func (*Filter) IsFilter

func (t *Filter) IsFilter(msg *message.Message) bool

func (*Filter) IsFilterWithName

func (t *Filter) IsFilterWithName(name string) (bool, error)