From a7b20104ca5640a6ba489363b5383b763423a5ba Mon Sep 17 00:00:00 2001
From: "aleksandr.shibanov" <aleksandr.shibanov@corp.mail.ru>
Date: Mon, 3 Apr 2023 16:36:04 +0300
Subject: [PATCH] canal: use localhost option

---
 canal/canal.go  | 1 +
 canal/config.go | 3 +++
 2 files changed, 4 insertions(+)

diff --git a/canal/canal.go b/canal/canal.go
index 5980fcecf..6c07bb741 100644
--- 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
index 3c11ccdb8..29c58f66b 100644
--- 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) {