diff options
Diffstat (limited to 'plugin/proxy/dnstap.go')
-rw-r--r-- | plugin/proxy/dnstap.go | 56 |
1 files changed, 0 insertions, 56 deletions
diff --git a/plugin/proxy/dnstap.go b/plugin/proxy/dnstap.go deleted file mode 100644 index 4e5a8bd40..000000000 --- a/plugin/proxy/dnstap.go +++ /dev/null @@ -1,56 +0,0 @@ -package proxy - -import ( - "context" - "time" - - "github.com/coredns/coredns/plugin/dnstap" - "github.com/coredns/coredns/plugin/dnstap/msg" - "github.com/coredns/coredns/request" - - tap "github.com/dnstap/golang-dnstap" - "github.com/miekg/dns" -) - -func toDnstap(ctx context.Context, host string, ex Exchanger, state request.Request, reply *dns.Msg, start time.Time) error { - tapper := dnstap.TapperFromContext(ctx) - if tapper == nil { - return nil - } - - // Query - b := msg.New().Time(start).HostPort(host) - - t := ex.Transport() - if t == "" { - t = state.Proto() - } - if t == "tcp" { - b.SocketProto = tap.SocketProtocol_TCP - } else { - b.SocketProto = tap.SocketProtocol_UDP - } - - if tapper.Pack() { - b.Msg(state.Req) - } - m, err := b.ToOutsideQuery(tap.Message_FORWARDER_QUERY) - if err != nil { - return err - } - tapper.TapMessage(m) - - // Response - if reply != nil { - if tapper.Pack() { - b.Msg(reply) - } - m, err := b.Time(time.Now()).ToOutsideResponse(tap.Message_FORWARDER_RESPONSE) - if err != nil { - return err - } - tapper.TapMessage(m) - } - - return nil -} |