Documentation
¶
Index ¶
- Constants
- Variables
- func GetExtractName() string
- func GetMySQLName() string
- func GetOracleName() string
- func GetReplicationName() string
- func MatchSchemaTable(owner, table, val *string, log *logrus.Logger) bool
- func ValToUper(v string) string
- type ClientCharacterSet
- type ClientCollation
- type DBOptions
- type DBOptionsJson
- type DBOptionsSet
- type DdlJson
- type DdlList
- type DdlSmt
- type DdlSmtSet
- type DiscardFile
- type DiscardFileSet
- type DiscardJson
- type ETL
- type Encoding
- type ExcludeTableSet
- type ExcludeTableSets
- type Module
- type ObjectNode
- type OdbInfo
- func (u *OdbInfo) GetClientCharacter() string
- func (u *OdbInfo) GetConnInfo() *OdbInfo
- func (u *OdbInfo) GetHostAddress() []string
- func (u *OdbInfo) GetPassWord() string
- func (u *OdbInfo) GetPort() uint16
- func (u *OdbInfo) GetRetryMaxConnNumber() int
- func (u *OdbInfo) GetSID() string
- func (u *OdbInfo) GetTimeZone() string
- func (u *OdbInfo) GetUserName() string
- type Options
- type OptsList
- type Parameter
- type Parameters
- type PassWordModel
- type PortModel
- type Process
- type ProcessInfo
- type ProcessJson
- type RetryMaxConnect
- type ServerIdModel
- type SourceDB
- type SourceDBJson
- type Spfile
- func (s *Spfile) DDLFilter(owner, table, optype, objtype string) bool
- func (s *Spfile) DMLExcludeFilter(owner, table *string) (bool, error)
- func (s *Spfile) DMLFilter(owner, table *string) (bool, error)
- func (s *Spfile) DMLInlucdeFilter(owner, table *string) (bool, error)
- func (s *Spfile) GetMySQLDBConnStr() *dbInfo
- func (s *Spfile) GetOracleDBConnStr() *OdbInfo
- func (s *Spfile) GetProcessName() *string
- func (s *Spfile) GetTrail() *TrailAttribute
- func (s *Spfile) LoadToDatabase() error
- func (s *Spfile) Production() error
- func (s *Spfile) PutParamsText()
- type TableExcludeJson
- type TableExcludeList
- type TableJson
- type TableList
- type TableSet
- type TableSets
- type TimeZone
- type TrailAttribute
- func (t *TrailAttribute) GetDir() *string
- func (t *TrailAttribute) GetKeepKey() *string
- func (t *TrailAttribute) GetKeepUnit() *string
- func (t *TrailAttribute) GetKeepVal() *int
- func (t *TrailAttribute) GetSizeKey() *string
- func (t *TrailAttribute) GetSizeUnit() *string
- func (t *TrailAttribute) GetSizeValue() *int
- func (t *TrailAttribute) GetTrail() *TrailAttribute
- type TrailDir
- type TrailDirJson
- type TypeModel
- type UserIDJson
- type UserId
- type UserIdClientCharacterSet
- type UserIdIpSet
- type UserIdModel
- type UserIdPassWordModel
- type UserIdPortModel
- type UserIdRetryMaxConnect
- type UserIdServerIdModel
- type UserIdSidModel
- type UserIdTimeZone
- type UserIdUserIdModel
Constants ¶
View Source
const ( IpV4Reg = "^((0|[1-9]\\d?|1\\d\\d|2[0-4]\\d|25[0-5])\\.){3}(0|[1-9]\\d?|1\\d\\d|2[0-4]\\d|25[0-5])$" IpV4Port = "^([0-9]{1,4}|[1-5][0-9]{4}|6[0-4][0-9]{3}|65[0-4][0-9]{2}|655[0-2][0-9]|6553[0-5])$" )
View Source
const (
AnnotationPrefix = "--"
)
Variables ¶
View Source
var ProcessBus processSet
Functions ¶
func GetExtractName ¶
func GetExtractName() string
func GetMySQLName ¶
func GetMySQLName() string
func GetOracleName ¶
func GetOracleName() string
func GetReplicationName ¶
func GetReplicationName() string
Types ¶
type ClientCharacterSet ¶
type ClientCharacterSet struct {
// contains filtered or unexported fields
}
type ClientCollation ¶
type ClientCollation struct {
// contains filtered or unexported fields
}
type DBOptions ¶
type DBOptions struct {
OptionsSet *Options
// contains filtered or unexported fields
}
type DBOptionsJson ¶
type DBOptionsSet ¶
type DBOptionsSet struct {
// contains filtered or unexported fields
}
var DBOptionsBus DBOptionsSet
func (*DBOptionsSet) Add ¶
func (d *DBOptionsSet) Add(raw *string) error
func (*DBOptionsSet) GetParam ¶
func (d *DBOptionsSet) GetParam() interface{}
func (*DBOptionsSet) Init ¶
func (d *DBOptionsSet) Init()
func (*DBOptionsSet) ListParamText ¶
func (d *DBOptionsSet) ListParamText() string
func (*DBOptionsSet) MarshalJson ¶
func (d *DBOptionsSet) MarshalJson() ([]byte, error)
func (*DBOptionsSet) Registry ¶
func (d *DBOptionsSet) Registry() map[string]Parameter
type DdlJson ¶
type DdlJson struct {
Type *string `json:"PARAMS_TYPE"`
Range *string `json:"TYPE"`
Owner *string `json:"OWNER"`
Table *string `json:"TABLE"`
OpType []string `json:"OPTYPE"`
ObjType []string `json:"OBJTYPE"`
}
序列化DDL
type DdlSmtSet ¶
type DdlSmtSet struct {
// contains filtered or unexported fields
}
var DdlSmtSetBus DdlSmtSet
func (*DdlSmtSet) ListParamText ¶
func (*DdlSmtSet) MarshalJson ¶
type DiscardFile ¶
type DiscardFile struct {
Dir *string
// contains filtered or unexported fields
}
type DiscardFileSet ¶
type DiscardFileSet struct {
// contains filtered or unexported fields
}
var DiscardFileBus DiscardFileSet
func (*DiscardFileSet) Add ¶
func (d *DiscardFileSet) Add(raw *string) error
func (*DiscardFileSet) GetParam ¶
func (d *DiscardFileSet) GetParam() interface{}
func (*DiscardFileSet) Init ¶
func (d *DiscardFileSet) Init()
func (*DiscardFileSet) ListParamText ¶
func (d *DiscardFileSet) ListParamText() string
func (*DiscardFileSet) MarshalJson ¶
func (d *DiscardFileSet) MarshalJson() ([]byte, error)
func (*DiscardFileSet) Registry ¶
func (d *DiscardFileSet) Registry() map[string]Parameter
type DiscardJson ¶
type ExcludeTableSet ¶
type ExcludeTableSet struct {
// contains filtered or unexported fields
}
var ExcludeTableSetBus ExcludeTableSet
func (*ExcludeTableSet) Add ¶
func (e *ExcludeTableSet) Add(raw *string) error
func (*ExcludeTableSet) GetParam ¶
func (e *ExcludeTableSet) GetParam() interface{}
func (*ExcludeTableSet) Init ¶
func (e *ExcludeTableSet) Init()
func (*ExcludeTableSet) ListParamText ¶
func (e *ExcludeTableSet) ListParamText() string
func (*ExcludeTableSet) MarshalJson ¶
func (e *ExcludeTableSet) MarshalJson() ([]byte, error)
func (*ExcludeTableSet) Registry ¶
func (e *ExcludeTableSet) Registry() map[string]Parameter
type ExcludeTableSets ¶
type ExcludeTableSets struct {
TableBus *TableExcludeList
// contains filtered or unexported fields
}
type ObjectNode ¶
type ObjectNode struct {
// contains filtered or unexported fields
}
type OdbInfo ¶
type OdbInfo struct {
// contains filtered or unexported fields
}
func (*OdbInfo) GetClientCharacter ¶
func (*OdbInfo) GetConnInfo ¶
func (*OdbInfo) GetHostAddress ¶
func (*OdbInfo) GetPassWord ¶
func (*OdbInfo) GetRetryMaxConnNumber ¶
func (*OdbInfo) GetTimeZone ¶
func (*OdbInfo) GetUserName ¶
type Options ¶
type Options struct {
// contains filtered or unexported fields
}
func (*Options) GetIgnoreForeignkey ¶
func (*Options) GetReplicates ¶
func (*Options) GetSuppressionTrigger ¶
type Parameters ¶
type PassWordModel ¶
type PassWordModel struct {
// contains filtered or unexported fields
}
type Process ¶
type Process struct {
ProInfo *ProcessInfo
// contains filtered or unexported fields
}
type ProcessInfo ¶
type ProcessInfo struct {
Name *string
}
func (*ProcessInfo) GetName ¶
func (p *ProcessInfo) GetName() *string
type ProcessJson ¶
序列化进程名称
type RetryMaxConnect ¶
type RetryMaxConnect struct {
// contains filtered or unexported fields
}
type ServerIdModel ¶
type ServerIdModel struct {
// contains filtered or unexported fields
}
type SourceDBJson ¶
type SourceDBJson struct {
Type *string `json:"PARAMS_TYPE"`
Address *string `json:"ADDRESS"` // 数据库地址
Port *uint16 `json:"PORT"` // 数据库端口
Types *string `json:"DATABASETYPE"` // 连接数据库类型, mysql或 mariadb
UserId *string `json:"USERID"` // 用户名
PassWord *string `json:"PASSWORD"` // 密码
ServerId *uint32 `json:"SERVERID"` // mysql server id
RetryMaxConnNumber *int `json:"RETRYMAXCONNNUMBER"` // 连接重连最大次数
ClientCharacter *string `json:"CLIENTCHARACTER"` // 客户端字符集
ClientCollation *string `json:"CLIENTCOLLATION"` // 客户端字符集
}
type Spfile ¶
type Spfile struct {
// contains filtered or unexported fields
}
func LoadSpfile ¶
func (*Spfile) DMLExcludeFilter ¶
DML MAP Exclude 过滤
func (*Spfile) DMLInlucdeFilter ¶
DML MAP INCLUDE 过滤
func (*Spfile) LoadToDatabase ¶
type TableExcludeJson ¶
type TableExcludeList ¶
type TableExcludeList struct {
// contains filtered or unexported fields
}
type TableJson ¶
type TableJson struct {
Type *string `json:"PARAMS_TYPE"`
Owner string `json:"OWNER"`
Table string `json:"TABLE"`
}
序列化进程名称
type TableSet ¶
type TableSet struct {
// contains filtered or unexported fields
}
var TableSetBus TableSet
func (*TableSet) ListParamText ¶
func (*TableSet) MarshalJson ¶
type TableSets ¶
type TableSets struct {
TableBus *TableList
// contains filtered or unexported fields
}
type TrailAttribute ¶
type TrailAttribute struct {
SizeValue *int
SizeUnit *string
// contains filtered or unexported fields
}
func (*TrailAttribute) GetDir ¶
func (t *TrailAttribute) GetDir() *string
func (*TrailAttribute) GetKeepKey ¶
func (t *TrailAttribute) GetKeepKey() *string
func (*TrailAttribute) GetKeepUnit ¶
func (t *TrailAttribute) GetKeepUnit() *string
func (*TrailAttribute) GetKeepVal ¶
func (t *TrailAttribute) GetKeepVal() *int
func (*TrailAttribute) GetSizeKey ¶
func (t *TrailAttribute) GetSizeKey() *string
func (*TrailAttribute) GetSizeUnit ¶
func (t *TrailAttribute) GetSizeUnit() *string
func (*TrailAttribute) GetSizeValue ¶
func (t *TrailAttribute) GetSizeValue() *int
func (*TrailAttribute) GetTrail ¶
func (t *TrailAttribute) GetTrail() *TrailAttribute
type TrailDir ¶
type TrailDir struct {
DirTrailAttribute *TrailAttribute
// contains filtered or unexported fields
}
type TrailDirJson ¶
type UserIDJson ¶
type UserIDJson struct {
Type *string `json:"PARAMS_TYPE"`
Address []string `json:"ADDRESS"` // 数据库地址
Port *uint16 `json:"PORT"` // 数据库端口
UserName *string `json:"USERNAME"` // 用户名
Sid *string `json:"SID"` // instance id
PassWord *string `json:"PASSWORD"` // 密码
RetryMaxConnNumber *int `json:"RETRYMAXCONNNUMBER"` // 连接重连最大次数
ClientCharacter *string `json:"CLIENTCHARACTER"` // 客户端字符集
TimeZone *string `json:"TIMEZONE"` // 时区
}
type UserIdClientCharacterSet ¶
type UserIdClientCharacterSet struct {
// contains filtered or unexported fields
}
type UserIdIpSet ¶
type UserIdIpSet struct {
// contains filtered or unexported fields
}
func (*UserIdIpSet) SetIpAddress ¶
func (u *UserIdIpSet) SetIpAddress(ip *string) error
type UserIdModel ¶
type UserIdModel struct {
// contains filtered or unexported fields
}
type UserIdPassWordModel ¶
type UserIdPassWordModel struct {
// contains filtered or unexported fields
}
type UserIdPortModel ¶
type UserIdPortModel struct {
// contains filtered or unexported fields
}
type UserIdRetryMaxConnect ¶
type UserIdRetryMaxConnect struct {
// contains filtered or unexported fields
}
type UserIdServerIdModel ¶
type UserIdServerIdModel struct {
// contains filtered or unexported fields
}
type UserIdSidModel ¶
type UserIdSidModel struct {
// contains filtered or unexported fields
}
type UserIdTimeZone ¶
type UserIdTimeZone struct {
// contains filtered or unexported fields
}
type UserIdUserIdModel ¶
type UserIdUserIdModel struct {
// contains filtered or unexported fields
}
func (*UserIdUserIdModel) SetUserId ¶
func (u *UserIdUserIdModel) SetUserId(uid *string)
Click to show internal directories.
Click to hide internal directories.