adelorenzo/kilo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

pkg/mesh: introduce kilo_leader guage metric

Browse Source 
This commit introduces a new Prometheus metric to detect if the node is
a leader of its location, from its own point of view.

Signed-off-by: Lucas Servén Marín <lserven@gmail.com>
This commit is contained in:
Lucas Servén Marín 2020-05-25 10:16:50 +02:00
parent 9b19bbe69c
commit 82c819659d
No known key found for this signature in database
GPG Key ID: 586FEAF680DA74AD
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/mesh/mesh.go
View File

@ -202,6 +202,7 @@ type Mesh struct {
mu sync.Mutex mu sync.Mutex
errorCounter *prometheus.CounterVec errorCounter *prometheus.CounterVec
leaderGuage prometheus.Gauge
nodesGuage prometheus.Gauge nodesGuage prometheus.Gauge
peersGuage prometheus.Gauge peersGuage prometheus.Gauge
reconcileCounter prometheus.Counter reconcileCounter prometheus.Counter
@ -282,6 +283,10 @@ func New(backend Backend, enc encapsulation.Encapsulator, granularity Granularit
Name: "kilo_errors_total", Name: "kilo_errors_total",
Help: "Number of errors that occurred while administering the mesh.", Help: "Number of errors that occurred while administering the mesh.",
}, []string{"event"}), }, []string{"event"}),
leaderGuage: prometheus.NewGauge(prometheus.GaugeOpts{
Name: "kilo_leader",
Help: "Leadership status of the node.",
}),
nodesGuage: prometheus.NewGauge(prometheus.GaugeOpts{ nodesGuage: prometheus.NewGauge(prometheus.GaugeOpts{
Name: "kilo_nodes", Name: "kilo_nodes",
Help: "Number of nodes in the mesh.", Help: "Number of nodes in the mesh.",
@ -620,6 +625,7 @@ func (m *Mesh) applyTopology() {
return return
} }
if t.leader { if t.leader {
m.leaderGuage.Set(1)
if err := iproute.SetAddress(m.kiloIface, t.wireGuardCIDR); err != nil { if err := iproute.SetAddress(m.kiloIface, t.wireGuardCIDR); err != nil {
level.Error(m.logger).Log("error", err) level.Error(m.logger).Log("error", err)
m.errorCounter.WithLabelValues("apply").Inc() m.errorCounter.WithLabelValues("apply").Inc()
@ -642,6 +648,7 @@ func (m *Mesh) applyTopology() {
return return
} }
} else { } else {
m.leaderGuage.Set(0)
level.Debug(m.logger).Log("msg", "local node is not the leader") level.Debug(m.logger).Log("msg", "local node is not the leader")
if err := iproute.Set(m.kiloIface, false); err != nil { if err := iproute.Set(m.kiloIface, false); err != nil {
level.Error(m.logger).Log("error", err) level.Error(m.logger).Log("error", err)
@ -663,6 +670,7 @@ func (m *Mesh) applyTopology() {
func (m *Mesh) RegisterMetrics(r prometheus.Registerer) { func (m *Mesh) RegisterMetrics(r prometheus.Registerer) {
r.MustRegister( r.MustRegister(
m.errorCounter, m.errorCounter,
m.leaderGuage,
m.nodesGuage, m.nodesGuage,
m.peersGuage, m.peersGuage,
m.reconcileCounter, m.reconcileCounter,