aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes/kubernetes.go
diff options
context:
space:
mode:
authorGravatar Manuel Alejandro de Brito Fontes <aledbf@gmail.com> 2016-09-22 09:27:29 -0300
committerGravatar GitHub <noreply@github.com> 2016-09-22 09:27:29 -0300
commitcacbb0e0b1cfcd7f4e95b76358a5332d6d90e6ea (patch)
tree153bea5a263e923ad67f2c27f3119d3b4f1b6f33 /middleware/kubernetes/kubernetes.go
parente0a49b73b580ba4ea1882b58318d36ff7977bbdd (diff)
parent3be9e58ddfc6ef0e8f3df74a14e8efad5e52545f (diff)
downloadcoredns-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.go8
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}}
}