github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 03:41:45 +00:00
Code Issues Projects Releases Wiki Activity

use custom dialer for tcp probes

Browse Source 
Change-Id: I323b472606eaf3242b665022afe2a79ecf3b8358
This commit is contained in:
Antonio Ojea 2023-01-17 23:51:59 +00:00
parent 1978008c8f
commit d21f98c6f9
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/probe/tcp/tcp.go
View File

@ -38,7 +38,7 @@ type Prober interface {
type tcpProber struct{} type tcpProber struct{}
// Probe returns a ProbeRunner capable of running an TCP check. // Probe checks that a TCP connection to the address can be opened.
func (pr tcpProber) Probe(host string, port int, timeout time.Duration) (probe.Result, string, error) { func (pr tcpProber) Probe(host string, port int, timeout time.Duration) (probe.Result, string, error) {
return DoTCPProbe(net.JoinHostPort(host, strconv.Itoa(port)), timeout) return DoTCPProbe(net.JoinHostPort(host, strconv.Itoa(port)), timeout)
} }
@ -48,7 +48,9 @@ func (pr tcpProber) Probe(host string, port int, timeout time.Duration) (probe.R
// If the socket fails to open, it returns Failure. // If the socket fails to open, it returns Failure.
// This is exported because some other packages may want to do direct TCP probes. // This is exported because some other packages may want to do direct TCP probes.
func DoTCPProbe(addr string, timeout time.Duration) (probe.Result, string, error) { func DoTCPProbe(addr string, timeout time.Duration) (probe.Result, string, error) {
conn, err := net.DialTimeout("tcp", addr, timeout) d := probe.ProbeDialer()
d.Timeout = timeout
conn, err := d.Dial("tcp", addr)
if err != nil { if err != nil {
// Convert errors to failures to handle timeouts. // Convert errors to failures to handle timeouts.
return probe.Failure, err.Error(), nil return probe.Failure, err.Error(), nil