Merge pull request #178 from checkr/zz/add-kafka-data-recorder-incr

Add kafka data recorder dd metrics
openflagr · Oct 10, 2018 · 3b41d74 · 3b41d74
2 parents 8c5b3a5 + fdcb664
commit 3b41d74
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/pkg/handler/data_recorder_kafka.go b/pkg/handler/data_recorder_kafka.go
@@ -5,6 +5,7 @@ import (
 	"crypto/x509"
 	"encoding/base64"
 	"encoding/json"
+	"fmt"
 	"io/ioutil"
 	"strings"
 	"time"
@@ -106,6 +107,21 @@ func (k *kafkaRecorder) AsyncRecord(r *models.EvalResult) {
 		Value:     kr,
 		Timestamp: time.Now().UTC(),
 	}
+
+	logKafkaAsyncRecordToDatadog(r)
+}
+
+var logKafkaAsyncRecordToDatadog = func(r *models.EvalResult) {
+	if config.Global.StatsdClient == nil {
+		return
+	}
+	config.Global.StatsdClient.Incr(
+		"data_recorder.kafka",
+		[]string{
+			fmt.Sprintf("FlagID:%d", util.SafeUint(r.FlagID)),
+		},
+		float64(1),
+	)
 }
 
 type kafkaEvalResult struct {