aboutsummaryrefslogtreecommitdiff
path: root/plugin
diff options
context:
space:
mode:
Diffstat (limited to 'plugin')
-rw-r--r--plugin/kubernetes/kubernetes.go5
-rw-r--r--plugin/kubernetes/object/endpoint.go1
-rw-r--r--plugin/kubernetes/object/pod.go8
-rw-r--r--plugin/kubernetes/object/service.go1
4 files changed, 6 insertions, 9 deletions
diff --git a/plugin/kubernetes/kubernetes.go b/plugin/kubernetes/kubernetes.go
index 1b8214415..f980fb4ee 100644
--- a/plugin/kubernetes/kubernetes.go
+++ b/plugin/kubernetes/kubernetes.go
@@ -372,11 +372,6 @@ func (k *Kubernetes) findPods(r recordRequest, zone string) (pods []msg.Service,
continue
}
- // exclude pods in the process of termination
- if p.Deleting {
- continue
- }
-
// check for matching ip and namespace
if ip == p.PodIP && match(namespace, p.Namespace) {
s := msg.Service{Key: strings.Join([]string{zonePath, Pod, namespace, podname}, "/"), Host: ip, TTL: k.ttl}
diff --git a/plugin/kubernetes/object/endpoint.go b/plugin/kubernetes/object/endpoint.go
index b8531f050..aa93b4ceb 100644
--- a/plugin/kubernetes/object/endpoint.go
+++ b/plugin/kubernetes/object/endpoint.go
@@ -7,6 +7,7 @@ import (
// Endpoints is a stripped down api.Endpoints with only the items we need for CoreDNS.
type Endpoints struct {
+ // Don't add new fields to this struct without talking to the CoreDNS maintainers.
Version string
Name string
Namespace string
diff --git a/plugin/kubernetes/object/pod.go b/plugin/kubernetes/object/pod.go
index 9f0ba48ad..072d8d56d 100644
--- a/plugin/kubernetes/object/pod.go
+++ b/plugin/kubernetes/object/pod.go
@@ -7,11 +7,11 @@ import (
// Pod is a stripped down api.Pod with only the items we need for CoreDNS.
type Pod struct {
+ // Don't add new fields to this struct without talking to the CoreDNS maintainers.
Version string
PodIP string
Name string
Namespace string
- Deleting bool
*Empty
}
@@ -29,9 +29,10 @@ func ToPod(obj interface{}) interface{} {
Namespace: pod.GetNamespace(),
Name: pod.GetName(),
}
+ // don't add pods that are being deleted.
t := pod.ObjectMeta.DeletionTimestamp
- if t != nil {
- p.Deleting = !(*t).Time.IsZero()
+ if t != nil && !(*t).Time.IsZero() {
+ return nil
}
*pod = api.Pod{}
@@ -48,7 +49,6 @@ func (p *Pod) DeepCopyObject() runtime.Object {
PodIP: p.PodIP,
Namespace: p.Namespace,
Name: p.Name,
- Deleting: p.Deleting,
}
return p1
}
diff --git a/plugin/kubernetes/object/service.go b/plugin/kubernetes/object/service.go
index af9a42b48..3c8304362 100644
--- a/plugin/kubernetes/object/service.go
+++ b/plugin/kubernetes/object/service.go
@@ -7,6 +7,7 @@ import (
// Service is a stripped down api.Service with only the items we need for CoreDNS.
type Service struct {
+ // Don't add new fields to this struct without talking to the CoreDNS maintainers.
Version string
Name string
Namespace string