add grv counter metrics

Author: pboros

metrics/group_processes.go

@@ -102,6 +102,12 @@ func (p *ProcessesMetricGroup) getLatencyTags(processName string, process *model
 	return tags
 }
 
+func (p *ProcessesMetricGroup) getTagsWithPriority(processName string, process *models.Process, priority string) map[string]string {
+	tags := p.getTags(processName, process)
+	tags["priority"] = priority
+	return tags
+}
+
 func (p *ProcessesMetricGroup) getLatencyTagsWithPriority(processName string, process *models.Process, quantile string, priority string) map[string]string {
 	tags := p.getLatencyTags(processName, process, quantile)
 	tags["priority"] = priority
@@ -171,7 +177,12 @@ func (p *ProcessesMetricGroup) GetMetrics(status *models.FullStatus) {
 			switch role.Role {
 			case "grv_proxy":
 				if role.GrvLatencyStatistics != nil {
+					grvCountScope := p.GetScopeOrExit("grv")
 					grvLatScope := p.GetScopeOrExit("grv_lat")
+					defaultCountTags := p.getTagsWithPriority(processName, &process, "default")
+					batchCountTags := p.getTagsWithPriority(processName, &process, "batch")
+					SetGauge(grvCountScope, "count", defaultCountTags, role.GrvLatencyStatistics.Default.Count)
+					SetGauge(grvCountScope, "count", batchCountTags, role.GrvLatencyStatistics.Batch.Count)
 					defaultMedianTags := p.getLatencyTagsWithPriority(processName, &process, "0.5", "default")
 					batchMedianTags := p.getLatencyTagsWithPriority(processName, &process, "0.5", "batch")
 					SetGauge(grvLatScope, "latency", defaultMedianTags, role.GrvLatencyStatistics.Default.Median)