fix(outputs.prometheus_client): Always default to TCP (#14471)
This commit is contained in:
parent
6761200309
commit
9ec0894dee
|
|
@ -5,7 +5,6 @@ import (
|
||||||
"context"
|
"context"
|
||||||
"crypto/tls"
|
"crypto/tls"
|
||||||
_ "embed"
|
_ "embed"
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"net"
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
@ -217,12 +216,13 @@ func (p *PrometheusClient) listen() (net.Listener, error) {
|
||||||
return p.listenTCP(p.Listen)
|
return p.listenTCP(p.Listen)
|
||||||
}
|
}
|
||||||
switch strings.ToLower(u.Scheme) {
|
switch strings.ToLower(u.Scheme) {
|
||||||
case "tcp", "http":
|
case "", "tcp", "http":
|
||||||
return p.listenTCP(u.Host)
|
return p.listenTCP(u.Host)
|
||||||
case "vsock":
|
case "vsock":
|
||||||
return p.listenVsock(u.Host)
|
return p.listenVsock(u.Host)
|
||||||
|
default:
|
||||||
|
return p.listenTCP(u.Host)
|
||||||
}
|
}
|
||||||
return nil, errors.New("Unknown scheme")
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (p *PrometheusClient) Connect() error {
|
func (p *PrometheusClient) Connect() error {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue