config

Documentation

Index

• Constants
• func LogDefautConfig() string
• func SetDBConfig(dbc *DBConfig)
• func SetExecuteConfig(cfg *ExecuteConfig)
• func SetStartConfig(cfg *CreateConfig)
• type CreateConfig
  • func NewStartConfig() *CreateConfig
  • func (this *CreateConfig) Check() error
  • func (this *CreateConfig) EndInfoString() string
  • func (this *CreateConfig) EndPostInfoRatherThan(otherEndFile string, otherEndPos uint64) bool
  • func (this *CreateConfig) EndTimeRatherThan(otherEndTime string) (bool, error)
  • func (this *CreateConfig) GetSaveDir() string
  • func (this *CreateConfig) HaveEndPosInfo() bool
  • func (this *CreateConfig) HaveEndTime() bool
  • func (this *CreateConfig) HaveStartPosInfo() bool
  • func (this *CreateConfig) HaveStartTime() bool
  • func (this *CreateConfig) StartInfoString() string
  • func (this *CreateConfig) StartPosInfoLessThan(otherStartFile string, otherStartPos uint64) bool
  • func (this *CreateConfig) StartTimeLessThan(otherStartTime string) (bool, error)
• type DBConfig
  • func GetDBConfig() *DBConfig
  • func (this *DBConfig) Check() error
  • func (this *DBConfig) GetDataSource() string
  • func (this *DBConfig) GetPassword() string
  • func (this *DBConfig) GetSyncerConfig() replication.BinlogSyncerConfig
• type ExecuteConfig
  • func (this *ExecuteConfig) Check() error
• type OfflineConfig
  • func NewOffileConfig() *OfflineConfig
  • func (this *OfflineConfig) Check() error
  • func (this *OfflineConfig) GetSaveDir() string
• type OfflineStatConfig
  • func (this *OfflineStatConfig) Check() error
  • func (this *OfflineStatConfig) TableStatFilePath() string
  • func (this *OfflineStatConfig) ThreadStatFilePath() string
  • func (this *OfflineStatConfig) TimestampStatFilePath() string
  • func (this *OfflineStatConfig) TransactionStatFilePath() string

Constants

const (
	ENABLE_ROLLBACK_UPDATE = true
	ENABLE_ROLLBACK_INSERT = true
	ENABLE_ROLLBACK_DELETE = true
	SAVE_DIR               = "rollback_sqls"
)

const (
	DB_HOST                = "127.0.0.1"
	DB_PORT                = 3306
	DB_USERNAME            = "root"
	DB_PASSWORD            = "root"
	DB_SCHEMA              = ""
	DB_AUTO_COMMIT         = true
	DB_MAX_OPEN_CONNS      = 8
	DB_MAX_IDEL_CONNS      = 8
	DB_CHARSET             = "utf8mb4"
	DB_TIMEOUT             = 10
	DB_PASSWORD_IS_DECRYPT = true
	SQL_LOG_BIN            = true
)

const DefaultOfflineStatSaveDir = "offline_stat_output"

const (
	EXECUTE_PARALLER = 1
)

Functions

func LogDefautConfig

func LogDefautConfig() string

func SetDBConfig

func SetDBConfig(dbc *DBConfig)

设置 DBConfig

func SetExecuteConfig

func SetExecuteConfig(cfg *ExecuteConfig)

func SetStartConfig

func SetStartConfig(cfg *CreateConfig)

Types

type CreateConfig

type CreateConfig struct {
	StartLogFile         string
	StartLogPos          uint64
	EndLogFile           string
	EndLogPos            uint64
	StartTime            string
	EndTime              string
	RollbackSchemas      []string
	RollbackTables       []string
	ThreadID             uint32
	Now                  time.Time
	EnableRollbackUpdate bool
	EnableRollbackInsert bool
	EnableRollbackDelete bool
	SaveDir              string
	MatchSqls            []string // 使用sql语句来匹配需要查询的时间段或者
}

func NewStartConfig

func NewStartConfig() *CreateConfig

func (*CreateConfig) Check

