Skip to content

Commit 5eda5b6

Browse files
committed
Add a metric for total FCM messags send
1 parent 5d7f02d commit 5eda5b6

File tree

2 files changed

+10
-1
lines changed

2 files changed

+10
-1
lines changed

handler.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ func genericHandler(w http.ResponseWriter, req *http.Request, ps httprouter.Para
4646
topic := getParamTopic(ps)
4747
message := NewMessage(topic, data.Title, data.Body)
4848
msg, err := fcmClient.Send(req.Context(), message)
49+
fcmMessages.WithLabelValues(ps.MatchedRoutePath(), topic).Inc()
4950

5051
if err != nil {
5152
fcmErrors.WithLabelValues(ps.MatchedRoutePath(), topic).Inc()
@@ -115,6 +116,7 @@ func processFcmMessage(ctx context.Context, routePath, topic string, m *template
115116

116117
// Send a message to the devices subscribed to the topic.
117118
fcmResponse, err := fcmClient.Send(ctx, message)
119+
fcmMessages.WithLabelValues(routePath, topic).Inc()
118120
if err != nil {
119121
fcmErrors.WithLabelValues(routePath, topic).Inc()
120122
}

main.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,13 @@ var (
3030
},
3131
[]string{"type"},
3232
)
33+
fcmMessages = promauto.NewCounterVec(
34+
prometheus.CounterOpts{
35+
Name: "alertmanager_webhook_fcm_messages_total",
36+
Help: "Total number of messages seind to Firebase Cloud Messaging API.",
37+
},
38+
[]string{"handler", "topic"},
39+
)
3340
fcmErrors = promauto.NewCounterVec(
3441
prometheus.CounterOpts{
3542
Name: "alertmanager_webhook_fcm_errors_total",
@@ -45,7 +52,7 @@ func main() {
4552

4653
fcmClient, err = NewMessaging()
4754
if err != nil {
48-
log.Fatalf("error getting Messaging client. Do you have GOOGLE_APPLICATION_CREDENTIALS set?: %v\n", err)
55+
log.Fatalf("error getting Messaging client: %v\nDo you have GOOGLE_APPLICATION_CREDENTIALS set?\n", err)
4956
}
5057

5158
router := httprouter.New()

0 commit comments

Comments
 (0)