diff options
author | 2019-02-11 14:46:53 +0000 | |
---|---|---|
committer | 2019-02-11 14:46:53 +0000 | |
commit | 29cb00aada276ad99e4f3aef380de9e68f2ebae8 (patch) | |
tree | 5f8425b59111f1154bd87bfa8917f6add807cace /plugin/kubernetes/watch_test.go | |
parent | f69819387dcb69234adcda08b0af1af97b84f76e (diff) | |
download | coredns-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.go | 53 |
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) - } - } -} |