upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-06-08 16:30:57 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Search for port number for service locator

Browse source
This commit is contained in:
Deyuan Deng 2015-10-19 19:30:38 +08:00
parent 02dd86c136
commit 151e4b7cb8
2 changed files with 21 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
pkg/registry/service/rest.go
View file

@ -309,6 +309,15 @@ func (rs *REST) ResourceLocation(ctx api.Context, id string) (*url.URL, http.Rou
Scheme: svcScheme,
Host: net.JoinHostPort(ip, strconv.Itoa(port)),
}, rs.proxyTransport, nil
} else {
port, err := strconv.ParseInt(portStr, 10, 64)
if err == nil && int(port) == ss.Ports[i].Port {
ip := ss.Addresses[rand.Intn(len(ss.Addresses))].IP
return &url.URL{
Scheme: svcScheme,
Host: net.JoinHostPort(ip, portStr),
}, rs.proxyTransport, nil
}
}
}
}

12
pkg/registry/service/rest_test.go
View file

@ -491,6 +491,18 @@ func TestServiceRegistryResourceLocation(t *testing.T) {
t.Errorf("Expected %v, but got %v", e, a)
}
// Test a name + port number.
location, _, err = redirector.ResourceLocation(ctx, "foo:93")
if err != nil {
t.Errorf("Unexpected error: %v", err)
}
if location == nil {
t.Errorf("Unexpected nil: %v", location)
}
if e, a := "//1.2.3.4:93", location.String(); e != a {
t.Errorf("Expected %v, but got %v", e, a)
}
// Test a scheme + name + port.
location, _, err = redirector.ResourceLocation(ctx, "https:foo:p")
if err != nil {