aboutsummaryrefslogtreecommitdiff
path: root/middleware/kubernetes
diff options
context:
space:
mode:
authorGravatar Miek Gieben <miek@miek.nl> 2017-08-06 05:54:24 -0700
committerGravatar GitHub <noreply@github.com> 2017-08-06 05:54:24 -0700
commitbcb2eb1ecc79b2721dc5a2e0cca64008b601e431 (patch)
treea2721b7dcf51dfac57f4e19d37d06ebc0c991973 /middleware/kubernetes
parent964f04f4433772795fd76711020c5616bad5b915 (diff)
downloadcoredns-bcb2eb1ecc79b2721dc5a2e0cca64008b601e431.tar.gz
coredns-bcb2eb1ecc79b2721dc5a2e0cca64008b601e431.tar.zst
coredns-bcb2eb1ecc79b2721dc5a2e0cca64008b601e431.zip
all: gometalinter (#843)
* kubernetes/reverse: remove deadcode * deadcode in errors and kubernetes removed * unnecessary conversion * constants * proxy: time.Since() * simplications * static check * Disable test/external_test
Diffstat (limited to 'middleware/kubernetes')
-rw-r--r--middleware/kubernetes/controller.go9
-rw-r--r--middleware/kubernetes/handler_test.go20
-rw-r--r--middleware/kubernetes/kubernetes.go20
-rw-r--r--middleware/kubernetes/kubernetes_test.go17
-rw-r--r--middleware/kubernetes/setup.go1
-rw-r--r--middleware/kubernetes/setup_test.go64
6 files changed, 52 insertions, 79 deletions
diff --git a/middleware/kubernetes/controller.go b/middleware/kubernetes/controller.go
index 29562c0a7..3d60718ee 100644
--- a/middleware/kubernetes/controller.go
+++ b/middleware/kubernetes/controller.go
@@ -51,11 +51,10 @@ type dnsControl struct {
selector *labels.Selector
- svcController *cache.Controller
- podController *cache.Controller
- nsController *cache.Controller
- epController *cache.Controller
- nodeController *cache.Controller
+ svcController *cache.Controller
+ podController *cache.Controller
+ nsController *cache.Controller
+ epController *cache.Controller
svcLister cache.StoreToServiceLister
podLister cache.StoreToPodLister
diff --git a/middleware/kubernetes/handler_test.go b/middleware/kubernetes/handler_test.go
index 9e38bc59f..04d64722f 100644
--- a/middleware/kubernetes/handler_test.go
+++ b/middleware/kubernetes/handler_test.go
@@ -273,32 +273,32 @@ func TestServeDNS(t *testing.T) {
k.Next = testHandler(nextMWMap)
ctx := context.TODO()
- runServeDNSTests(t, dnsTestCases, k, ctx)
- runServeDNSTests(t, autopathCases, k, ctx)
- runServeDNSTests(t, autopathBareSearch, k, ctx)
+ runServeDNSTests(ctx, t, dnsTestCases, k)
+ runServeDNSTests(ctx, t, autopathCases, k)
+ runServeDNSTests(ctx, t, autopathBareSearch, k)
//Set PodMode to Disabled
k.PodMode = PodModeDisabled
- runServeDNSTests(t, podModeDisabledCases, k, ctx)
+ runServeDNSTests(ctx, t, podModeDisabledCases, k)
//Set PodMode to Insecure
k.PodMode = PodModeInsecure
- runServeDNSTests(t, podModeInsecureCases, k, ctx)
+ runServeDNSTests(ctx, t, podModeInsecureCases, k)
//Set PodMode to Verified
k.PodMode = PodModeVerified
- runServeDNSTests(t, podModeVerifiedCases, k, ctx)
+ runServeDNSTests(ctx, t, podModeVerifiedCases, k)
// Set ndots to 2 for the ndots test cases
k.AutoPath.NDots = 2
- runServeDNSTests(t, autopath2NDotsCases, k, ctx)
+ runServeDNSTests(ctx, t, autopath2NDotsCases, k)
k.AutoPath.NDots = defautNdots
// Disable the NXDOMAIN override (enabled by default)
k.OnNXDOMAIN = dns.RcodeNameError
- runServeDNSTests(t, autopathCases, k, ctx)
- runServeDNSTests(t, autopathBareSearchExpectNameErr, k, ctx)
+ runServeDNSTests(ctx, t, autopathCases, k)
+ runServeDNSTests(ctx, t, autopathBareSearchExpectNameErr, k)
}
-func runServeDNSTests(t *testing.T, dnsTestCases map[string](*test.Case), k Kubernetes, ctx context.Context) {
+func runServeDNSTests(ctx context.Context, t *testing.T, dnsTestCases map[string](*test.Case), k Kubernetes) {
for testname, tc := range dnsTestCases {
testname = "\nTest Case \"" + testname + "\""
r := tc.Msg()
diff --git a/middleware/kubernetes/kubernetes.go b/middleware/kubernetes/kubernetes.go
index 016cfc403..3649eb02c 100644
--- a/middleware/kubernetes/kubernetes.go
+++ b/middleware/kubernetes/kubernetes.go
@@ -100,13 +100,12 @@ type recordRequest struct {
}
var (
- errNoItems = errors.New("no items found")
- errNsNotExposed = errors.New("namespace is not exposed")
- errInvalidRequest = errors.New("invalid query name")
- errZoneNotFound = errors.New("zone not found")
- errAPIBadPodType = errors.New("expected type *api.Pod")
- errPodsDisabled = errors.New("pod records disabled")
- errResolvConfReadErr = errors.New("resolv.conf read error")
+ errNoItems = errors.New("no items found")
+ errNsNotExposed = errors.New("namespace is not exposed")
+ errInvalidRequest = errors.New("invalid query name")
+ errZoneNotFound = errors.New("zone not found")
+ errAPIBadPodType = errors.New("expected type *api.Pod")
+ errPodsDisabled = errors.New("pod records disabled")
)
// Services implements the ServiceBackend interface.
@@ -468,13 +467,6 @@ func (k *Kubernetes) getRecordsForK8sItems(services []service, pods []pod, r rec
return records
}
-func ipFromPodName(podname string) string {
- if strings.Count(podname, "-") == 3 && !strings.Contains(podname, "--") {
- return strings.Replace(podname, "-", ".", -1)
- }
- return strings.Replace(podname, "-", ":", -1)
-}
-
func (k *Kubernetes) findPodWithIP(ip string) (p *api.Pod) {
if !k.AutoPath.Enabled {
return nil
diff --git a/middleware/kubernetes/kubernetes_test.go b/middleware/kubernetes/kubernetes_test.go
index 268028c1e..ae3fbf149 100644
--- a/middleware/kubernetes/kubernetes_test.go
+++ b/middleware/kubernetes/kubernetes_test.go
@@ -260,23 +260,6 @@ func TestEndpointHostname(t *testing.T) {
}
}
-func TestIpFromPodName(t *testing.T) {
- var tests = []struct {
- ip string
- expected string
- }{
- {"10-11-12-13", "10.11.12.13"},
- {"1-2-3-4", "1.2.3.4"},
- {"1-2-3--A-B-C", "1:2:3::A:B:C"},
- }
- for _, test := range tests {
- result := ipFromPodName(test.ip)
- if result != test.expected {
- t.Errorf("Expected ip for podname '%v' to be '%v', but got '%v'", test.ip, test.expected, result)
- }
- }
-}
-
type APIConnServiceTest struct{}
func (APIConnServiceTest) Run() { return }
diff --git a/middleware/kubernetes/setup.go b/middleware/kubernetes/setup.go
index a12673a13..d56b788f9 100644
--- a/middleware/kubernetes/setup.go
+++ b/middleware/kubernetes/setup.go
@@ -242,7 +242,6 @@ func kubernetesParse(c *caddy.Controller) (*Kubernetes, error) {
const (
defaultResyncPeriod = 5 * time.Minute
- defaultPodMode = PodModeDisabled
defautNdots = 0
defaultResolvConfFile = "/etc/resolv.conf"
defaultOnNXDOMAIN = dns.RcodeSuccess
diff --git a/middleware/kubernetes/setup_test.go b/middleware/kubernetes/setup_test.go
index c8e84a724..9512c8fbf 100644
--- a/middleware/kubernetes/setup_test.go
+++ b/middleware/kubernetes/setup_test.go
@@ -54,7 +54,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -70,7 +70,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -87,7 +87,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -105,7 +105,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -123,7 +123,7 @@ func TestKubernetesParse(t *testing.T) {
1,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -141,7 +141,7 @@ func TestKubernetesParse(t *testing.T) {
2,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -159,7 +159,7 @@ func TestKubernetesParse(t *testing.T) {
0,
30 * time.Second,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -177,7 +177,7 @@ func TestKubernetesParse(t *testing.T) {
0,
15 * time.Minute,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -195,7 +195,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"environment=prod",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -213,7 +213,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"application=nginx,environment in (production,qa,staging)",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -235,7 +235,7 @@ func TestKubernetesParse(t *testing.T) {
2,
15 * time.Minute,
"application=nginx,environment in (production,qa,staging)",
- defaultPodMode,
+ PodModeDisabled,
nil,
true,
nil,
@@ -252,7 +252,7 @@ func TestKubernetesParse(t *testing.T) {
-1,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -268,7 +268,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -286,7 +286,7 @@ func TestKubernetesParse(t *testing.T) {
-1,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -304,7 +304,7 @@ func TestKubernetesParse(t *testing.T) {
-1,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -322,7 +322,7 @@ func TestKubernetesParse(t *testing.T) {
0,
0 * time.Minute,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -340,7 +340,7 @@ func TestKubernetesParse(t *testing.T) {
0,
0 * time.Second,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -358,7 +358,7 @@ func TestKubernetesParse(t *testing.T) {
0,
0 * time.Second,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -376,7 +376,7 @@ func TestKubernetesParse(t *testing.T) {
0,
0 * time.Second,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -394,7 +394,7 @@ func TestKubernetesParse(t *testing.T) {
0,
0 * time.Second,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -489,7 +489,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
[]net.IPNet{parseCidr("10.0.0.0/24"), parseCidr("10.0.1.0/24")},
false,
nil,
@@ -508,7 +508,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -527,7 +527,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -546,7 +546,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
[]string{"13.14.15.16:53"},
@@ -565,7 +565,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -585,7 +585,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -607,7 +607,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -626,7 +626,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -650,7 +650,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -668,7 +668,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -686,7 +686,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,
@@ -704,7 +704,7 @@ func TestKubernetesParse(t *testing.T) {
0,
defaultResyncPeriod,
"",
- defaultPodMode,
+ PodModeDisabled,
nil,
false,
nil,