diff --git a/.gitignore b/.gitignore index c5e82d74..7acb1baf 100644 --- a/.gitignore +++ b/.gitignore @@ -1 +1,3 @@ -bin \ No newline at end of file +./bin +vendor +.idea \ No newline at end of file diff --git a/cmd/go-mysql-elasticsearch/main.go b/cmd/go-mysql-elasticsearch/main.go index af035075..8ad5d978 100644 --- a/cmd/go-mysql-elasticsearch/main.go +++ b/cmd/go-mysql-elasticsearch/main.go @@ -13,12 +13,12 @@ import ( ) var configFile = flag.String("config", "./etc/river.toml", "go-mysql-elasticsearch config file") -var my_addr = flag.String("my_addr", "", "MySQL addr") -var my_user = flag.String("my_user", "", "MySQL user") -var my_pass = flag.String("my_pass", "", "MySQL password") -var es_addr = flag.String("es_addr", "", "Elasticsearch addr") -var data_dir = flag.String("data_dir", "", "path for go-mysql-elasticsearch to save data") -var server_id = flag.Int("server_id", 0, "MySQL server id, as a pseudo slave") +var myAddr = flag.String("my_addr", "", "MySQL addr") +var myUser = flag.String("my_user", "", "MySQL user") +var myPass = flag.String("my_pass", "", "MySQL password") +var esAddr = flag.String("es_addr", "", "Elasticsearch addr") +var dataDir = flag.String("data_dir", "", "path for go-mysql-elasticsearch to save data") +var serverID = flag.Int("server_id", 0, "MySQL server id, as a pseudo slave") var flavor = flag.String("flavor", "", "flavor: mysql or mariadb") var execution = flag.String("exec", "", "mysqldump execution path") var logLevel = flag.String("log_level", "info", "log level") @@ -44,28 +44,28 @@ func main() { return } - if len(*my_addr) > 0 { - cfg.MyAddr = *my_addr + if len(*myAddr) > 0 { + cfg.MyAddr = *myAddr } - if len(*my_user) > 0 { - cfg.MyUser = *my_user + if len(*myUser) > 0 { + cfg.MyUser = *myUser } - if len(*my_pass) > 0 { - cfg.MyPassword = *my_pass + if len(*myPass) > 0 { + cfg.MyPassword = *myPass } - if *server_id > 0 { - cfg.ServerID = uint32(*server_id) + if *serverID > 0 { + cfg.ServerID = uint32(*serverID) } - if len(*es_addr) > 0 { - cfg.ESAddr = *es_addr + if len(*esAddr) > 0 { + cfg.ESAddr = *esAddr } - if len(*data_dir) > 0 { - cfg.DataDir = *data_dir + if len(*dataDir) > 0 { + cfg.DataDir = *dataDir } if len(*flavor) > 0 {