From f2daa022563fc2f57d0e3f1c2479391a1a8224d2 Mon Sep 17 00:00:00 2001 From: Asim Date: Fri, 3 Apr 2015 00:30:18 +0200 Subject: [PATCH] Fix kubernetes compile issues --- registry/kubernetes_registry.go | 6 ++++-- registry/kubernetes_watcher.go | 2 +- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/registry/kubernetes_registry.go b/registry/kubernetes_registry.go index 4181c219..77fe0db4 100644 --- a/registry/kubernetes_registry.go +++ b/registry/kubernetes_registry.go @@ -38,7 +38,9 @@ func (c *KubernetesRegistry) GetService(name string) (Service, error) { return service, nil } - services, err := c.Client.Services(c.Namespace).List(labels.OneTermEqualSelector("name", name)) + selector := labels.SelectorFromSet(labels.Set{"name": name}) + + services, err := c.Client.Services(c.Namespace).List(selector) if err != nil { return nil, err } @@ -51,7 +53,7 @@ func (c *KubernetesRegistry) GetService(name string) (Service, error) { for _, item := range services.Items { ks.ServiceNodes = append(ks.ServiceNodes, &KubernetesNode{ NodeAddress: item.Spec.PortalIP, - NodePort: item.Spec.Port, + NodePort: item.Spec.Ports[0].Port, }) } diff --git a/registry/kubernetes_watcher.go b/registry/kubernetes_watcher.go index 2804c114..319d8132 100644 --- a/registry/kubernetes_watcher.go +++ b/registry/kubernetes_watcher.go @@ -32,7 +32,7 @@ func (k *KubernetesWatcher) OnUpdate(services []api.Service) { ServiceNodes: []*KubernetesNode{ &KubernetesNode{ NodeAddress: serviceIP.String(), - NodePort: service.Spec.Port, + NodePort: service.Spec.Ports[0].Port, }, }, }