func normalizeTimeSeriesReqs()

in exporter/collector/integrationtest/testcases/testcase.go [440:462]

• 20 lines of code
• 8 McCabe index (conditional complexity)

func normalizeTimeSeriesReqs(t testing.TB, reqs ...*monitoringpb.CreateTimeSeriesRequest) {
	for _, req := range reqs {
		for _, ts := range req.TimeSeries {
			for _, p := range ts.Points {
				// Normalize timestamps if they are set
				if p.GetInterval().GetStartTime() != nil {
					p.GetInterval().StartTime = &timestamppb.Timestamp{}
				}
				if p.GetInterval().GetEndTime() != nil {
					p.GetInterval().EndTime = &timestamppb.Timestamp{}
				}
				if ts.GetValueType() == googlemetricpb.MetricDescriptor_DISTRIBUTION {
					for _, ex := range p.GetValue().GetDistributionValue().GetExemplars() {
						ex.Timestamp = &timestamppb.Timestamp{}
					}
				}
			}

			// clear project ID from monitored resource
			delete(ts.GetResource().GetLabels(), "project_id")
		}
	}
}