config

Documentation

Overview

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Variables
• func GetRawVersionInfo() string
• func RecordAppVersion(app string, cfg *Config)
• type AllConfig
• type AppConfig
• type CSVConfig
• type CheckConfig
• type Config
  • func NewConfig() *Config
  • func (c *Config) AdjustConfig() error
  • func (c *Config) Parse(args []string) error
  • func (c *Config) String() string
• type DiffConfig
• type FullConfig
• type LogConfig
• type MetaConfig
• type MySQLConfig
• type OracleConfig
• type ReverseConfig
• type TableConfig

Variables

var (
	Version   = "None"
	BuildTS   = "None"
	GitHash   = "None"
	GitBranch = "None"
)

版本信息

Functions

func GetRawVersionInfo

func GetRawVersionInfo() string

func RecordAppVersion

func RecordAppVersion(app string, cfg *Config)

版本信息输出重定向到日志

Types

type AllConfig

type AllConfig struct {
	LogminerQueryTimeout int `toml:"logminer-query-timeout" json:"logminer-query-timeout"`
	FilterThreads        int `toml:"filter-threads" json:"filter-threads"`
	ApplyThreads         int `toml:"apply-threads" json:"apply-threads"`
	WorkerQueue          int `toml:"worker-queue" json:"worker-queue"`
	WorkerThreads        int `toml:"worker-threads" json:"worker-threads"`
}

type AppConfig

type AppConfig struct {
	InsertBatchSize  int    `toml:"insert-batch-size" json:"insert-batch-size"`
	SlowlogThreshold int    `toml:"slowlog-threshold" json:"slowlog-threshold"`
	PprofPort        string `toml:"pprof-port" json:"pprof-port"`
}

type CSVConfig

type CSVConfig struct {
	Header           bool   `toml:"header" json:"header"`
	Separator        string `toml:"separator" json:"separator"`
	Terminator       string `toml:"terminator" json:"terminator"`
	Charset          string `toml:"charset" json:"charset"`
	Delimiter        string `toml:"delimiter" json:"delimiter"`
	EscapeBackslash  bool   `toml:"escape-backslash" json:"escape-backslash"`
	Rows             int    `toml:"rows" json:"rows"`
	OutputDir        string `toml:"output-dir" json:"output-dir"`
	TaskThreads      int    `toml:"task-threads" json:"task-threads"`
	TableThreads     int    `toml:"table-threads" json:"table-threads"`
	SQLThreads       int    `toml:"sql-threads" json:"sql-threads"`
	EnableCheckpoint bool   `toml:"enable-checkpoint" json:"enable-checkpoint"`
	ConsistentRead   bool   `toml:"consistent-read" json:"consistent-read"`
}

type CheckConfig

type CheckConfig struct {
	CheckThreads int    `toml:"check-threads" json:"check-threads"`
	CheckSQLDir  string `toml:"check-sql-dir" json:"check-sql-dir"`
}

type Config

type Config struct {
	*flag.FlagSet `json:"-"`
	AppConfig     AppConfig     `toml:"app" json:"app"`
	ReverseConfig ReverseConfig `toml:"reverse" json:"reverse"`
	CheckConfig   CheckConfig   `toml:"check" json:"check"`
	FullConfig    FullConfig    `toml:"full" json:"full"`
	CSVConfig     CSVConfig     `toml:"csv" json:"csv"`
	AllConfig     AllConfig     `toml:"all" json:"all"`
	OracleConfig  OracleConfig  `toml:"oracle" json:"oracle"`
	MySQLConfig   MySQLConfig   `toml:"mysql" json:"mysql"`
	MetaConfig    MetaConfig    `toml:"meta" json:"meta"`
	LogConfig     LogConfig     `toml:"log" json:"log"`
	DiffConfig    DiffConfig    `toml:"compare" json:"compare"`
	ConfigFile    string        `json:"config-file"`
	PrintVersion  bool
	TaskMode      string `json:"task-mode"`
	DBTypeS       string `json:"db-type-s"`
	DBTypeT       string `json:"db-type-t"`
}

程序配置文件

func NewConfig

func NewConfig() *Config

func (*Config) AdjustConfig

func (c *Config) AdjustConfig() error

func (*Config) Parse

func (c *Config) Parse(args []string) error

