From c93ac44eb0fa05b9abc9bd30b38d4f2302b7d91e Mon Sep 17 00:00:00 2001 From: Francesco Casula Date: Mon, 20 Feb 2023 16:54:27 +0100 Subject: [PATCH] chore: adding timeout to ssh config --- services/streammanager/kafka/client/client.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/services/streammanager/kafka/client/client.go b/services/streammanager/kafka/client/client.go index d2b77fc33ea..5b9c6286171 100644 --- a/services/streammanager/kafka/client/client.go +++ b/services/streammanager/kafka/client/client.go @@ -72,7 +72,11 @@ func New(network string, addresses []string, conf Config) (*Client, error) { return nil, fmt.Errorf("cannot parse SSH private key: %w", err) } - sshConfig := &ssh.ClientConfig{User: conf.SSHConfig.User, Auth: []ssh.AuthMethod{ssh.PublicKeys(signer)}} + sshConfig := &ssh.ClientConfig{ + User: conf.SSHConfig.User, + Auth: []ssh.AuthMethod{ssh.PublicKeys(signer)}, + Timeout: conf.DialTimeout, + } if conf.SSHConfig.AcceptAnyHostKey { sshConfig.HostKeyCallback = ssh.InsecureIgnoreHostKey() }