moira

1
package redis
2

3
import "github.com/garyburd/redigo/redis"
4

5
// UpdateMetricsHeartbeat increments redis counter
6
func (connector *DbConnector) UpdateMetricsHeartbeat() error {
7
	c := connector.pool.Get()
8
	defer c.Close()
9
	err := c.Send("INCR", selfStateMetricsHeartbeatKey)
10
	return err
11
}
12

13
// GetMetricsUpdatesCount return metrics count received by Moira-Filter
14
func (connector *DbConnector) GetMetricsUpdatesCount() (int64, error) {
15
	c := connector.pool.Get()
16
	defer c.Close()
17
	ts, err := redis.Int64(c.Do("GET", selfStateMetricsHeartbeatKey))
18
	if err == redis.ErrNil {
19
		return 0, nil
20
	}
21
	return ts, err
22
}
23

24
// GetChecksUpdatesCount return checks count by Moira-Checker
25
func (connector *DbConnector) GetChecksUpdatesCount() (int64, error) {
26
	c := connector.pool.Get()
27
	defer c.Close()
28
	ts, err := redis.Int64(c.Do("GET", selfStateChecksCounterKey))
29
	if err == redis.ErrNil {
30
		return 0, nil
31
	}
32
	return ts, err
33
}
34

35
var selfStateMetricsHeartbeatKey = "moira-selfstate:metrics-heartbeat"
36
var selfStateChecksCounterKey = "moira-selfstate:checks-counter"
37