aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes
diff options
context:
space:
mode:
authorGravatar Miek Gieben <miek@miek.nl> 2016-11-11 16:56:15 +0000
committerGravatar Miek Gieben <miek@miek.nl> 2016-11-11 16:56:15 +0000
commit651f3938a158e3b299ba5d548b191aee6d36f62d (patch)
tree1f6f72b6895f5e09ec6101185559b7360ad97856 /middleware/kubernetes
parent20e25559d5eada5a68a0720816a6e947b94860ce (diff)
downloadcoredns-651f3938a158e3b299ba5d548b191aee6d36f62d.tar.gz
coredns-651f3938a158e3b299ba5d548b191aee6d36f62d.tar.zst
coredns-651f3938a158e3b299ba5d548b191aee6d36f62d.zip
More idiomatic Go
Diffstat (limited to 'middleware/kubernetes')
-rw-r--r--middleware/kubernetes/kubernetes.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go
index ca7067806..0a63ffc9e 100644
--- a/middleware/kubernetes/kubernetes.go
+++ b/middleware/kubernetes/kubernetes.go
@@ -44,8 +44,8 @@ type Kubernetes struct {
Selector *labels.Selector
}
-var noItemsErr = errors.New("no items found")
-var nsUnexposedErr = errors.New("namespace is not exposed")
+var errNoItems = errors.New("no items found")
+var errNsNotExposed = errors.New("namespace is not exposed")
// Services implements the ServiceBackend interface.
func (k *Kubernetes) Services(state request.Request, exact bool, opt middleware.Options) ([]msg.Service, []msg.Service, error) {
@@ -71,7 +71,7 @@ func (k *Kubernetes) Lookup(state request.Request, name string, typ uint16) (*dn
// IsNameError implements the ServiceBackend interface.
func (k *Kubernetes) IsNameError(err error) bool {
- return err == noItemsErr || err == nsUnexposedErr
+ return err == errNoItems || err == errNsNotExposed
}
// Debug implements the ServiceBackend interface.
@@ -202,7 +202,7 @@ func (k *Kubernetes) Records(name string, exact bool) ([]msg.Service, error) {
// Abort if the namespace does not contain a wildcard, and namespace is not published per CoreFile
// Case where namespace contains a wildcard is handled in Get(...) method.
if (!nsWildcard) && (len(k.Namespaces) > 0) && (!dnsstrings.StringInSlice(namespace, k.Namespaces)) {
- return nil, nsUnexposedErr
+ return nil, errNsNotExposed
}
k8sItems, err := k.Get(namespace, nsWildcard, serviceName, serviceWildcard, typeName)
@@ -211,7 +211,7 @@ func (k *Kubernetes) Records(name string, exact bool) ([]msg.Service, error) {
}
if len(k8sItems) == 0 {
// Did not find item in k8s
- return nil, noItemsErr
+ return nil, errNoItems
}
records := k.getRecordsForServiceItems(k8sItems, zone)