aboutsummaryrefslogtreecommitdiff
path: root/plugin/kubernetes
diff options
context:
space:
mode:
Diffstat (limited to 'plugin/kubernetes')
-rw-r--r--plugin/kubernetes/handler_test.go1
-rw-r--r--plugin/kubernetes/kubernetes.go5
-rw-r--r--plugin/kubernetes/kubernetes_test.go2
3 files changed, 5 insertions, 3 deletions
diff --git a/plugin/kubernetes/handler_test.go b/plugin/kubernetes/handler_test.go
index c9df46d07..6bcb00ecd 100644
--- a/plugin/kubernetes/handler_test.go
+++ b/plugin/kubernetes/handler_test.go
@@ -288,6 +288,7 @@ var svcIndex = map[string][]*api.Service{
Protocol: "tcp",
Port: 80,
}},
+ Type: api.ServiceTypeExternalName,
},
}},
}
diff --git a/plugin/kubernetes/kubernetes.go b/plugin/kubernetes/kubernetes.go
index d8b27d42d..8048f85cb 100644
--- a/plugin/kubernetes/kubernetes.go
+++ b/plugin/kubernetes/kubernetes.go
@@ -418,16 +418,15 @@ func (k *Kubernetes) findServices(r recordRequest, zone string) (services []msg.
}
// External service
- if svc.Spec.ExternalName != "" {
+ if svc.Spec.Type == api.ServiceTypeExternalName {
s := msg.Service{Key: strings.Join([]string{zonePath, Svc, svc.Namespace, svc.Name}, "/"), Host: svc.Spec.ExternalName, TTL: k.ttl}
if t, _ := s.HostType(); t == dns.TypeCNAME {
s.Key = strings.Join([]string{zonePath, Svc, svc.Namespace, svc.Name}, "/")
services = append(services, s)
err = nil
-
- continue
}
+ continue
}
// ClusterIP service
diff --git a/plugin/kubernetes/kubernetes_test.go b/plugin/kubernetes/kubernetes_test.go
index f05693d71..6a95c5b71 100644
--- a/plugin/kubernetes/kubernetes_test.go
+++ b/plugin/kubernetes/kubernetes_test.go
@@ -101,6 +101,7 @@ func (APIConnServiceTest) SvcIndex(string) []*api.Service {
Protocol: "tcp",
Port: 80,
}},
+ Type: api.ServiceTypeExternalName,
},
},
}
@@ -144,6 +145,7 @@ func (APIConnServiceTest) ServiceList() []*api.Service {
Protocol: "tcp",
Port: 80,
}},
+ Type: api.ServiceTypeExternalName,
},
},
}