mapping

Documentation

Index

• type DBChangeMappingProcessor
  • func NewDBChangeMappingProcessor() *DBChangeMappingProcessor
  • func (p *DBChangeMappingProcessor) Configure(config core.StringMap) (err error)
  • func (p *DBChangeMappingProcessor) Process(msg *core.Message) (skip bool, err error)
• type DBInfo
• type TableInfo

Types

type DBChangeMappingProcessor

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

func NewDBChangeMappingProcessor

func NewDBChangeMappingProcessor() *DBChangeMappingProcessor

func (*DBChangeMappingProcessor) Configure

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

func (*DBChangeMappingProcessor) Process

func (p *DBChangeMappingProcessor) Process(msg *core.Message) (skip bool, err error)

type DBInfo

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

type TableInfo

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