moira

1
package metrics
2

3
type NotifierMetrics struct {
4
	SubsMalformed          *Bucket
5
	EventsReceived         *Bucket
6
	EventsMalformed        *Bucket
7
	EventsProcessingFailed *Bucket
8
	SendingFailed          *Bucket
9
	SendersOkMetrics       *Map
10
	SendersFailedMetrics   *Map
11
}
12

13
func NewNotifierMetrics() *NotifierMetrics {
14
	subsMalformed, _ := NewBucket("notifier.subs.malformed")
15
	eventsReceived, _ := NewBucket("notifier.events.received")
16
	eventsMalformed, _ := NewBucket("notifier.events.malformed")
17
	eventsProcessingFailed, _ := NewBucket("notifier.events.failed")
18
	sendingFailed, _ := NewBucket("notifier.sending.failed")
19
	senderOkMetrics := newMap()
20
	senderFailedMetrics := newMap()
21

22
	return &NotifierMetrics{
23
		SubsMalformed:          subsMalformed,
24
		EventsReceived:         eventsReceived,
25
		EventsMalformed:        eventsMalformed,
26
		EventsProcessingFailed: eventsProcessingFailed,
27
		SendingFailed:          sendingFailed,
28
		SendersOkMetrics:       senderOkMetrics,
29
		SendersFailedMetrics:   senderFailedMetrics,
30
	}
31
}
32