diff options
Diffstat (limited to 'middleware/kubernetes/reverse_test.go')
-rw-r--r-- | middleware/kubernetes/reverse_test.go | 125 |
1 files changed, 0 insertions, 125 deletions
diff --git a/middleware/kubernetes/reverse_test.go b/middleware/kubernetes/reverse_test.go deleted file mode 100644 index aaf0907e8..000000000 --- a/middleware/kubernetes/reverse_test.go +++ /dev/null @@ -1,125 +0,0 @@ -package kubernetes - -import ( - "testing" - - "github.com/coredns/coredns/middleware/pkg/dnsrecorder" - "github.com/coredns/coredns/middleware/test" - - "github.com/miekg/dns" - "golang.org/x/net/context" - "k8s.io/client-go/1.5/pkg/api" -) - -type APIConnReverseTest struct{} - -func (APIConnReverseTest) Run() { return } -func (APIConnReverseTest) Stop() error { return nil } -func (APIConnReverseTest) PodIndex(string) []interface{} { return nil } - -func (APIConnReverseTest) ServiceList() []*api.Service { - svcs := []*api.Service{ - { - ObjectMeta: api.ObjectMeta{ - Name: "svc1", - Namespace: "testns", - }, - Spec: api.ServiceSpec{ - ClusterIP: "192.168.1.100", - Ports: []api.ServicePort{{ - Name: "http", - Protocol: "tcp", - Port: 80, - }}, - }, - }, - } - return svcs -} - -func (APIConnReverseTest) EndpointsList() api.EndpointsList { - return api.EndpointsList{ - Items: []api.Endpoints{ - { - Subsets: []api.EndpointSubset{ - { - Addresses: []api.EndpointAddress{ - { - IP: "10.0.0.100", - Hostname: "ep1a", - }, - }, - Ports: []api.EndpointPort{ - { - Port: 80, - Protocol: "tcp", - Name: "http", - }, - }, - }, - }, - ObjectMeta: api.ObjectMeta{ - Name: "svc1", - Namespace: "testns", - }, - }, - }, - } -} - -func (APIConnReverseTest) GetNodeByName(name string) (api.Node, error) { - return api.Node{ - ObjectMeta: api.ObjectMeta{ - Name: "test.node.foo.bar", - }, - }, nil -} - -func TestReverse(t *testing.T) { - - k := New([]string{"cluster.local.", "0.10.in-addr.arpa."}) - k.APIConn = &APIConnReverseTest{} - - tests := []test.Case{ - { - Qname: "100.0.0.10.in-addr.arpa.", Qtype: dns.TypePTR, - Rcode: dns.RcodeSuccess, - Answer: []dns.RR{ - test.PTR("100.0.0.10.in-addr.arpa. 303 IN PTR ep1a.svc1.testns.svc.cluster.local."), - }, - }, - { - Qname: "101.0.0.10.in-addr.arpa.", Qtype: dns.TypePTR, - Rcode: dns.RcodeSuccess, - Ns: []dns.RR{ - test.SOA("0.10.in-addr.arpa. 300 IN SOA ns.dns.0.10.in-addr.arpa. hostmaster.0.10.in-addr.arpa. 1502782828 7200 1800 86400 60"), - }, - }, - { - Qname: "example.org.cluster.local.", Qtype: dns.TypePTR, - Rcode: dns.RcodeSuccess, - Ns: []dns.RR{ - test.SOA("cluster.local. 300 IN SOA ns.dns.cluster.local. hostmaster.cluster.local. 1502989566 7200 1800 86400 60"), - }, - }, - } - - ctx := context.TODO() - for i, tc := range tests { - r := tc.Msg() - - w := dnsrecorder.New(&test.ResponseWriter{}) - - _, err := k.ServeDNS(ctx, w, r) - if err != tc.Error { - t.Errorf("Test %d: expected no error, got %v", i, err) - return - } - - resp := w.Msg - if resp == nil { - t.Fatalf("Test %d: got nil message and no error for: %s %d", i, r.Question[0].Name, r.Question[0].Qtype) - } - test.SortAndCheck(t, resp, tc) - } -} |