Finish async Export for OtlpHttpClient, OtlpHttpExporter and `Otl…

…pHttpLogExporter`. Add tests for both sync and async exporting. Signed-off-by: owent <admin@owent.net>
open-telemetry · Mar 23, 2022 · 4174407 · 4174407
1 parent 4c3dc25
commit 4174407
Show file tree

Hide file tree

Showing 6 changed files with 489 additions and 332 deletions.
diff --git a/exporters/otlp/src/otlp_http_exporter.cc b/exporters/otlp/src/otlp_http_exporter.cc
@@ -70,7 +70,7 @@ void OtlpHttpExporter::Export(
 
   proto::collector::trace::v1::ExportTraceServiceRequest service_request;
   OtlpRecordableUtils::PopulateRequest(spans, &service_request);
-  http_client_->Export(service_request, result_callback);
+  http_client_->Export(service_request, std::move(result_callback));
 }
 
 bool OtlpHttpExporter::Shutdown(std::chrono::microseconds timeout) noexcept

diff --git a/exporters/otlp/src/otlp_http_log_exporter.cc b/exporters/otlp/src/otlp_http_log_exporter.cc
@@ -70,7 +70,7 @@ void OtlpHttpLogExporter::Export(
   }
   proto::collector::logs::v1::ExportLogsServiceRequest service_request;
   OtlpRecordableUtils::PopulateRequest(logs, &service_request);
-  http_client_->Export(service_request, result_callback);
+  http_client_->Export(service_request, std::move(result_callback));
 }
 
 bool OtlpHttpLogExporter::Shutdown(std::chrono::microseconds timeout) noexcept