123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869 |
- package example
- import (
- "fmt"
- "io"
- "os"
- "github.com/coredns/coredns/plugin"
- "github.com/coredns/coredns/plugin/metrics"
- clog "github.com/coredns/coredns/plugin/pkg/log"
- "github.com/miekg/dns"
- "golang.org/x/net/context"
- )
- var log = clog.NewWithPlugin("example")
- type Example struct {
- Next plugin.Handler
- }
- func (e Example) ServeDNS(ctx context.Context, w dns.ResponseWriter, r *dns.Msg) (int, error) {
-
-
-
-
-
- log.Debug("Received response")
-
- pw := NewResponsePrinter(w)
-
- requestCount.WithLabelValues(metrics.WithServer(ctx)).Inc()
-
- return plugin.NextOrFailure(e.Name(), e.Next, ctx, pw, r)
- }
- func (e Example) Name() string { return "example" }
- type ResponsePrinter struct {
- dns.ResponseWriter
- }
- func NewResponsePrinter(w dns.ResponseWriter) *ResponsePrinter {
- return &ResponsePrinter{ResponseWriter: w}
- }
- func (r *ResponsePrinter) WriteMsg(res *dns.Msg) error {
- fmt.Fprintln(out, "example")
- return r.ResponseWriter.WriteMsg(res)
- }
- var out io.Writer = os.Stdout
|