aboutsummaryrefslogtreecommitdiff
path: root/plugin/kubernetes/watch_test.go
diff options
context:
space:
mode:
authorGravatar Miek Gieben <miek@miek.nl> 2019-02-11 14:46:53 +0000
committerGravatar GitHub <noreply@github.com> 2019-02-11 14:46:53 +0000
commit29cb00aada276ad99e4f3aef380de9e68f2ebae8 (patch)
tree5f8425b59111f1154bd87bfa8917f6add807cace /plugin/kubernetes/watch_test.go
parentf69819387dcb69234adcda08b0af1af97b84f76e (diff)
downloadcoredns-29cb00aada276ad99e4f3aef380de9e68f2ebae8.tar.gz
coredns-29cb00aada276ad99e4f3aef380de9e68f2ebae8.tar.zst
coredns-29cb00aada276ad99e4f3aef380de9e68f2ebae8.zip
Remove grpc watch functionality (#2549)
This was added, but didn't see any use. For a large, complex chunk of code we should have some users of it. Remove all watch functionally from plugins, servers and packages. Fixes: #2548 Signed-off-by: Miek Gieben <miek@miek.nl>
Diffstat (limited to 'plugin/kubernetes/watch_test.go')
-rw-r--r--plugin/kubernetes/watch_test.go53
1 files changed, 0 insertions, 53 deletions
diff --git a/plugin/kubernetes/watch_test.go b/plugin/kubernetes/watch_test.go
deleted file mode 100644
index 08eda894b..000000000
--- a/plugin/kubernetes/watch_test.go
+++ /dev/null
@@ -1,53 +0,0 @@
-package kubernetes
-
-import (
- "strconv"
- "strings"
- "testing"
-
- "github.com/coredns/coredns/plugin/kubernetes/object"
-)
-
-func endpointSubsets(addrs ...string) (eps []object.EndpointSubset) {
- for _, ap := range addrs {
- apa := strings.Split(ap, ":")
- address := apa[0]
- port, _ := strconv.Atoi(apa[1])
- eps = append(eps, object.EndpointSubset{Addresses: []object.EndpointAddress{{IP: address}}, Ports: []object.EndpointPort{{Port: int32(port)}}})
- }
- return eps
-}
-
-func TestEndpointsSubsetDiffs(t *testing.T) {
- var tests = []struct {
- a, b, expected object.Endpoints
- }{
- { // From a->b: Nothing changes
- object.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")},
- object.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")},
- object.Endpoints{},
- },
- { // From a->b: Everything goes away
- object.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")},
- object.Endpoints{},
- object.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")},
- },
- { // From a->b: Everything is new
- object.Endpoints{},
- object.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")},
- object.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")},
- },
- { // From a->b: One goes away, one is new
- object.Endpoints{Subsets: endpointSubsets("10.0.0.2:8080")},
- object.Endpoints{Subsets: endpointSubsets("10.0.0.1:80")},
- object.Endpoints{Subsets: endpointSubsets("10.0.0.2:8080", "10.0.0.1:80")},
- },
- }
-
- for i, te := range tests {
- got := endpointsSubsetDiffs(&te.a, &te.b)
- if !endpointsEquivalent(got, &te.expected) {
- t.Errorf("Expected '%v' for test %v, got '%v'.", te.expected, i, got)
- }
- }
-}