filter

Documentation

Index

• Constants
• func FindColumn(data map[string]interface{}, name string) interface{}
• type ConvertDmlColumnFilter
  • func (cdcf *ConvertDmlColumnFilter) Filter(msg *msg.Msg) bool
  • func (cdcf *ConvertDmlColumnFilter) NewFilter(config map[string]interface{}) error
• type ConvertSnakeCaseColumnFilter
  • func (cdcf *ConvertSnakeCaseColumnFilter) Filter(m *msg.Msg) bool
  • func (cdcf *ConvertSnakeCaseColumnFilter) NewFilter(config map[string]interface{}) error
• type DeleteDmlColumnFilter
  • func (ddcf *DeleteDmlColumnFilter) Filter(msg *msg.Msg) bool
  • func (ddcf *DeleteDmlColumnFilter) NewFilter(config map[string]interface{}) error
• type Filter
• type MatcherFilter
  • func NewMatcherFilter(filterConfigs []*config.FilterConfig) MatcherFilter
  • func (matcher MatcherFilter) IterateFilter(msg *msg.Msg) bool
  • func (matcher MatcherFilter) StartFilter(syncChan *channel.SyncChannel, outputChan *channel.OutputChannel, ...)
• type RenameDmlColumnFilter
  • func (rdcf *RenameDmlColumnFilter) Filter(msg *msg.Msg) bool
  • func (rdcf *RenameDmlColumnFilter) NewFilter(config map[string]interface{}) error

Constants

const ConvertDmlColumnFilterName = "convert-dml-column"

const ConvertSnakeCaseColumnFilterName = "convert-snakecase-column"

const DeleteDMLColumnFilterName = "delete-dml-column"

const RenameDmlColumnFilterName = "rename-dml-column"

Functions

func FindColumn

func FindColumn(data map[string]interface{}, name string) interface{}

Types

type ConvertDmlColumnFilter

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

func (*ConvertDmlColumnFilter) Filter

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

func (*ConvertDmlColumnFilter) NewFilter

func (cdcf *ConvertDmlColumnFilter) NewFilter(config map[string]interface{}) error

type ConvertSnakeCaseColumnFilter

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

func (*ConvertSnakeCaseColumnFilter) Filter

func (cdcf *ConvertSnakeCaseColumnFilter) Filter(m *msg.Msg) bool

func (*ConvertSnakeCaseColumnFilter) NewFilter

func (cdcf *ConvertSnakeCaseColumnFilter) NewFilter(config map[string]interface{}) error

type DeleteDmlColumnFilter

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

func (*DeleteDmlColumnFilter) Filter

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

func (*DeleteDmlColumnFilter) NewFilter

func (ddcf *DeleteDmlColumnFilter) NewFilter(config map[string]interface{}) error

type Filter

type Filter interface {
	NewFilter(config map[string]interface{}) error
	Filter(msg *msg.Msg) bool
}

type MatcherFilter

type MatcherFilter []Filter

func NewMatcherFilter

func NewMatcherFilter(filterConfigs []*config.FilterConfig) MatcherFilter

func (MatcherFilter) IterateFilter

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

func (MatcherFilter) StartFilter

func (matcher MatcherFilter) StartFilter(syncChan *channel.SyncChannel, outputChan *channel.OutputChannel, inSchema schema.Schema)

type RenameDmlColumnFilter

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

func (*RenameDmlColumnFilter) Filter

func (rdcf *RenameDmlColumnFilter) Filter(msg *msg.Msg) bool

func (*RenameDmlColumnFilter) NewFilter

func (rdcf *RenameDmlColumnFilter) NewFilter(config map[string]interface{}) error