diff options
| author |  Miek Gieben <miek@miek.nl>
| 2017-08-19 07:18:35 +0100 |
|---|---|---|
| committer |  GitHub <noreply@github.com>
| 2017-08-19 07:18:35 +0100 |
| commit | 627687b11fe56d3235a2f6a5055f1c6749752096 (patch) | |
| tree | e07143ff472de3243cf48fc365ab0c7d821c10ee /middleware/kubernetes/kubernetes.go | |
| parent | f96cf27193032120ba727316c4057dffed0cbe48 (diff) | |
| download | coredns-627687b11fe56d3235a2f6a5055f1c6749752096.tar.gz coredns-627687b11fe56d3235a2f6a5055f1c6749752096.tar.zst coredns-627687b11fe56d3235a2f6a5055f1c6749752096.zip | |
mw/kubernetes: remove zone from parseRequest (#938)
* mw/kubernetes: remove zone from parseRequest
State has the zone info as well, so don't need to have it in
parseRequest anymore.
* Fix up tests
* improve test coverage
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 { |