status-im
/
consul
mirror of https://github.com/status-im/consul.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Adds telemetry on number of DNS queries served, per-agent.

This commit is contained in:
James Phillips 2015-12-21 17:01:28 -08:00
parent 3a619ff4bf
commit a4dc11167f
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
command/agent/dns.go
View File

@ -9,6 +9,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/armon/go-metrics"
"github.com/hashicorp/consul/consul" "github.com/hashicorp/consul/consul"
"github.com/hashicorp/consul/consul/structs" "github.com/hashicorp/consul/consul/structs"
"github.com/miekg/dns" "github.com/miekg/dns"
@ -221,6 +222,8 @@ func (d *DNSServer) handlePtr(resp dns.ResponseWriter, req *dns.Msg) {
if err := resp.WriteMsg(m); err != nil { if err := resp.WriteMsg(m); err != nil {
d.logger.Printf("[WARN] dns: failed to respond: %v", err) d.logger.Printf("[WARN] dns: failed to respond: %v", err)
} }
metrics.IncrCounter([]string{"consul", "dns", "query", d.agent.config.NodeName}, 1)
} }
// handleQuery is used to handle DNS queries in the configured domain // handleQuery is used to handle DNS queries in the configured domain
@ -256,6 +259,8 @@ func (d *DNSServer) handleQuery(resp dns.ResponseWriter, req *dns.Msg) {
if err := resp.WriteMsg(m); err != nil { if err := resp.WriteMsg(m); err != nil {
d.logger.Printf("[WARN] dns: failed to respond: %v", err) d.logger.Printf("[WARN] dns: failed to respond: %v", err)
} }
metrics.IncrCounter([]string{"consul", "dns", "query", d.agent.config.NodeName}, 1)
} }
// addSOA is used to add an SOA record to a message for the given domain // addSOA is used to add an SOA record to a message for the given domain