diff options
author | 2017-09-12 10:52:43 +0100 | |
---|---|---|
committer | 2017-09-12 10:52:43 +0100 | |
commit | 3e252deabbfd9f0f384df4bf7b3847e9442f0b9f (patch) | |
tree | efc796384a2c0c961e4e3914cf663e3aa2d5594d /middleware/kubernetes/kubernetes.go | |
parent | c2105a4f41132286e3145872fc187ab4e75a24b4 (diff) | |
download | coredns-3e252deabbfd9f0f384df4bf7b3847e9442f0b9f.tar.gz coredns-3e252deabbfd9f0f384df4bf7b3847e9442f0b9f.tar.zst coredns-3e252deabbfd9f0f384df4bf7b3847e9442f0b9f.zip |
Remove debug queries (#1058)
* Remove debug from interface and methods
* remove debug queries from etcd
* remove debug queries from k8s - they were not used
* And remove from mw/proxy-google as well
* Remove debug query test
Diffstat (limited to 'middleware/kubernetes/kubernetes.go')
-rw-r--r-- | middleware/kubernetes/kubernetes.go | 23 |
1 files changed, 9 insertions, 14 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go index 42c68e580..fe58df74d 100644 --- a/middleware/kubernetes/kubernetes.go +++ b/middleware/kubernetes/kubernetes.go @@ -81,7 +81,7 @@ var ( ) // Services implements the ServiceBackend interface. -func (k *Kubernetes) Services(state request.Request, exact bool, opt middleware.Options) (svcs []msg.Service, debug []msg.Service, err error) { +func (k *Kubernetes) Services(state request.Request, exact bool, opt middleware.Options) (svcs []msg.Service, err error) { // We're looking again at types, which we've already done in ServeDNS, but there are some types k8s just can't answer. switch state.QType() { @@ -92,19 +92,19 @@ func (k *Kubernetes) Services(state request.Request, exact bool, opt middleware. segs := dns.SplitDomainName(t) if len(segs) != 1 { - return nil, nil, fmt.Errorf("kubernetes: TXT query can only be for dns-version: %s", state.QName()) + return nil, fmt.Errorf("kubernetes: TXT query can only be for dns-version: %s", state.QName()) } if segs[0] != "dns-version" { - return nil, nil, nil + return nil, nil } svc := msg.Service{Text: DNSSchemaVersion, TTL: 28800, Key: msg.Path(state.QName(), "coredns")} - return []msg.Service{svc}, nil, nil + return []msg.Service{svc}, nil case dns.TypeNS: // We can only get here if the qname equal the zone, see ServeDNS in handler.go. ns := k.nsAddr() svc := msg.Service{Host: ns.A.String(), Key: msg.Path(state.QName(), "coredns")} - return []msg.Service{svc}, nil, nil + return []msg.Service{svc}, nil } if state.QType() == dns.TypeA && isDefaultNS(state.Name(), state.Zone) { @@ -112,7 +112,7 @@ func (k *Kubernetes) Services(state request.Request, exact bool, opt middleware. // SOA records always use this hardcoded name ns := k.nsAddr() svc := msg.Service{Host: ns.A.String(), Key: msg.Path(state.QName(), "coredns")} - return []msg.Service{svc}, nil, nil + return []msg.Service{svc}, nil } s, e := k.Records(state, false) @@ -120,7 +120,7 @@ func (k *Kubernetes) Services(state request.Request, exact bool, opt middleware. // SRV for external services is not yet implemented, so remove those records. if state.QType() != dns.TypeSRV { - return s, nil, e + return s, e } internal := []msg.Service{} @@ -130,13 +130,11 @@ func (k *Kubernetes) Services(state request.Request, exact bool, opt middleware. } } - return internal, nil, e + return internal, e } // primaryZone will return the first non-reverse zone being handled by this middleware -func (k *Kubernetes) primaryZone() string { - return k.Zones[k.primaryZoneIndex] -} +func (k *Kubernetes) primaryZone() string { return k.Zones[k.primaryZoneIndex] } // Lookup implements the ServiceBackend interface. func (k *Kubernetes) Lookup(state request.Request, name string, typ uint16) (*dns.Msg, error) { @@ -148,9 +146,6 @@ func (k *Kubernetes) IsNameError(err error) bool { return err == errNoItems || err == errNsNotExposed || err == errInvalidRequest } -// Debug implements the ServiceBackend interface. -func (k *Kubernetes) Debug() string { return "debug" } - func (k *Kubernetes) getClientConfig() (*rest.Config, error) { loadingRules := &clientcmd.ClientConfigLoadingRules{} overrides := &clientcmd.ConfigOverrides{} |