GoogleCloudExporter: Fix empty metrics StartTimestamp in datapoints

exporter/googlecloudexporter/googlecloud.go

@@ -184,6 +184,10 @@ func newGoogleCloudMetricsExporter(cfg *Config, params component.ExporterCreateP
 
 // pushMetrics calls StackdriverExporter.PushMetricsProto on each element of the given metrics
 func (me *metricsExporter) pushMetrics(ctx context.Context, m pdata.Metrics) error {
+	// Some metrics from Hostmetric receiver has Datapoints with empty StartTimestamp = 0
+	// This causes that later on StartTimestamp is assigned as Timestamp and such datapoints are rejected by google monitoring api
+	fixEmptyStartTime(m)
+
 	// PushMetricsProto doesn't bundle subsequent calls, so we need to
 	// combine the data here to avoid generating too many RPC calls.
 	mds := exportAdditionalLabels(internaldata.MetricsToOC(m))

exporter/googlecloudexporter/googlecloudfixes.go

@@ -0,0 +1,52 @@
+package googlecloudexporter
+
+import "go.opentelemetry.io/collector/consumer/pdata"
+
+/* Fixes empty StartTimestamp field in input metrics datapoints by updating StartTimestamp = Timestamp - 1 micro sec
+   Some metrics from Hostmetric receiver has Datapoints with empty StartTimestamp = 0
+   This causes that later on StartTimestamp is assigned as Timestamp and such datapoints are rejected by google monitoring api */
+func fixEmptyStartTime(metrics pdata.Metrics) {
+	resourceMetrics := metrics.ResourceMetrics()
+	for i := 0; i < resourceMetrics.Len(); i++ {
+		rm := resourceMetrics.At(i)
+		ilms := rm.InstrumentationLibraryMetrics()
+
+		for j := 0; j < ilms.Len(); j++ {
+			ilm := ilms.At(j)
+			metrics := ilm.Metrics()
+
+			for k := 0; k < metrics.Len(); k++ {
+				metric := metrics.At(k)
+
+				switch metric.DataType() {
+				case pdata.MetricDataTypeIntSum:
+					fixEmptyStartTimestampInIntData(metric.IntSum().DataPoints())
+					break
+				case pdata.MetricDataTypeDoubleSum:
+					fixEmptyStartTimestampInDoubleData(metric.DoubleSum().DataPoints())
+					break
+				}
+			}
+		}
+	}
+}
+
+const microSecAsNano = 1000
+
+func fixEmptyStartTimestampInIntData(dps pdata.IntDataPointSlice) {
+	for i := 0; i < dps.Len(); i++ {
+		dp := dps.At(i)
+		if dp.StartTimestamp() == 0 && dp.Timestamp() > microSecAsNano {
+			dp.SetStartTimestamp(dp.Timestamp() - microSecAsNano)
+		}
+	}
+}
+
+func fixEmptyStartTimestampInDoubleData(dps pdata.DoubleDataPointSlice) {
+	for i := 0; i < dps.Len(); i++ {
+		dp := dps.At(i)
+		if dp.StartTimestamp() == 0 && dp.Timestamp() > microSecAsNano {
+			dp.SetStartTimestamp(dp.Timestamp() - microSecAsNano)
+		}
+	}
+}