Add MaxReconnectAttempts to canal config (go-mysql-org#360)

Author: luk3thomas

canal/canal.go

@@ -400,16 +400,17 @@ func (c *Canal) checkBinlogRowFormat() error {
 
 func (c *Canal) prepareSyncer() error {
 	cfg := replication.BinlogSyncerConfig{
-		ServerID:        c.cfg.ServerID,
-		Flavor:          c.cfg.Flavor,
-		User:            c.cfg.User,
-		Password:        c.cfg.Password,
-		Charset:         c.cfg.Charset,
-		HeartbeatPeriod: c.cfg.HeartbeatPeriod,
-		ReadTimeout:     c.cfg.ReadTimeout,
-		UseDecimal:      c.cfg.UseDecimal,
-		ParseTime:       c.cfg.ParseTime,
-		SemiSyncEnabled: c.cfg.SemiSyncEnabled,
+		ServerID:             c.cfg.ServerID,
+		Flavor:               c.cfg.Flavor,
+		User:                 c.cfg.User,
+		Password:             c.cfg.Password,
+		Charset:              c.cfg.Charset,
+		HeartbeatPeriod:      c.cfg.HeartbeatPeriod,
+		ReadTimeout:          c.cfg.ReadTimeout,
+		UseDecimal:           c.cfg.UseDecimal,
+		ParseTime:            c.cfg.ParseTime,
+		SemiSyncEnabled:      c.cfg.SemiSyncEnabled,
+		MaxReconnectAttempts: c.cfg.MaxReconnectAttempts,
 	}
 
 	if strings.Contains(c.cfg.Addr, "/") {

canal/config.go

@@ -70,6 +70,10 @@ type Config struct {
 
 	// SemiSyncEnabled enables semi-sync or not.
 	SemiSyncEnabled bool `toml:"semi_sync_enabled"`
+
+	// Set to change the maximum number of attempts to re-establish a broken
+	// connection
+	MaxReconnectAttempts int `toml:"max_reconnect_attempts"`
 }
 
 func NewConfigWithFile(name string) (*Config, error) {