telemetry-gateway: add processed events counter (#57205)

Author: bobheadxi

cmd/telemetry-gateway/internal/server/metrics.go

@@ -17,8 +17,8 @@ type recordEventsMetrics struct {
 type recordEventsRequestPayloadMetrics struct {
 	// Record event length of individual payloads
 	length metric.Int64Histogram
-	// Count number of failedEvents
-	failedEvents metric.Int64Counter
+	// Count of processed events
+	processedEvents metric.Int64Counter
 }
 
 func newRecordEventsMetrics() (m recordEventsMetrics, err error) {
@@ -35,9 +35,9 @@ func newRecordEventsMetrics() (m recordEventsMetrics, err error) {
 	if err != nil {
 		return m, err
 	}
-	m.payload.failedEvents, err = meter.Int64Counter(
-		"telemetry-gateway.record_events.payload_failed_events_count",
-		metric.WithDescription("Number of events that failed to submit in indvidiual record_events request payloads"))
+	m.payload.processedEvents, err = meter.Int64Counter(
+		"telemetry-gateway.record_events.processed_events",
+		metric.WithDescription("Number of events processed"))
 	if err != nil {
 		return m, err
 	}

cmd/telemetry-gateway/internal/server/publish_events.go

@@ -40,8 +40,10 @@ func handlePublishEvents(
 	tr.SetAttributes(resultAttribute)
 	payloadMetrics.length.Record(ctx, int64(len(events)),
 		metric.WithAttributes(resultAttribute))
-	payloadMetrics.failedEvents.Add(ctx, int64(len(summary.failedEvents)),
-		metric.WithAttributes(resultAttribute))
+	payloadMetrics.processedEvents.Add(ctx, int64(len(summary.succeededEvents)),
+		metric.WithAttributes(attribute.Bool("succeeded", true), resultAttribute))
+	payloadMetrics.processedEvents.Add(ctx, int64(len(summary.failedEvents)),
+		metric.WithAttributes(attribute.Bool("succeeded", false), resultAttribute))
 
 	// Generate a log message for convenience
 	summaryFields := []log.Field{