diff options
author | 2016-09-22 09:27:29 -0300 | |
---|---|---|
committer | 2016-09-22 09:27:29 -0300 | |
commit | cacbb0e0b1cfcd7f4e95b76358a5332d6d90e6ea (patch) | |
tree | 153bea5a263e923ad67f2c27f3119d3b4f1b6f33 /middleware/kubernetes/kubernetes.go | |
parent | e0a49b73b580ba4ea1882b58318d36ff7977bbdd (diff) | |
parent | 3be9e58ddfc6ef0e8f3df74a14e8efad5e52545f (diff) | |
download | coredns-cacbb0e0b1cfcd7f4e95b76358a5332d6d90e6ea.tar.gz coredns-cacbb0e0b1cfcd7f4e95b76358a5332d6d90e6ea.tar.zst coredns-cacbb0e0b1cfcd7f4e95b76358a5332d6d90e6ea.zip |
Merge pull request #279 from aledbf/revert-k8s
Revert k8s changes
Diffstat (limited to 'middleware/kubernetes/kubernetes.go')
-rw-r--r-- | middleware/kubernetes/kubernetes.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go index eddc58b12..7e21d5759 100644 --- a/middleware/kubernetes/kubernetes.go +++ b/middleware/kubernetes/kubernetes.go @@ -183,14 +183,14 @@ func (k *Kubernetes) Get(namespace string, nsWildcard bool, servicename string, var resultItems []api.Service - for _, item := range serviceList { + for _, item := range serviceList.Items { if symbolMatches(namespace, item.Namespace, nsWildcard) && symbolMatches(servicename, item.Name, serviceWildcard) { // If namespace has a wildcard, filter results against Corefile namespace list. // (Namespaces without a wildcard were filtered before the call to this function.) if nsWildcard && (len(k.Namespaces) > 0) && (!util.StringInSlice(item.Namespace, k.Namespaces)) { continue } - resultItems = append(resultItems, *item) + resultItems = append(resultItems, item) } } @@ -216,11 +216,11 @@ func isKubernetesNameError(err error) bool { } func (k *Kubernetes) getServiceRecordForIP(ip, name string) []msg.Service { - svcList, err := k.APIConn.svcLister.List(labels.Everything()) + svcList, err := k.APIConn.svcLister.List() if err != nil { return nil } - for _, service := range svcList { + for _, service := range svcList.Items { if service.Spec.ClusterIP == ip { return []msg.Service{msg.Service{Host: ip}} } |