update: 支持当开启ssl时的binlog解析

hanchuanchuan · Dec 18, 2020 · 2373c1b · 2373c1b
1 parent a4b1e20
commit 2373c1b
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/session/parser.go b/session/parser.go
@@ -2,6 +2,7 @@ package session
 
 import (
 	"context"
+	"crypto/tls"
 	"database/sql/driver"
 	"encoding/hex"
 	"fmt"
@@ -234,6 +235,13 @@ func (s *session) parserBinlog(ctx context.Context) {
 		// SemiSyncEnabled: p.cfg.SemiSync,
 	}
 
+	if s.opt.ssl != "" {
+		switch s.opt.ssl {
+		case "preferred", "true", "required":
+			cfg.TLSConfig = &tls.Config{InsecureSkipVerify: true}
+		}
+	}
+
 	b := replication.NewBinlogSyncer(cfg)
 	defer b.Close()