diff options
author | 2017-01-29 12:06:26 -0800 | |
---|---|---|
committer | 2017-01-29 20:06:26 +0000 | |
commit | 738067a3c7a5ec15690364c0f5ba97c884195cd5 (patch) | |
tree | 7fb15ac9b4d2cc9a0f419caf481cb83da9eb483e /middleware/kubernetes | |
parent | bc301be5ee5841efdddd64b3f3661053c753ffac (diff) | |
download | coredns-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.go | 24 | ||||
-rw-r--r-- | middleware/kubernetes/kubernetes_test.go | 4 |
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) } |