The highest tagged major version is v2.

tool

package

v1.0.13 Latest Latest Go to latest Published: Nov 23, 2021 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func FilterVerify(f *pipeline.Filter) bool

FilterVerify verify filter's type return false is illegal

func FilterVerifyStr(s string) bool

FilterVerifyStr verify sting correct return false if illegal

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(filters []*pipeline.Filter) (f *Filter)

NewFilter return a Filter object

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

IsFilter filter message by message object return true if not pass

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

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