func (*Config) String

func (c *Config) String() string

type DiffConfig

type DiffConfig struct {
	ChunkSize         int           `toml:"chunk-size" json:"chunk-size"`
	DiffThreads       int           `toml:"diff-threads" json:"diff-threads"`
	OnlyCheckRows     bool          `toml:"only-check-rows" json:"only-check-rows"`
	EnableCheckpoint  bool          `toml:"enable-checkpoint" json:"enable-checkpoint"`
	IgnoreStructCheck bool          `toml:"ignore-struct-check" json:"ignore-struct-check"`
	FixSqlDir         string        `toml:"fix-sql-dir" json:"fix-sql-dir"`
	TableConfig       []TableConfig `toml:"table-config" json:"table-config"`
}

type FullConfig

type FullConfig struct {
	ChunkSize        int  `toml:"chunk-size" json:"chunk-size"`
	TaskThreads      int  `toml:"task-threads" json:"task-threads"`
	TableThreads     int  `toml:"table-threads" json:"table-threads"`
	SQLThreads       int  `toml:"sql-threads" json:"sql-threads"`
	ApplyThreads     int  `toml:"apply-threads" json:"apply-threads"`
	EnableCheckpoint bool `toml:"enable-checkpoint" json:"enable-checkpoint"`
	ConsistentRead   bool `toml:"consistent-read" json:"consistent-read"`
}

type LogConfig

type LogConfig struct {
	LogLevel   string `toml:"log-level" json:"log-level"`
	LogFile    string `toml:"log-file" json:"log-file"`
	MaxSize    int    `toml:"max-size" json:"max-size"`
	MaxDays    int    `toml:"max-days" json:"max-days"`
	MaxBackups int    `toml:"max-backups" json:"max-backups"`
}

type MetaConfig

type MetaConfig struct {
	Username   string `toml:"username" json:"username"`
	Password   string `toml:"password" json:"password"`
	Host       string `toml:"host" json:"host"`
	Port       int    `toml:"port" json:"port"`
	MetaSchema string `toml:"meta-schema" json:"meta-schema"`
}

type MySQLConfig

type MySQLConfig struct {
	Username      string `toml:"username" json:"username"`
	Password      string `toml:"password" json:"password"`
	Host          string `toml:"host" json:"host"`
	Port          int    `toml:"port" json:"port"`
	Charset       string `toml:"charset" json:"charset"`
	ConnectParams string `toml:"connect-params" json:"connect-params"`
	SchemaName    string `toml:"schema-name" json:"schema-name"`
	TableOption   string `toml:"table-option" json:"table-option"`
	Overwrite     bool   `toml:"overwrite" json:"overwrite"`
}

type OracleConfig

type OracleConfig struct {
	Username      string   `toml:"username" json:"username"`
	Password      string   `toml:"password" json:"password"`
	Host          string   `toml:"host" json:"host"`
	Port          int      `toml:"port" json:"port"`
	ServiceName   string   `toml:"service-name" json:"service-name"`
	PDBName       string   `toml:"pdb-name" json:"pdb-name"`
	Charset       string   `toml:"charset" json:"charset"`
	LibDir        string   `toml:"lib-dir" json:"lib-dir"`
	ConnectParams string   `toml:"connect-params" json:"connect-params"`
	SessionParams []string `toml:"session-params" json:"session-params"`
	SchemaName    string   `toml:"schema-name" json:"schema-name"`
	IncludeTable  []string `toml:"include-table" json:"include-table"`
	ExcludeTable  []string `toml:"exclude-table" json:"exclude-table"`
}

type ReverseConfig

type ReverseConfig struct {
	ReverseThreads   int    `toml:"reverse-threads" json:"reverse-threads"`
	DirectWrite      bool   `toml:"direct-write" json:"direct-write"`
	DDLReverseDir    string `toml:"ddl-reverse-dir" json:"ddl-reverse-dir"`
	DDLCompatibleDir string `toml:"ddl-compatible-dir" json:"ddl-compatible-dir"`
}

type TableConfig

type TableConfig struct {
	SourceTable string `toml:"source-table" json:"source-table"`
	IndexFields string `toml:"index-fields" json:"index-fields"`
	Range       string `toml:"range" json:"range"`
}