filters

Documentation

Index

• Constants
• func NewFilters(filterConfigs []config.GenericConfig) ([]core.IFilter, error)
• type BaseFilter
  • func (baseFilter *BaseFilter) ConfigureMatchers(configData map[string]interface{}) error
  • func (baseFilter *BaseFilter) MatchMsg(msg *core.Msg) bool

Constants

const AcceptFilterName = "accept"

const DeleteDMLColumnFilterName = "delete-dml-column"

const RejectFilterName = "reject"

const RenameColumnFilterName = "rename-dml-column"

Functions

func NewFilters

func NewFilters(filterConfigs []config.GenericConfig) ([]core.IFilter, error)

Types

type BaseFilter

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

func (*BaseFilter) ConfigureMatchers

func (baseFilter *BaseFilter) ConfigureMatchers(configData map[string]interface{}) error

func (*BaseFilter) MatchMsg

func (baseFilter *BaseFilter) MatchMsg(msg *core.Msg) bool