dts

Documentation

Index

• Constants
• type AliDts
  • func New() (*AliDts, error)
  • func (ad *AliDts) Parse(data []byte) (*DtsRecord, error)
• type DtsField
• type DtsFields
• type DtsRecord
  • func (r *DtsRecord) GetAfterColumns() map[string]string
  • func (r *DtsRecord) GetBeforeColumns() map[string]string
• type DtsTypeBytes
• type DtsTypeDateTime
• type DtsTypeTimestamp
• type DtsTypeTimestampWithTimeZone
• type DtsTypeValue

Constants

const AliyunDtsSchema = `` /* 10904-byte string literal not displayed */

Types

type AliDts

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

func New

func New() (*AliDts, error)

func (*AliDts) Parse

func (ad *AliDts) Parse(data []byte) (*DtsRecord, error)

Parse 解析DTS的消息记录

type DtsField

type DtsField struct {
	Name     string `mapstructure:"name"`
	DataType int    `mapstructure:"dataTypeNumber"`
}

type DtsFields

type DtsFields struct {
	Items []*DtsField `mapstructure:"array"`
}

type DtsRecord

type DtsRecord struct {
	Version         int                    `mapstructure:"version"`
	Id              int64                  `mapstructure:"id"`
	SourceTimeStamp int64                  `mapstructure:"sourceTimestamp"`
	SourceTxId      string                 `mapstructure:"sourceTxid"`
	ObjectName      map[string]string      `mapstructure:"objectName"` // 数据库名.表名
	Operation       string                 `mapstructure:"operation"`
	Fields          map[string]interface{} `mapstructure:"fields"`       // 字段slice
	BeforeImages    map[string]interface{} `mapstructure:"beforeImages"` // 改变前
	AfterImages     map[string]interface{} `mapstructure:"afterImages"`  // 改变后

	// 额外的字段
	Database    string
	Table       string
	TableFields []*DtsField
}

DtsRecord 原始的记录

func (*DtsRecord) GetAfterColumns

func (r *DtsRecord) GetAfterColumns() map[string]string

func (*DtsRecord) GetBeforeColumns

func (r *DtsRecord) GetBeforeColumns() map[string]string

type DtsTypeBytes

type DtsTypeBytes struct {
	Value []byte `mapstructure:"value"`
}

type DtsTypeDateTime

type DtsTypeDateTime struct {
	Year   map[string]interface{} `mapstructure:"year"`
	Month  map[string]interface{} `mapstructure:"month"`
	Day    map[string]interface{} `mapstructure:"day"`
	Hour   map[string]interface{} `mapstructure:"hour"`
	Minute map[string]interface{} `mapstructure:"minute"`
	Second map[string]interface{} `mapstructure:"second"`
}

type DtsTypeTimestamp

type DtsTypeTimestamp struct {
	Timestamp int64 `mapstructure:"timestamp"`
}

type DtsTypeTimestampWithTimeZone

type DtsTypeTimestampWithTimeZone struct {
	Value DtsTypeDateTime `mapstructure:"value"`
}

type DtsTypeValue

type DtsTypeValue struct {
	Value string `mapstructure:"value"`
}