|
@@ -50,7 +50,7 @@ var (
|
|
|
// 初始化加载
|
|
// 初始化加载
|
|
|
func init() {
|
|
func init() {
|
|
|
flag.StringVar(&lastid, "id", "", "增量加载的lastid") //增量
|
|
flag.StringVar(&lastid, "id", "", "增量加载的lastid") //增量
|
|
|
- flag.StringVar(>id, "gtid", "", "历史增量的起始id") //历史
|
|
|
|
|
|
|
+ flag.StringVar(>id, "gtid", "", "历史增量的起始id") //历史
|
|
|
flag.StringVar(&sec_gtid, "sec_gtid", "", "全量分段起始id")
|
|
flag.StringVar(&sec_gtid, "sec_gtid", "", "全量分段起始id")
|
|
|
flag.StringVar(&sec_lteid, "sec_lteid", "", "全量分段结束id")
|
|
flag.StringVar(&sec_lteid, "sec_lteid", "", "全量分段结束id")
|
|
|
flag.Parse()
|
|
flag.Parse()
|
|
@@ -82,6 +82,7 @@ func lastUdpJob() {
|
|
|
|
|
|
|
|
// 主函数
|
|
// 主函数
|
|
|
func main() {
|
|
func main() {
|
|
|
|
|
+
|
|
|
go checkMailJob()
|
|
go checkMailJob()
|
|
|
lastNodeResponse = time.Now().Unix()
|
|
lastNodeResponse = time.Now().Unix()
|
|
|
updport := Sysconfig["udpport"].(string)
|
|
updport := Sysconfig["udpport"].(string)
|
zhengkun