aboutsummaryrefslogtreecommitdiff
path: root/test/etcd_cache_test.go
diff options
context:
space:
mode:
authorGravatar Miek Gieben <miek@miek.nl> 2017-09-12 10:52:43 +0100
committerGravatar GitHub <noreply@github.com> 2017-09-12 10:52:43 +0100
commit3e252deabbfd9f0f384df4bf7b3847e9442f0b9f (patch)
treeefc796384a2c0c961e4e3914cf663e3aa2d5594d /test/etcd_cache_test.go
parentc2105a4f41132286e3145872fc187ab4e75a24b4 (diff)
downloadcoredns-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.go77
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."},
+}