diff options
Diffstat (limited to 'plugin/kubernetes/controller_test.go')
| -rw-r--r-- | plugin/kubernetes/controller_test.go | 46 |
1 files changed, 1 insertions, 45 deletions
diff --git a/plugin/kubernetes/controller_test.go b/plugin/kubernetes/controller_test.go index 1663e4c6a..99d7e92f7 100644 --- a/plugin/kubernetes/controller_test.go +++ b/plugin/kubernetes/controller_test.go @@ -4,10 +4,10 @@ import ( "context" "net" "strconv" - "strings" "testing" "github.com/coredns/coredns/plugin/test" + "github.com/miekg/dns" api "k8s.io/api/core/v1" meta "k8s.io/apimachinery/pkg/apis/meta/v1" @@ -15,50 +15,6 @@ import ( "k8s.io/client-go/kubernetes/fake" ) -func endpointSubsets(addrs ...string) (eps []api.EndpointSubset) { - for _, ap := range addrs { - apa := strings.Split(ap, ":") - address := apa[0] - port, _ := strconv.Atoi(apa[1]) - eps = append(eps, api.EndpointSubset{Addresses: []api.EndpointAddress{{IP: address}}, Ports: []api.EndpointPort{{Port: int32(port)}}}) - } - return eps -} - -func TestEndpointsSubsetDiffs(t *testing.T) { - var tests = []struct { - a, b, expected api.Endpoints - }{ - { // From a->b: Nothing changes - api.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")}, - api.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")}, - api.Endpoints{}, - }, - { // From a->b: Everything goes away - api.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")}, - api.Endpoints{}, - api.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")}, - }, - { // From a->b: Everything is new - api.Endpoints{}, - api.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")}, - api.Endpoints{Subsets: endpointSubsets("10.0.0.1:80", "10.0.0.2:8080")}, - }, - { // From a->b: One goes away, one is new - api.Endpoints{Subsets: endpointSubsets("10.0.0.2:8080")}, - api.Endpoints{Subsets: endpointSubsets("10.0.0.1:80")}, - api.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) - } - } -} - func inc(ip net.IP) { for j := len(ip) - 1; j >= 0; j-- { ip[j]++ |