Versions in this module Expand all Collapse all v1 v1.0.37 Aug 12, 2023 Changes in this version + const ALIYUN_DTS_SCHEMA + const DefaultExpireTime + const MYSQL_TYPE_BIT + const MYSQL_TYPE_DATE + const MYSQL_TYPE_DATETIME + const MYSQL_TYPE_DATE_NEW + const MYSQL_TYPE_DECIMAL + const MYSQL_TYPE_DOUBLE + const MYSQL_TYPE_FLOAT + const MYSQL_TYPE_INT16 + const MYSQL_TYPE_INT24 + const MYSQL_TYPE_INT32 + const MYSQL_TYPE_INT64 + const MYSQL_TYPE_INT8 + const MYSQL_TYPE_NULL + const MYSQL_TYPE_TIME + const MYSQL_TYPE_TIMESTAMP + const MYSQL_TYPE_TIMESTAMP_NEW + const MYSQL_TYPE_VARCHAR + const MYSQL_TYPE_YEAR + type AliDts struct + func New() (*AliDts, error) + func (ad *AliDts) Parse(data []byte) (*DtsRecord, error) + type AliOss struct + AccessKey string + AccessSecret string + Domain string + Endpoint string + 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 struct + DataType int + Name string + type DtsFields struct + Items []*DtsField + type DtsRecord struct + AfterImages map[string]interface{} + BeforeImages map[string]interface{} + Database string + Fields map[string]interface{} + Id int64 + ObjectName map[string]string + Operation string + SourceTimeStamp int64 + SourceTxId string + Table string + TableFields []*DtsField + Version int + func (r *DtsRecord) GetAfterColumns() map[string]string + func (r *DtsRecord) GetBeforeColumns() map[string]string + type DtsTypeBytes struct + Value []byte + type DtsTypeDateTime struct + Day map[string]interface{} + Hour map[string]interface{} + Minute map[string]interface{} + Month map[string]interface{} + Second map[string]interface{} + Year map[string]interface{} + type DtsTypeTimestamp struct + Timestamp int64 + type DtsTypeTimestampWithTimeZone struct + Value DtsTypeDateTime + type DtsTypeValue struct + Value string + type OssPolicyConfig struct + Conditions [][]string + Expiration string + type OssSignature struct + AccessKeyId string + Directory string + Expire int64 + Host string + Policy string + Signature string
Go to main page