diff options
author | 2016-09-21 16:05:18 -0300 | |
---|---|---|
committer | 2016-09-21 20:05:18 +0100 | |
commit | d250742d9e8a1851db370c5218e3ae90d373dccb (patch) | |
tree | d2be53e75b963c811071690aa886efe84d24ef36 /middleware/kubernetes/kubernetes.go | |
parent | 5301c5af5fde0ad5bf063e12decd4c5202047457 (diff) | |
download | coredns-d250742d9e8a1851db370c5218e3ae90d373dccb.tar.gz coredns-d250742d9e8a1851db370c5218e3ae90d373dccb.tar.zst coredns-d250742d9e8a1851db370c5218e3ae90d373dccb.zip |
Fix k8s build (#278)
Diffstat (limited to 'middleware/kubernetes/kubernetes.go')
-rw-r--r-- | middleware/kubernetes/kubernetes.go | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go index 0bd1dc7a4..eddc58b12 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.Items { + for _, item := range serviceList { 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,12 +216,11 @@ func isKubernetesNameError(err error) bool { } func (k *Kubernetes) getServiceRecordForIP(ip, name string) []msg.Service { - svcList, err := k.APIConn.svcLister.List() + svcList, err := k.APIConn.svcLister.List(labels.Everything()) if err != nil { return nil } - - for _, service := range svcList.Items { + for _, service := range svcList { if service.Spec.ClusterIP == ip { return []msg.Service{msg.Service{Host: ip}} } |