Merge pull request #777 from AleksandrShibanov/canal-use-localhost-option

lance6716 · web-flow · commit e5de23b8bd47 · 2023-04-06T10:28:21.000+08:00
canal: use localhost option
diff --git a/canal/canal.go b/canal/canal.go
@@ -450,6 +450,7 @@ func (c *Canal) prepareSyncer() error {
 		TLSConfig:               c.cfg.TLSConfig,
 		Logger:                  c.cfg.Logger,
 		Dialer:                  c.cfg.Dialer,
+		Localhost:               c.cfg.Localhost,
 	}
 
 	if strings.Contains(c.cfg.Addr, "/") {
diff --git a/canal/config.go b/canal/config.go
@@ -96,6 +96,9 @@ type Config struct {
 
 	//Set Dialer
 	Dialer client.Dialer
+
+	//Set Localhost
+	Localhost string
 }
 
 func NewConfigWithFile(name string) (*Config, error) {

Original file line number	Diff line number	Diff line change
`@@ -450,6 +450,7 @@ func (c *Canal) prepareSyncer() error {`
`450`	`450`	`TLSConfig: c.cfg.TLSConfig,`
`451`	`451`	`Logger: c.cfg.Logger,`
`452`	`452`	`Dialer: c.cfg.Dialer,`
	`453`	`+ Localhost: c.cfg.Localhost,`
`453`	`454`	`}`
`454`	`455`
`455`	`456`	`if strings.Contains(c.cfg.Addr, "/") {`
Original file line number	Diff line number	Diff line change
`@@ -96,6 +96,9 @@ type Config struct {`
`96`	`96`
`97`	`97`	`//Set Dialer`
`98`	`98`	`Dialer client.Dialer`
	`99`	`+`
	`100`	`+ //Set Localhost`
	`101`	`+ Localhost string`
`99`	`102`	`}`
`100`	`103`
`101`	`104`	`func NewConfigWithFile(name string) (*Config, error) {`