func (this *CreateConfig) Check() error

func (*CreateConfig) EndInfoString

func (this *CreateConfig) EndInfoString() string

func (*CreateConfig) EndPostInfoRatherThan

func (this *CreateConfig) EndPostInfoRatherThan(otherEndFile string, otherEndPos uint64) bool

结束位点大于其他位点

func (*CreateConfig) EndTimeRatherThan

func (this *CreateConfig) EndTimeRatherThan(otherEndTime string) (bool, error)

结束时间大于其他位点

func (*CreateConfig) GetSaveDir

func (this *CreateConfig) GetSaveDir() string

设置最终的保存文件

func (*CreateConfig) HaveEndPosInfo

func (this *CreateConfig) HaveEndPosInfo() bool

是否所有结束位点信息

func (*CreateConfig) HaveEndTime

func (this *CreateConfig) HaveEndTime() bool

是否有结束时间

func (*CreateConfig) HaveStartPosInfo

func (this *CreateConfig) HaveStartPosInfo() bool

是否有开始位点信息

func (*CreateConfig) HaveStartTime

func (this *CreateConfig) HaveStartTime() bool

是否有开始事件

func (*CreateConfig) StartInfoString

func (this *CreateConfig) StartInfoString() string

func (*CreateConfig) StartPosInfoLessThan

func (this *CreateConfig) StartPosInfoLessThan(otherStartFile string, otherStartPos uint64) bool

开始位点小于其他位点

func (*CreateConfig) StartTimeLessThan

func (this *CreateConfig) StartTimeLessThan(otherStartTime string) (bool, error)

开始时间小于其他位点

type DBConfig

type DBConfig struct {
	Username          string
	Password          string
	Database          string
	CharSet           string
	Host              string
	Timeout           int
	Port              int
	MaxOpenConns      int
	MaxIdelConns      int
	AllowOldPasswords int
	AutoCommit        bool
	PasswordIsDecrypt bool
	SqlLogBin         bool
}

func GetDBConfig

func GetDBConfig() *DBConfig

func (*DBConfig) Check

func (this *DBConfig) Check() error

func (*DBConfig) GetDataSource

func (this *DBConfig) GetDataSource() string

func (*DBConfig) GetPassword

func (this *DBConfig) GetPassword() string

获取密码, 有判断是否需要进行解密

func (*DBConfig) GetSyncerConfig

func (this *DBConfig) GetSyncerConfig() replication.BinlogSyncerConfig

type ExecuteConfig

type ExecuteConfig struct {
	FilePath string
	Paraller int64
}

func (*ExecuteConfig) Check

func (this *ExecuteConfig) Check() error

type OfflineConfig

type OfflineConfig struct {
	BinlogFiles          []string
	ThreadID             uint32
	Now                  time.Time
	EnableRollbackUpdate bool
	EnableRollbackInsert bool
	EnableRollbackDelete bool
	SaveDir              string
	SchemaFile           string   // 建表语句
	MatchSqls            []string // 使用sql语句来匹配需要查询的时间段或者
}

func NewOffileConfig

func NewOffileConfig() *OfflineConfig

func (*OfflineConfig) Check

func (this *OfflineConfig) Check() error

func (*OfflineConfig) GetSaveDir

func (this *OfflineConfig) GetSaveDir() string

设置最终的保存文件

type OfflineStatConfig

type OfflineStatConfig struct {
	SaveDir     string
	BinlogFiles []string
}

func (*OfflineStatConfig) Check

func (this *OfflineStatConfig) Check() error

func (*OfflineStatConfig) TableStatFilePath

func (this *OfflineStatConfig) TableStatFilePath() string

func (*OfflineStatConfig) ThreadStatFilePath

func (this *OfflineStatConfig) ThreadStatFilePath() string

func (*OfflineStatConfig) TimestampStatFilePath

func (this *OfflineStatConfig) TimestampStatFilePath() string

func (*OfflineStatConfig) TransactionStatFilePath

func (this *OfflineStatConfig) TransactionStatFilePath() string