diff --git a/metrics_proto.go b/metrics_proto.go index efa2b52..139daad 100644 --- a/metrics_proto.go +++ b/metrics_proto.go @@ -207,7 +207,14 @@ func (se *statsExporter) convertSummaryMetrics(summary *metricspb.Metric) []*met return metrics } -func (se *statsExporter) handleMetricsProtoUpload(payloads []*metricProtoPayload) error { +func (se *statsExporter) handleMetricsProtoUpload(payloads []*metricProtoPayload) { + err := se.uploadMetricsProto(payloads) + if err != nil { + se.o.handleError(err) + } +} + +func (se *statsExporter) uploadMetricsProto(payloads []*metricProtoPayload) error { ctx, cancel := se.o.newContextWithTimeout() defer cancel()