fix some linter warning (#326)

Author: killua525

pkg/inputs/mysqlbatch/input.go

@@ -38,7 +38,7 @@ type PluginConfig struct {
 	Source      *config.DBConfig `mapstructure:"source" toml:"source" json:"source"` // keep same with mysql binlog config to make most cases simple
 	SourceSlave *config.DBConfig `mapstructure:"source-slave" toml:"source-slave" json:"source-slave"`
 
-	SourceProbeCfg *helper.SourceProbeCfg `mapstructure:"source-probe-config"json:"source-probe-config"`
+	SourceProbeCfg *helper.SourceProbeCfg `mapstructure:"source-probe-config" json:"source-probe-config"`
 
 	PositionRepo *config.GenericPluginConfig `mapstructure:"position-repo" toml:"position-repo" json:"position-repo"`
 

pkg/inputs/mysqlstream/binlog_tailer.go

@@ -463,7 +463,7 @@ func (tailer *BinlogTailer) Start() error {
 						continue
 					}
 
-					log.Infof("QueryEvent: database: %s, sql: %s, position: %s", dbName, ddlSQL, currentPosition)
+					log.Infof("QueryEvent: database: %s, sql: %s, position: %v", dbName, ddlSQL, currentPosition)
 
 					if tailer.binlogEventSchemaFilter != nil {
 						if !tailer.binlogEventSchemaFilter(dbName) {

pkg/inputs/mysqlstream/input.go

@@ -40,7 +40,7 @@ type MySQLBinlogInputPluginConfig struct {
 	IgnoreBiDirectionalData bool                        `mapstructure:"ignore-bidirectional-data" toml:"ignore-bidirectional-data" json:"ignore-bidirectional-data"`
 	StartPosition           *config.MySQLBinlogPosition `mapstructure:"start-position" toml:"start-position" json:"start-position"`
 
-	SourceProbeCfg *helper.SourceProbeCfg `mapstructure:"source-probe-config"json:"source-probe-config"`
+	SourceProbeCfg *helper.SourceProbeCfg `mapstructure:"source-probe-config" json:"source-probe-config"`
 
 	PositionRepo *config.GenericPluginConfig `mapstructure:"position-repo" toml:"position-repo" json:"position-repo"`
 
@@ -53,9 +53,9 @@ type MySQLBinlogInputPluginConfig struct {
 	//
 	// internal configurations that is not exposed to users
 	//
-	DisableBinlogChecker bool   `mapstructure:"-"json:"-"`
-	DebugBinlog          bool   `mapstructure:"-"json:"-"`
-	BinlogSyncerTimeout  string `mapstructure:"-"json:"-"`
+	DisableBinlogChecker bool   `mapstructure:"-" json:"-"`
+	DebugBinlog          bool   `mapstructure:"-" json:"-"`
+	BinlogSyncerTimeout  string `mapstructure:"-" json:"-"`
 }
 
 type mysqlStreamInputPlugin struct {

pkg/schedulers/batch_table_scheduler/batch_table_scheduler.go

@@ -74,10 +74,10 @@ var (
 const BatchTableSchedulerName = "batch-table-scheduler"
 
 type BatchSchedulerConfig struct {
-	NrWorker          int           `mapstructure:"nr-worker"json:"nr-worker"`
-	MaxBatchPerWorker int           `mapstructure:"batch-size"json:"batch-size"`
-	QueueSize         int           `mapstructure:"queue-size"json:"queue-size"`
-	SlidingWindowSize int           `mapstructure:"sliding-window-size"json:"sliding-window-size"`
+	NrWorker          int           `mapstructure:"nr-worker" json:"nr-worker"`
+	MaxBatchPerWorker int           `mapstructure:"batch-size" json:"batch-size"`
+	QueueSize         int           `mapstructure:"queue-size" json:"queue-size"`
+	SlidingWindowSize int           `mapstructure:"sliding-window-size" json:"sliding-window-size"`
 	NrRetries         int           `mapstructure:"nr-retries" json:"nr-retries"`
 	RetrySleepString  string        `mapstructure:"retry-sleep" json:"retry-sleep"`
 	HealthyThreshold  int           `mapstructure:"healthy-threshold" json:"healthy-threshold"`