mirrors/external-dns
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/external-dns.git synced 2026-05-04 14:21:33 +02:00
Code Issues Packages Projects Releases Wiki Activity

ref(controller): namespace exposed metrics with the external_dns prefix

Browse Source
This commit is contained in:
Martin Linkhorst 2018-11-28 15:20:53 +01:00
parent aa9e7df1dd
commit b2601c19a7
No known key found for this signature in database
GPG Key ID: CBE9EF3F75BAA5FD
1 changed files with 15 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
controller/controller.go
View File

@ -28,23 +28,27 @@ import (
)
var (
registryErrors = prometheus.NewCounter(
registryErrorsTotal = prometheus.NewCounter(
prometheus.CounterOpts{
Name: "registry_errors_total",
Help: "Number of Registry errors.",
Namespace: "external_dns",
Subsystem: "registry",
Name: "errors_total",
Help: "Number of Registry errors.",
},
)
sourceErrors = prometheus.NewCounter(
sourceErrorsTotal = prometheus.NewCounter(
prometheus.CounterOpts{
Name: "source_errors_total",
Help: "Number of Source errors.",
Namespace: "external_dns",
Subsystem: "source",
Name: "errors_total",
Help: "Number of Source errors.",
},
)
)
func init() {
prometheus.MustRegister(registryErrors)
prometheus.MustRegister(sourceErrors)
prometheus.MustRegister(registryErrorsTotal)
prometheus.MustRegister(sourceErrorsTotal)
}
// Controller is responsible for orchestrating the different components.
@ -66,13 +70,13 @@ type Controller struct {
func (c *Controller) RunOnce() error {
records, err := c.Registry.Records()
if err != nil {
registryErrors.Inc()
registryErrorsTotal.Inc()
return err
}
endpoints, err := c.Source.Endpoints()
if err != nil {
sourceErrors.Inc()
sourceErrorsTotal.Inc()
return err
}
@ -86,7 +90,7 @@ func (c *Controller) RunOnce() error {
err = c.Registry.ApplyChanges(plan.Changes)
if err != nil {
registryErrors.Inc()
registryErrorsTotal.Inc()
return err
}
return nil