filter

Documentation

Index

• type BinlogFilter
• type BinlogFilterMatcher
  • func (matcher BinlogFilterMatcher) IterateFilter(msg *msg.Msg) bool
• type ChangeStreamFilter
• type ChangeStreamFilterMatcher
  • func (matcher ChangeStreamFilterMatcher) IterateFilter(msg *msg.MongoMsg) bool
• type ConvertDmlColumnFilter
  • func NewConvertDmlColumnFilter(config map[string]interface{}) (*ConvertDmlColumnFilter, error)
  • func (filter *ConvertDmlColumnFilter) Filter(msg *msg.Msg) bool
• type DeleteDmlColumnFilter
  • func NewDeleteDmlColumnFilter(config map[string]interface{}) (*DeleteDmlColumnFilter, error)
  • func (filter *DeleteDmlColumnFilter) Filter(msg *msg.Msg) bool
• type RuleFilter
  • func NewRuleFilter(includeTableRegex []string) *RuleFilter
  • func (filter *RuleFilter) Filter(msg *msg.MongoMsg) bool

Types

type BinlogFilter

type BinlogFilter interface {
	Filter(msg *msg.Msg) bool
}

type BinlogFilterMatcher

type BinlogFilterMatcher []BinlogFilter

func (BinlogFilterMatcher) IterateFilter

func (matcher BinlogFilterMatcher) IterateFilter(msg *msg.Msg) bool

type ChangeStreamFilter

type ChangeStreamFilter interface {
	Filter(msg *msg.MongoMsg) bool
}

type ChangeStreamFilterMatcher

type ChangeStreamFilterMatcher []ChangeStreamFilter

func (ChangeStreamFilterMatcher) IterateFilter

func (matcher ChangeStreamFilterMatcher) IterateFilter(msg *msg.MongoMsg) bool

type ConvertDmlColumnFilter

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

func NewConvertDmlColumnFilter

func NewConvertDmlColumnFilter(config map[string]interface{}) (*ConvertDmlColumnFilter, error)

func (*ConvertDmlColumnFilter) Filter

func (filter *ConvertDmlColumnFilter) Filter(msg *msg.Msg) bool

type DeleteDmlColumnFilter

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

func NewDeleteDmlColumnFilter

func NewDeleteDmlColumnFilter(config map[string]interface{}) (*DeleteDmlColumnFilter, error)

func (*DeleteDmlColumnFilter) Filter

func (filter *DeleteDmlColumnFilter) Filter(msg *msg.Msg) bool

type RuleFilter

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

func NewRuleFilter

func NewRuleFilter(includeTableRegex []string) *RuleFilter

func (*RuleFilter) Filter

func (filter *RuleFilter) Filter(msg *msg.MongoMsg) bool