1 files changed, 55 insertions, 0 deletions
diff --git a/plugin/metadata/metadata.go b/plugin/metadata/metadata.go
new file mode 100644
index 000000000..1e840d3fd
--- /dev/null
+++ b/plugin/metadata/metadata.go
@@ -0,0 +1,55 @@
+package metadata
+
+import (
+	"context"
+
+	"github.com/coredns/coredns/plugin"
+	"github.com/coredns/coredns/plugin/pkg/variables"
+	"github.com/coredns/coredns/request"
+
+	"github.com/miekg/dns"
+)
+
+// Metadata implements collecting metadata information from all plugins that
+// implement the Provider interface.
+type Metadata struct {
+	Zones     []string
+	Providers []Provider
+	Next      plugin.Handler
+}
+
+// Name implements the Handler interface.
+func (m *Metadata) Name() string { return "metadata" }
+
+// ServeDNS implements the plugin.Handler interface.
+func (m *Metadata) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error) {
+
+	md, ctx := newMD(ctx)
+
+	state := request.Request{W: w, Req: r}
+	if plugin.Zones(m.Zones).Matches(state.Name()) != "" {
+		// Go through all Providers and collect metadata
+		for _, provider := range m.Providers {
+			for _, varName := range provider.MetadataVarNames() {
+				if val, ok := provider.Metadata(ctx, w, r, varName); ok {
+					md.setValue(varName, val)
+				}
+			}
+		}
+	}
+
+	rcode, err := plugin.NextOrFailure(m.Name(), m.Next, ctx, w, r)
+
+	return rcode, err
+}
+
+// MetadataVarNames implements the plugin.Provider interface.
+func (m *Metadata) MetadataVarNames() []string { return variables.All }
+
+// Metadata implements the plugin.Provider interface.
+func (m *Metadata) Metadata(ctx context.Context, w dns.ResponseWriter, r *dns.Msg, varName string) (interface{}, bool) {
+	if val, err := variables.GetValue(varName, w, r); err == nil {
+		return val, true
+	}
+	return nil, false
+}