diff options
Diffstat (limited to 'middleware/kubernetes/kubernetes.go')
| -rw-r--r-- | middleware/kubernetes/kubernetes.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go index 419017bad..0ed71b6c0 100644 --- a/middleware/kubernetes/kubernetes.go +++ b/middleware/kubernetes/kubernetes.go @@ -315,7 +315,7 @@ func (k *Kubernetes) Entries(state request.Request) ([]msg.Service, error) { return nil, errNoItems } - records := k.getRecordsForK8sItems(services, pods, r) + records := k.getRecordsForK8sItems(services, pods, state.Zone) return records, nil } @@ -332,8 +332,8 @@ func endpointHostname(addr api.EndpointAddress) string { return "" } -func (k *Kubernetes) getRecordsForK8sItems(services []kService, pods []kPod, r recordRequest) (records []msg.Service) { - zonePath := msg.Path(r.zone, "coredns") +func (k *Kubernetes) getRecordsForK8sItems(services []kService, pods []kPod, zone string) (records []msg.Service) { + zonePath := msg.Path(zone, "coredns") for _, svc := range services { if svc.addr == api.ClusterIPNone || len(svc.endpoints) > 0 { |