diff options
author | 2018-11-01 15:56:00 -0400 | |
---|---|---|
committer | 2018-11-01 19:56:00 +0000 | |
commit | 05204ef14253de13c18b8442c2b04dd03345d98b (patch) | |
tree | 1050182126f5c9288e59aeb8aa7275a47935bdea /plugin/metrics/metrics.go | |
parent | f5aa6cac67d65357dfa81f39f3ef33e57a376795 (diff) | |
download | coredns-05204ef14253de13c18b8442c2b04dd03345d98b.tar.gz coredns-05204ef14253de13c18b8442c2b04dd03345d98b.tar.zst coredns-05204ef14253de13c18b8442c2b04dd03345d98b.zip |
Metrics registered on wrong prometheus registry (#2246)
* - UT on metrics verifying that all plugins of all blocs have their metrics collectors declared
* - fix error msg
* - redirect Registry of metric to the one that handle the listener
- allow duplicate of metrics collector on the same Registry (case of same plugin in 2 blocs listening metrics on the same address)
* - fix change of signature
* - ensure cleaning metrics before starting the test (metrics collectors are global vars .. and re-used by several tests)
* - I think I fixed this test. Ensure correct mn of hits and clean metrics before test.
* - fix typo in error msg - proposed at review
* - fix typo in comment
* - remove ResetMetrics functions
- change a way to test the numeric metrics : get the diff between begin and end of test
* - oops. removing debug logs
Diffstat (limited to 'plugin/metrics/metrics.go')
-rw-r--r-- | plugin/metrics/metrics.go | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/plugin/metrics/metrics.go b/plugin/metrics/metrics.go index 8efeff1e7..6b496cccc 100644 --- a/plugin/metrics/metrics.go +++ b/plugin/metrics/metrics.go @@ -57,7 +57,15 @@ func New(addr string) *Metrics { } // MustRegister wraps m.Reg.MustRegister. -func (m *Metrics) MustRegister(c prometheus.Collector) { m.Reg.MustRegister(c) } +func (m *Metrics) MustRegister(c prometheus.Collector) { + err := m.Reg.Register(c) + if err != nil { + // ignore any duplicate error, but fatal on any other kind of error + if _, ok := err.(prometheus.AlreadyRegisteredError); !ok { + log.Fatalf("Cannot register metrics collector: %s", err) + } + } +} // AddZone adds zone z to m. func (m *Metrics) AddZone(z string) { |