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

FilterVerify verify filter's type return false is illegal

func FilterVerifyStr

func FilterVerifyStr(s string) bool

FilterVerifyStr verify sting correct return false if illegal

Types

type Filter

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

Filter verify message, filter or pass message by blacklist and whitelist

func NewFilter

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

NewFilter return a Filter object

func (*Filter) IsFilter

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

IsFilter filter message by message object return true if not pass

func (*Filter) IsFilterWithName

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

IsFilterWithName filter message by database name and table name. return true if not pass