Fix some of the stats exported. (#437)

Author: Bogdan Drutu

internal/collector/processor/nodebatcher/metrics.go

@@ -61,39 +61,39 @@ func MetricViews(level telemetry.Level) []*view.View {
 		Measure:     statNodesAddedToBatches,
 		Description: statNodesAddedToBatches.Description(),
 		TagKeys:     exporterTagKeys,
-		Aggregation: view.Count(),
+		Aggregation: view.Sum(),
 	}
 
 	nodesRemovedFromBatchesView := &view.View{
 		Name:        statNodesRemovedFromBatches.Name(),
 		Measure:     statNodesRemovedFromBatches,
 		Description: statNodesRemovedFromBatches.Description(),
 		TagKeys:     exporterTagKeys,
-		Aggregation: view.Count(),
+		Aggregation: view.Sum(),
 	}
 
 	countBatchSizeTriggerSendView := &view.View{
 		Name:        statBatchSizeTriggerSend.Name(),
 		Measure:     statBatchSizeTriggerSend,
 		Description: statBatchSizeTriggerSend.Description(),
 		TagKeys:     tagKeys,
-		Aggregation: view.Count(),
+		Aggregation: view.Sum(),
 	}
 
 	countTimeoutTriggerSendView := &view.View{
 		Name:        statTimeoutTriggerSend.Name(),
 		Measure:     statTimeoutTriggerSend,
 		Description: statTimeoutTriggerSend.Description(),
 		TagKeys:     tagKeys,
-		Aggregation: view.Count(),
+		Aggregation: view.Sum(),
 	}
 
 	countBatchOnDeadNode := &view.View{
 		Name:        statBatchOnDeadNode.Name(),
 		Measure:     statBatchOnDeadNode,
 		Description: statBatchOnDeadNode.Description(),
 		TagKeys:     tagKeys,
-		Aggregation: view.Count(),
+		Aggregation: view.Sum(),
 	}
 
 	return []*view.View{

internal/collector/processor/queued/queued_processor.go

@@ -112,10 +112,6 @@ func (sp *queuedSpanProcessor) Stop() {
 
 // ProcessSpans implements the SpanProcessor interface
 func (sp *queuedSpanProcessor) ProcessSpans(td data.TraceData, spanFormat string) error {
-	return sp.enqueueSpanBatch(td, spanFormat)
-}
-
-func (sp *queuedSpanProcessor) enqueueSpanBatch(td data.TraceData, spanFormat string) error {
 	item := &queueItem{
 		queuedTime: time.Now(),
 		td:         td,
@@ -232,14 +228,14 @@ func MetricViews(level telemetry.Level) []*view.View {
 		Measure:     statSuccessSendOps,
 		Description: "The number of successful send operations performed by queued exporter",
 		TagKeys:     tagKeys,
-		Aggregation: view.Count(),
+		Aggregation: view.Sum(),
 	}
 	countFailuresSendView := &view.View{
 		Name:        statFailedSendOps.Name(),
 		Measure:     statFailedSendOps,
 		Description: "The number of failed send operations performed by queued exporter",
 		TagKeys:     tagKeys,
-		Aggregation: view.Count(),
+		Aggregation: view.Sum(),
 	}
 
 	latencyDistributionAggregation := view.Distribution(10, 25, 50, 75, 100, 250, 500, 750, 1000, 2000, 3000, 4000, 5000, 10000, 20000, 30000, 50000)

internal/collector/telemetry/process_telemetry.go

@@ -31,7 +31,7 @@ var viewTotalAllocMem = &view.View{
 	Name:        mRuntimeTotalAllocMem.Name(),
 	Description: mRuntimeTotalAllocMem.Description(),
 	Measure:     mRuntimeTotalAllocMem,
-	Aggregation: view.Count(),
+	Aggregation: view.LastValue(),
 	TagKeys:     nil,
 }
 
@@ -49,7 +49,7 @@ var viewCPUSeconds = &view.View{
 	Name:        mCPUSeconds.Name(),
 	Description: mCPUSeconds.Description(),
 	Measure:     mCPUSeconds,
-	Aggregation: view.Count(),
+	Aggregation: view.LastValue(),
 	TagKeys:     nil,
 }