aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes
diff options
context:
space:
mode:
authorGravatar Yong Tang <yongtang@users.noreply.github.com> 2017-01-29 12:06:26 -0800
committerGravatar Miek Gieben <miek@miek.nl> 2017-01-29 20:06:26 +0000
commit738067a3c7a5ec15690364c0f5ba97c884195cd5 (patch)
tree7fb15ac9b4d2cc9a0f419caf481cb83da9eb483e /middleware/kubernetes
parentbc301be5ee5841efdddd64b3f3661053c753ffac (diff)
downloadcoredns-738067a3c7a5ec15690364c0f5ba97c884195cd5.tar.gz
coredns-738067a3c7a5ec15690364c0f5ba97c884195cd5.tar.zst
coredns-738067a3c7a5ec15690364c0f5ba97c884195cd5.zip
Fix `go fmt`, `go lint`, and `go vet` issues (#494)
This fix fixes several `go fmt`, `go lint`, and `go vet` issues, to make goreportcard happy: https://goreportcard.com/report/github.com/miekg/coredns Signed-off-by: Yong Tang <yong.tang.github@outlook.com>
Diffstat (limited to 'middleware/kubernetes')
-rw-r--r--middleware/kubernetes/kubernetes.go24
-rw-r--r--middleware/kubernetes/kubernetes_test.go4
2 files changed, 16 insertions, 12 deletions
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go
index af2de43f0..7ad2403c6 100644
--- a/middleware/kubernetes/kubernetes.go
+++ b/middleware/kubernetes/kubernetes.go
@@ -44,10 +44,14 @@ type Kubernetes struct {
}
const (
- PodModeDisabled = "disabled" // default. pod requests are ignored
- PodModeVerified = "verified" // Pod requests are answered only if they exist
- PodModeInsecure = "insecure" // ALL pod requests are answered without verfying they exist
- DnsSchemaVersion = "1.0.0" // https://github.com/kubernetes/dns/blob/master/docs/specification.md
+ // PodModeDisabled is the default value where pod requests are ignored
+ PodModeDisabled = "disabled"
+ // PodModeVerified is where Pod requests are answered only if they exist
+ PodModeVerified = "verified"
+ // PodModeInsecure is where pod requests are answered without verfying they exist
+ PodModeInsecure = "insecure"
+ // DNSSchemaVersion is the schema version: https://github.com/kubernetes/dns/blob/master/docs/specification.md
+ DNSSchemaVersion = "1.0.0"
)
type endpoint struct {
@@ -100,7 +104,7 @@ func (k *Kubernetes) recordsForTXT(r recordRequest) ([]msg.Service, error) {
switch r.typeName {
case "dns-version":
s := msg.Service{
- Text: DnsSchemaVersion,
+ Text: DNSSchemaVersion,
TTL: 28800,
Key: msg.Path(r.typeName+"."+r.zone, "coredns")}
return []msg.Service{s}, nil
@@ -289,7 +293,7 @@ func (k *Kubernetes) Records(r recordRequest) ([]msg.Service, error) {
return nil, errNsNotExposed
}
- services, pods, err := k.Get(r)
+ services, pods, err := k.get(r)
if err != nil {
return nil, err
}
@@ -405,8 +409,8 @@ func (k *Kubernetes) findPods(namespace, podname string) (pods []pod, err error)
return pods, nil
}
-// Get retrieves matching data from the cache.
-func (k *Kubernetes) Get(r recordRequest) (services []service, pods []pod, err error) {
+// get retrieves matching data from the cache.
+func (k *Kubernetes) get(r recordRequest) (services []service, pods []pod, err error) {
switch {
case r.typeName == "pod":
pods, err = k.findPods(r.namespace, r.service)
@@ -497,7 +501,7 @@ func (k *Kubernetes) getServiceRecordForIP(ip, name string) []msg.Service {
}
if service.Spec.ClusterIP == ip {
domain := service.Name + "." + service.Namespace + ".svc." + k.PrimaryZone()
- return []msg.Service{msg.Service{Host: domain}}
+ return []msg.Service{{Host: domain}}
}
}
// If no cluster ips match, search endpoints
@@ -513,7 +517,7 @@ func (k *Kubernetes) getServiceRecordForIP(ip, name string) []msg.Service {
for _, addr := range eps.Addresses {
if addr.IP == ip {
domain := endpointHostname(addr) + "." + ep.ObjectMeta.Name + "." + ep.ObjectMeta.Namespace + ".svc." + k.PrimaryZone()
- return []msg.Service{msg.Service{Host: domain}}
+ return []msg.Service{{Host: domain}}
}
}
}
diff --git a/middleware/kubernetes/kubernetes_test.go b/middleware/kubernetes/kubernetes_test.go
index 7b59cfecf..244db748c 100644
--- a/middleware/kubernetes/kubernetes_test.go
+++ b/middleware/kubernetes/kubernetes_test.go
@@ -27,8 +27,8 @@ func TestSymbolContainsWildcard(t *testing.T) {
func expectString(t *testing.T, function, qtype, query string, r *recordRequest, field, expected string) {
ref := reflect.ValueOf(r)
- ref_f := reflect.Indirect(ref).FieldByName(field)
- got := ref_f.String()
+ refField := reflect.Indirect(ref).FieldByName(field)
+ got := refField.String()
if got != expected {
t.Errorf("Expected %v(%v, \"%v\") to get %v == \"%v\". Instead got \"%v\".", function, query, qtype, field, expected, got)
}