diff options
author | 2019-08-18 14:41:51 -0700 | |
---|---|---|
committer | 2019-08-18 14:41:51 -0700 | |
commit | 6402cef3371b6a5716dd032e2484d865cf25338a (patch) | |
tree | 3d53847a82db477f9e2e8dea16b0015d5695703e /plugin/federation/federation_test.go | |
parent | bbf148360b2bd35b9a1e358fdf7984a33b15a8d5 (diff) | |
download | coredns-6402cef3371b6a5716dd032e2484d865cf25338a.tar.gz coredns-6402cef3371b6a5716dd032e2484d865cf25338a.tar.zst coredns-6402cef3371b6a5716dd032e2484d865cf25338a.zip |
Move federation plugin to github.com/coredns/federation (#3139)
* Remove federation
Signed-off-by: Yong Tang <yong.tang.github@outlook.com>
* Rebuild and point to github.com/coredns/federation
Signed-off-by: Yong Tang <yong.tang.github@outlook.com>
* Export `localNodeName` => `LocalNodeName`, to be used by federation (until deprecation)
Signed-off-by: Yong Tang <yong.tang.github@outlook.com>
* Remove plugin/kubernetes/federation.go (=> kubernetes/federation repo)
Signed-off-by: Yong Tang <yong.tang.github@outlook.com>
* Update github.com/coredns/federation
Signed-off-by: Yong Tang <yong.tang.github@outlook.com>
* sticker-ci fix
Signed-off-by: Yong Tang <yong.tang.github@outlook.com>
Diffstat (limited to 'plugin/federation/federation_test.go')
-rw-r--r-- | plugin/federation/federation_test.go | 119 |
1 files changed, 0 insertions, 119 deletions
diff --git a/plugin/federation/federation_test.go b/plugin/federation/federation_test.go deleted file mode 100644 index 64d6272b7..000000000 --- a/plugin/federation/federation_test.go +++ /dev/null @@ -1,119 +0,0 @@ -package federation - -import ( - "context" - "testing" - - "github.com/coredns/coredns/plugin/kubernetes" - "github.com/coredns/coredns/plugin/pkg/dnstest" - "github.com/coredns/coredns/plugin/test" - - "github.com/miekg/dns" -) - -func TestIsNameFederation(t *testing.T) { - tests := []struct { - fed string - qname string - expectedZone string - }{ - {"prod", "nginx.mynamespace.prod.svc.example.com.", "nginx.mynamespace.svc.example.com."}, - {"prod", "nginx.mynamespace.staging.svc.example.com.", ""}, - {"prod", "nginx.mynamespace.example.com.", ""}, - {"prod", "example.com.", ""}, - {"prod", "com.", ""}, - } - - fed := New() - for i, tc := range tests { - fed.f[tc.fed] = "test-name" - if x, _ := fed.isNameFederation(tc.qname, "example.com."); x != tc.expectedZone { - t.Errorf("Test %d, failed to get zone, expected %s, got %s", i, tc.expectedZone, x) - } - } -} - -func TestFederationKubernetes(t *testing.T) { - tests := []test.Case{ - { - // service exists so we return the IP address associated with it. - Qname: "svc1.testns.prod.svc.cluster.local.", Qtype: dns.TypeA, - Rcode: dns.RcodeSuccess, - Answer: []dns.RR{ - test.A("svc1.testns.prod.svc.cluster.local. 303 IN A 10.0.0.1"), - }, - }, - { - // service does not exist, do the federation dance. - Qname: "svc0.testns.prod.svc.cluster.local.", Qtype: dns.TypeA, - Rcode: dns.RcodeSuccess, - Answer: []dns.RR{ - test.CNAME("svc0.testns.prod.svc.cluster.local. 303 IN CNAME svc0.testns.prod.svc.fd-az.fd-r.federal.example."), - }, - }, - } - - k := kubernetes.New([]string{"cluster.local."}) - k.APIConn = &APIConnFederationTest{zone: "fd-az", region: "fd-r"} - - fed := New() - fed.zones = []string{"cluster.local."} - fed.Federations = k.Federations - fed.Next = k - fed.f = map[string]string{ - "prod": "federal.example.", - } - - ctx := context.TODO() - for i, tc := range tests { - m := tc.Msg() - - rec := dnstest.NewRecorder(&test.ResponseWriter{}) - _, err := fed.ServeDNS(ctx, rec, m) - if err != nil { - t.Errorf("Test %d, expected no error, got %v", i, err) - return - } - - resp := rec.Msg - if err := test.SortAndCheck(resp, tc); err != nil { - t.Error(err) - } - } -} - -func TestFederationKubernetesMissingLabels(t *testing.T) { - tests := []test.Case{ - { - // service does not exist, do the federation dance. - Qname: "svc0.testns.prod.svc.cluster.local.", Qtype: dns.TypeA, - Rcode: dns.RcodeSuccess, - Answer: []dns.RR{ - test.CNAME("svc0.testns.prod.svc.cluster.local. 303 IN CNAME svc0.testns.prod.svc.fd-az.fd-r.federal.example."), - }, - }, - } - - k := kubernetes.New([]string{"cluster.local."}) - k.APIConn = &APIConnFederationTest{zone: "", region: ""} - - fed := New() - fed.zones = []string{"cluster.local."} - fed.Federations = k.Federations - fed.Next = k - fed.f = map[string]string{ - "prod": "federal.example.", - } - - ctx := context.TODO() - for _, tc := range tests { - m := tc.Msg() - - rec := dnstest.NewRecorder(&test.ResponseWriter{}) - _, err := fed.ServeDNS(ctx, rec, m) - if err == nil { - t.Errorf("Expected an error") - return - } - } -} |