feat: add conn_group tag to server_processing_latency_millisecond

raystack · Oct 13, 2021 · 282b878 · 282b878
1 parent f1819bf
commit 282b878
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/docs/reference/metrics.md b/docs/reference/metrics.md
@@ -203,6 +203,7 @@ Duration from the time request is sent to the time events are published. This me
 Duration from the time request is receieved to the time events are published. This metric is calculated per event by following formula`(PublishedTime - ReceievedTime)/CountEvents`
 
 * Type: `Timing`
+* Tags: `conn_group=*`
 
 ### `worker_processing_duration_milliseconds`
 

diff --git a/worker/worker.go b/worker/worker.go
@@ -62,7 +62,7 @@ func (w *Pool) StartWorkers() {
 					metrics.Timing("event_processing_duration_milliseconds", eventTimingMs, fmt.Sprintf("conn_group=%s", request.ConnIdentifier.Group))
 					now := time.Now()
 					metrics.Timing("worker_processing_duration_milliseconds", (now.Sub(batchReadTime).Milliseconds())/lenBatch, "worker="+workerName)
-					metrics.Timing("server_processing_latency_milliseconds", (now.Sub(request.TimeConsumed)).Milliseconds()/lenBatch, "")
+					metrics.Timing("server_processing_latency_milliseconds", (now.Sub(request.TimeConsumed)).Milliseconds()/lenBatch, fmt.Sprintf("conn_group=%s", request.ConnIdentifier.Group))
 				}
 				metrics.Count("kafka_messages_delivered_total", totalErr, fmt.Sprintf("success=false,conn_group=%s", request.ConnIdentifier.Group))
 				metrics.Count("kafka_messages_delivered_total", len(request.EventReq.GetEvents())-totalErr, fmt.Sprintf("success=true,conn_group=%s", request.ConnIdentifier.Group))