github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-12 20:57:20 +00:00
Code Issues Projects Releases Wiki Activity

Add an integration test for services.

Browse Source
This commit is contained in:
Brendan Burns
2014-10-02 20:24:30 -07:00
parent d131ad640a
commit f00fd8d2e3
2 changed files with 73 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/service/endpoints_controller.go
View File

@@ -62,8 +62,8 @@ func (e *EndpointController) SyncServiceEndpoints() error {
resultErr = err
continue
}
endpoints := make([]string, len(pods.Items))
for ix, pod := range pods.Items {
endpoints := []string{}
for _, pod := range pods.Items {
port, err := findPort(&pod.DesiredState.Manifest, service.ContainerPort)
if err != nil {
glog.Errorf("Failed to find port for service: %v, %v", service, err)
@@ -73,7 +73,7 @@ func (e *EndpointController) SyncServiceEndpoints() error {
glog.Errorf("Failed to find an IP for pod: %v", pod)
continue
}
endpoints[ix] = net.JoinHostPort(pod.CurrentState.PodIP, strconv.Itoa(port))
endpoints = append(endpoints, net.JoinHostPort(pod.CurrentState.PodIP, strconv.Itoa(port)))
}
currentEndpoints, err := e.client.GetEndpoints(nsCtx, service.ID)
if err != nil {