diff --git a/pkg/kubelet/util/util_unix_test.go b/pkg/kubelet/util/util_unix_test.go index fea4e409f5e..1234a0a0ad2 100644 --- a/pkg/kubelet/util/util_unix_test.go +++ b/pkg/kubelet/util/util_unix_test.go @@ -133,3 +133,49 @@ func TestIsUnixDomainSocket(t *testing.T) { assert.Equal(t, result, test.expectSocket, "Unexpected result from IsUnixDomainSocket: %v for %s", result, test.label) } } + +func TestGetAddressAndDialer(t *testing.T) { + tests := []struct { + endpoint string + expectError bool + expectedAddr string + }{ + { + endpoint: "unix:///tmp/s1.sock", + expectError: false, + expectedAddr: "/tmp/s1.sock", + }, + { + endpoint: "unix:///tmp/f6.sock", + expectError: false, + expectedAddr: "/tmp/f6.sock", + }, + { + endpoint: "tcp://localhost:9090", + expectError: true, + }, + { + // The misspelling is intentional to make it error + endpoint: "htta://free-test.com", + expectError: true, + }, + { + endpoint: "https://www.youtube.com/", + expectError: true, + }, + { + endpoint: "http://www.baidu.com/", + expectError: true, + }, + } + for _, test := range tests { + // just test addr and err + addr, _, err := GetAddressAndDialer(test.endpoint) + if test.expectError { + assert.NotNil(t, err, "expected error during parsing %s", test.endpoint) + continue + } + assert.Nil(t, err, "expected no error during parsing %s", test.endpoint) + assert.Equal(t, test.expectedAddr, addr) + } +}