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 CompareConfig
• 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 MigrateConfig
• type MySQLConfig
• type OracleConfig
• type ReverseConfig
• type SchemaConfig
• type StructClusteredConfig
• type StructNonClusteredConfig

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"`
	NullValue        string `toml:"null-value" json:"null-value"`
	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"`
	SQLHint          string `toml:"sql-hint" json:"sql-hint"`
	CallTimeout      int    `toml:"call-timeout" json:"call-timeout"`
}

type CheckConfig

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

type CompareConfig

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

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"`
	SchemaConfig  SchemaConfig  `toml:"schema-config" json:"schema-config"`
	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"`
}

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"`
	SQLHint          string `toml:"sql-hint" json:"sql-hint"`
	CallTimeout      int    `toml:"call-timeout" json:"call-timeout"`
}

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 MigrateConfig

type MigrateConfig struct {
	SourceTable string `toml:"source-table" json:"source-table"`
	EnableSplit bool   `toml:"enable-split" json:"enable-split"`
	Range       string `toml:"range" json:"range"`
	SQLHint     string `toml:"sql-hint" json:"sql-hint"`
}

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

type ReverseConfig

type ReverseConfig struct {
	LowerCaseFieldName string `toml:"lower-case-field-name" json:"lower-case-field-name"`
	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 SchemaConfig

type SchemaConfig struct {
	SourceSchema             string                     `toml:"source-schema" json:"source-schema"`
	SourceIncludeTable       []string                   `toml:"source-include-table" json:"source-include-table"`
	SourceExcludeTable       []string                   `toml:"source-exclude-table" json:"source-exclude-table"`
	TargetSchema             string                     `toml:"target-schema" json:"target-schema"`
	GlobalTableOption        string                     `toml:"global-table-option" json:"global-table-option"`
	CompareConfig            []CompareConfig            `toml:"compare-config" json:"compare-config"`
	MigrateConfig            []MigrateConfig            `toml:"migrate-config" json:"migrate-config"`
	StructNonClusteredConfig []StructNonClusteredConfig `toml:"struct-nonclustered-config" json:"struct-nonclustered-config"`
	StructClusteredConfig    StructClusteredConfig      `toml:"struct-clustered-config" json:"struct-clustered-config"`
}

type StructClusteredConfig

type StructClusteredConfig struct {
	SourceTable []string `toml:"source-table" json:"source-table"`
}

type StructNonClusteredConfig

type StructNonClusteredConfig struct {
	SourceTable             []string `toml:"source-table" json:"source-table"`
	NonClusteredTableOption string   `toml:"nonclustered-table-option" json:"nonclustered-table-option"`
}