diff options
author | 2017-09-12 10:52:43 +0100 | |
---|---|---|
committer | 2017-09-12 10:52:43 +0100 | |
commit | 3e252deabbfd9f0f384df4bf7b3847e9442f0b9f (patch) | |
tree | efc796384a2c0c961e4e3914cf663e3aa2d5594d /test/etcd_cache_test.go | |
parent | c2105a4f41132286e3145872fc187ab4e75a24b4 (diff) | |
download | coredns-3e252deabbfd9f0f384df4bf7b3847e9442f0b9f.tar.gz coredns-3e252deabbfd9f0f384df4bf7b3847e9442f0b9f.tar.zst coredns-3e252deabbfd9f0f384df4bf7b3847e9442f0b9f.zip |
Remove debug queries (#1058)
* Remove debug from interface and methods
* remove debug queries from etcd
* remove debug queries from k8s - they were not used
* And remove from mw/proxy-google as well
* Remove debug query test
Diffstat (limited to 'test/etcd_cache_test.go')
-rw-r--r-- | test/etcd_cache_test.go | 77 |
1 files changed, 77 insertions, 0 deletions
diff --git a/test/etcd_cache_test.go b/test/etcd_cache_test.go new file mode 100644 index 000000000..db283e73e --- /dev/null +++ b/test/etcd_cache_test.go @@ -0,0 +1,77 @@ +// +build etcd + +package test + +import ( + "io/ioutil" + "log" + "testing" + + "github.com/coredns/coredns/middleware/etcd/msg" + "github.com/coredns/coredns/middleware/proxy" + "github.com/coredns/coredns/middleware/test" + "github.com/coredns/coredns/request" + + "github.com/miekg/dns" + "golang.org/x/net/context" +) + +// uses some stuff from etcd_tests.go + +func TestEtcdCache(t *testing.T) { + corefile := `.:0 { + etcd skydns.test { + path /skydns + } + cache skydns.test +}` + + ex, udp, _, err := CoreDNSServerAndPorts(corefile) + if err != nil { + t.Fatalf("Could not get CoreDNS serving instance: %s", err) + } + defer ex.Stop() + + etc := etcdMiddleware() + log.SetOutput(ioutil.Discard) + + var ctx = context.TODO() + for _, serv := range servicesCacheTest { + set(ctx, t, etc, serv.Key, 0, serv) + defer delete(ctx, t, etc, serv.Key) + } + + p := proxy.NewLookup([]string{udp}) + state := request.Request{W: &test.ResponseWriter{}, Req: new(dns.Msg)} + + resp, err := p.Lookup(state, "b.example.skydns.test.", dns.TypeA) + if err != nil { + t.Errorf("Expected to receive reply, but didn't: %s", err) + } + checkResponse(t, resp) + + resp, err = p.Lookup(state, "b.example.skydns.test.", dns.TypeA) + if err != nil { + t.Errorf("Expected to receive reply, but didn't: %s", err) + } + checkResponse(t, resp) + if len(resp.Extra) != 0 { + t.Errorf("Expected no RRs in additional section, got: %d", len(resp.Extra)) + } +} + +func checkResponse(t *testing.T, resp *dns.Msg) { + if len(resp.Answer) == 0 { + t.Fatal("Expected to at least one RR in the answer section, got none") + } + if resp.Answer[0].Header().Rrtype != dns.TypeA { + t.Errorf("Expected RR to A, got: %d", resp.Answer[0].Header().Rrtype) + } + if resp.Answer[0].(*dns.A).A.String() != "127.0.0.1" { + t.Errorf("Expected 127.0.0.1, got: %d", resp.Answer[0].(*dns.A).A.String()) + } +} + +var servicesCacheTest = []*msg.Service{ + {Host: "127.0.0.1", Port: 666, Key: "b.example.skydns.test."}, +} |