aliyun

Documentation

Index

• Constants
• type AliDts
  • func New() (*AliDts, error)
  • func (ad *AliDts) Parse(data []byte) (*DtsRecord, error)
• type AliOss
  • func NewAliOss(domain, endpoint, accessKey, accessSecret string) *AliOss
  • func (a *AliOss) GenSignature(dir string) (*OssSignature, error)
  • func (a *AliOss) Upload(bucket, dir, fileName string, data []byte) (string, 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
• type OssPolicyConfig
• type OssSignature

Constants

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

const DefaultExpireTime = 600

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 AliOss

type AliOss struct {
	AccessKey    string
	AccessSecret string
	Domain       string
	Endpoint     string
}

func NewAliOss

func NewAliOss(domain, endpoint, accessKey, accessSecret string) *AliOss

func (*AliOss) GenSignature

func (a *AliOss) GenSignature(dir string) (*OssSignature, error)

GenSignature 生成oss直传token

func (*AliOss) Upload

func (a *AliOss) Upload(bucket, dir, fileName string, data []byte) (string, error)

Upload file

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"`
}

type OssPolicyConfig

type OssPolicyConfig struct {
	Expiration string     `json:"expiration"`
	Conditions [][]string `json:"conditions"`
}

type OssSignature

type OssSignature struct {
	AccessKeyId string
	Host        string
	Expire      int64
	Signature   string
	Directory   string
	Policy      string
}