From 2e831c76c245b262597d3b9f26ef035e8dec0230 Mon Sep 17 00:00:00 2001 From: Sebastiaan van Stijn Date: Sat, 9 Apr 2022 15:03:04 +0200 Subject: [PATCH] daemon/logger/gelf: remove uses of pkg/urlutil.IsTransportURL() pkg/urlutil (despite its poorly chosen name) is not really intended as a generic utility to handle URLs, and should only be used by the builder to handle (remote) build contexts. This patch: - removes a redundant use of urlutil.IsTransportURL(); code further below already checked if the given scheme (protocol) was supported. - renames some variables that collided with imported packages. Signed-off-by: Sebastiaan van Stijn --- daemon/logger/gelf/gelf.go | 14 ++++---------- daemon/logger/gelf/gelf_test.go | 8 ++++---- 2 files changed, 8 insertions(+), 14 deletions(-) diff --git a/daemon/logger/gelf/gelf.go b/daemon/logger/gelf/gelf.go index 5492e5a4ce..c7814e9207 100644 --- a/daemon/logger/gelf/gelf.go +++ b/daemon/logger/gelf/gelf.go @@ -14,7 +14,6 @@ import ( "github.com/Graylog2/go-gelf/gelf" "github.com/docker/docker/daemon/logger" "github.com/docker/docker/daemon/logger/loggerutils" - "github.com/docker/docker/pkg/urlutil" "github.com/sirupsen/logrus" ) @@ -251,23 +250,18 @@ func parseAddress(address string) (*url.URL, error) { if address == "" { return nil, fmt.Errorf("gelf-address is a required parameter") } - if !urlutil.IsTransportURL(address) { - return nil, fmt.Errorf("gelf-address should be in form proto://address, got %v", address) - } - url, err := url.Parse(address) + addr, err := url.Parse(address) if err != nil { return nil, err } - // we support only udp - if url.Scheme != "udp" && url.Scheme != "tcp" { + if addr.Scheme != "udp" && addr.Scheme != "tcp" { return nil, fmt.Errorf("gelf: endpoint needs to be TCP or UDP") } - // get host and port - if _, _, err = net.SplitHostPort(url.Host); err != nil { + if _, _, err = net.SplitHostPort(addr.Host); err != nil { return nil, fmt.Errorf("gelf: please provide gelf-address as proto://host:port") } - return url, nil + return addr, nil } diff --git a/daemon/logger/gelf/gelf_test.go b/daemon/logger/gelf/gelf_test.go index 2b6e5f0f82..144dc544d3 100644 --- a/daemon/logger/gelf/gelf_test.go +++ b/daemon/logger/gelf/gelf_test.go @@ -223,12 +223,12 @@ func TestNewTCP(t *testing.T) { ContainerID: "12345678901234567890", } - logger, err := New(info) + gelfLogger, err := New(info) if err != nil { t.Fatal(err) } - err = logger.Close() + err = gelfLogger.Close() if err != nil { t.Fatal(err) } @@ -250,12 +250,12 @@ func TestNewUDP(t *testing.T) { ContainerID: "12345678901234567890", } - logger, err := New(info) + gelfLogger, err := New(info) if err != nil { t.Fatal(err) } - err = logger.Close() + err = gelfLogger.Close() if err != nil { t.Fatal(err) }