value

Documentation

Index

• type ColumnValueConfig
• type ColumnValueProcessor
  • func NewColumnValueProcessor() *ColumnValueProcessor
  • func (p *ColumnValueProcessor) Configure(config core.StringMap) (err error)
  • func (p *ColumnValueProcessor) Process(msg *core.Message) (bool, error)
• type DBTableNameCatcher
  • func NewDBTableNameCatcher() *DBTableNameCatcher
  • func (catcher *DBTableNameCatcher) Configure(config core.StringMap) (err error)
  • func (catcher *DBTableNameCatcher) Process(msg *core.Message) (bool, error)
• type DBTableNameCatcherConfig
• type ValueMapper
  • func NewValueMapper() *ValueMapper
  • func (m *ValueMapper) Configure(config core.StringMap) (err error)
  • func (m *ValueMapper) Process(msg *core.Message) (bool, error)
• type ValueMapperConfig

Types

type ColumnValueConfig

type ColumnValueConfig struct {
	TableNameVariable   string
	OutputVariable      string
	TableColumnMappings map[string]string
}

type ColumnValueProcessor

type ColumnValueProcessor struct {
	*core.BaseComponent
	// contains filtered or unexported fields
}

func NewColumnValueProcessor

func NewColumnValueProcessor() *ColumnValueProcessor

func (*ColumnValueProcessor) Configure

func (p *ColumnValueProcessor) Configure(config core.StringMap) (err error)

func (*ColumnValueProcessor) Process

func (p *ColumnValueProcessor) Process(msg *core.Message) (bool, error)

type DBTableNameCatcher

type DBTableNameCatcher struct {
	*core.BaseComponent
	// contains filtered or unexported fields
}

func NewDBTableNameCatcher

func NewDBTableNameCatcher() *DBTableNameCatcher

func (*DBTableNameCatcher) Configure

func (catcher *DBTableNameCatcher) Configure(config core.StringMap) (err error)

func (*DBTableNameCatcher) Process

func (catcher *DBTableNameCatcher) Process(msg *core.Message) (bool, error)

type DBTableNameCatcherConfig

type DBTableNameCatcherConfig struct {
	// if TableNamePattern and TableNameVariable both configured, we will use the sub match as table name
	// or only TableNameVariable configured, we will use table name of db event directly
	TableNamePattern  string
	TableNameVariable string
	// if DBNamePattern and DBNameVariable both configured, we will use the sub match as db name
	// or only DBNameVariable configured, we will use db name of db event directly
	DBNamePattern  string
	DBNameVariable string
}

type ValueMapper

type ValueMapper struct {
	*core.BaseComponent
	// contains filtered or unexported fields
}

func NewValueMapper

func NewValueMapper() *ValueMapper

func (*ValueMapper) Configure

func (m *ValueMapper) Configure(config core.StringMap) (err error)

func (*ValueMapper) Process

func (m *ValueMapper) Process(msg *core.Message) (bool, error)

type ValueMapperConfig

type ValueMapperConfig struct {
	InputVariable  string
	OutputVariable string
	Mappings       map[string]string
}