aboutsummaryrefslogtreecommitdiff
path: root/middleware/federation/setup.go
diff options
context:
space:
mode:
Diffstat (limited to 'middleware/federation/setup.go')
-rw-r--r--middleware/federation/setup.go89
1 files changed, 0 insertions, 89 deletions
diff --git a/middleware/federation/setup.go b/middleware/federation/setup.go
deleted file mode 100644
index 1ef635603..000000000
--- a/middleware/federation/setup.go
+++ /dev/null
@@ -1,89 +0,0 @@
-package federation
-
-import (
- "fmt"
-
- "github.com/coredns/coredns/core/dnsserver"
- "github.com/coredns/coredns/middleware"
- "github.com/coredns/coredns/middleware/kubernetes"
- "github.com/miekg/dns"
-
- "github.com/mholt/caddy"
-)
-
-func init() {
- caddy.RegisterPlugin("federation", caddy.Plugin{
- ServerType: "dns",
- Action: setup,
- })
-}
-
-func setup(c *caddy.Controller) error {
- fed, err := federationParse(c)
- if err != nil {
- return middleware.Error("federation", err)
- }
-
- // Do this in OnStartup, so all middleware has been initialized.
- c.OnStartup(func() error {
- m := dnsserver.GetConfig(c).Handler("kubernetes")
- if m == nil {
- return nil
- }
- if x, ok := m.(*kubernetes.Kubernetes); ok {
- fed.Federations = x.Federations
- }
- return nil
- })
-
- dnsserver.GetConfig(c).AddMiddleware(func(next middleware.Handler) middleware.Handler {
- fed.Next = next
- return fed
- })
-
- return nil
-}
-
-func federationParse(c *caddy.Controller) (*Federation, error) {
- fed := New()
-
- for c.Next() {
- // federation [zones..]
- zones := c.RemainingArgs()
- origins := []string{}
- if len(zones) > 0 {
- origins = make([]string, len(zones))
- copy(origins, zones)
- } else {
- origins = make([]string, len(c.ServerBlockKeys))
- copy(origins, c.ServerBlockKeys)
- }
-
- for c.NextBlock() {
- x := c.Val()
- switch x {
- default:
- args := c.RemainingArgs()
- if x := len(args); x != 1 {
- return fed, fmt.Errorf("need two arguments for federation, got %d", x)
- }
-
- fed.f[x] = dns.Fqdn(args[0])
- }
- }
-
- for i := range origins {
- origins[i] = middleware.Host(origins[i]).Normalize()
- }
-
- fed.zones = origins
-
- if len(fed.f) == 0 {
- return fed, fmt.Errorf("at least one name to zone federation expected")
- }
-
- return fed, nil
- }
-
- return fed, nil
-}