feat: add metrics for sqs api calls

soerenschneider · Mar 16, 2024 · 476c42a · 476c42a
1 parent 124f217
commit 476c42a
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/client/sqs_dispatch.go b/client/sqs_dispatch.go
@@ -11,6 +11,7 @@ import (
 	"github.com/rs/zerolog/log"
 	"github.com/soerenschneider/dyndns/conf"
 	"github.com/soerenschneider/dyndns/internal/common"
+	"github.com/soerenschneider/dyndns/internal/metrics"
 )
 
 type SqsDispatch struct {
@@ -43,6 +44,7 @@ func (h *SqsDispatch) Notify(msg *common.UpdateRecordRequest) error {
 
 	// TODO: change interface signature
 	ctx := context.Background()
+	metrics.SqsApiCalls.WithLabelValues("send_message").Inc()
 	result, err := h.client.SendMessageWithContext(ctx, &sqs.SendMessageInput{
 		MessageBody:  aws.String(string(data)),
 		QueueUrl:     aws.String(h.queueUrl),

diff --git a/internal/metrics/metrics_common.go b/internal/metrics/metrics_common.go
@@ -56,6 +56,13 @@ var (
 		Namespace: namespace,
 		Name:      "notification_errors",
 	})
+
+	SqsApiCalls = promauto.NewCounterVec(prometheus.CounterOpts{
+		Namespace: namespace,
+		Subsystem: "sqs",
+		Help:      "The total amount of SQS API calls",
+		Name:      "api_calls_total",
+	}, []string{"operation"})
 )
 
 func StartMetricsServer(addr string) {