: client_(client),

      service_method_(*Protobuf::DescriptorPool::generated_pool()->FindMethodByName(

          "opentelemetry.proto.collector.trace.v1.TraceService.Export")) {}

void OpenTelemetryGrpcTraceExporter::onCreateInitialMetadata(Http::RequestHeaderMap& metadata) {

  metadata.setReferenceUserAgent(OtlpUtils::getOtlpUserAgentHeader());

}

    Grpc::ResponsePtr<ExportTraceServiceResponse>&& response, Tracing::Span&) {

  if (response->has_partial_success()) {

    auto msg = response->partial_success().error_message();

    auto rejected_spans = response->partial_success().rejected_spans();

    if (rejected_spans > 0 || !msg.empty()) {

      if (msg.empty()) {

        msg = "empty message";

      }

      ENVOY_LOG(debug, "OTLP partial success: {} ({} spans rejected)", msg, rejected_spans);

    }

  }

}

                                               const std::string& message, Tracing::Span&) {

  ENVOY_LOG(debug, "OTLP trace export failed with status: {}, message: {}",

            Grpc::Utility::grpcStatusToString(status), message);

}

bool OpenTelemetryGrpcTraceExporter::log(const ExportTraceServiceRequest& request) {

  client_->send(service_method_, request, *this, Tracing::NullSpan::instance(),

                Http::AsyncClient::RequestOptions());

  OpenTelemetryTraceExporter::logExportedSpans(request);

  return true;

}