in pkg/util/util.go [110:132]
func ParseEndpoint(endpoint string, cleanupSocket bool) (string, string, error) {
u, err := url.Parse(endpoint)
if err != nil {
klog.Fatal(err.Error())
}
var addr string
switch u.Scheme {
case "unix":
addr = u.Path
if cleanupSocket {
if err := os.Remove(addr); err != nil && !os.IsNotExist(err) {
klog.Fatalf("Failed to remove %s, error: %s", addr, err)
}
}
case "tcp":
addr = u.Host
default:
klog.Fatalf("%v endpoint scheme not supported", u.Scheme)
}
return u.Scheme, addr, nil
}