aboutsummaryrefslogtreecommitdiff
path: root/plugin/federation/federation_test.go
diff options
context:
space:
mode:
authorGravatar Yong Tang <yong.tang.github@outlook.com> 2019-08-18 14:41:51 -0700
committerGravatar GitHub <noreply@github.com> 2019-08-18 14:41:51 -0700
commit6402cef3371b6a5716dd032e2484d865cf25338a (patch)
tree3d53847a82db477f9e2e8dea16b0015d5695703e /plugin/federation/federation_test.go
parentbbf148360b2bd35b9a1e358fdf7984a33b15a8d5 (diff)
downloadcoredns-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.go119
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
- }
- }
-}