OpenTelemetry Protocol (OTLP) trace exporter implementation. More...

#include <trace_exporters.h>

Inheritance diagram for kcenon::monitoring::otlp_exporter:

Collaboration diagram for kcenon::monitoring::otlp_exporter:

Public Member Functions
	otlp_exporter (const trace_export_config &config, const otel_resource &resource)

common::VoidResult	export_spans (const std::vector< trace_span > &spans) override
	Export a batch of spans.

common::VoidResult	flush () override
	Flush any pending spans.

common::VoidResult	shutdown () override
	Shutdown the exporter.

std::unordered_map< std::string, std::size_t >	get_stats () const override
	Get exporter statistics.

Public Member Functions inherited from kcenon::monitoring::trace_exporter_interface
virtual	~trace_exporter_interface ()=default

Private Member Functions
common::VoidResult	send_grpc_batch (const std::vector< otel_span_data > &spans)

common::VoidResult	send_http_json_batch (const std::vector< otel_span_data > &spans)

common::VoidResult	send_http_protobuf_batch (const std::vector< otel_span_data > &spans)

Private Attributes
trace_export_config	config_

std::unique_ptr< opentelemetry_tracer_adapter >	otel_adapter_

std::atomic< std::size_t >	exported_spans_ {0}

std::atomic< std::size_t >	failed_exports_ {0}

std::atomic< std::size_t >	dropped_spans_ {0}

Detailed Description

OpenTelemetry Protocol (OTLP) trace exporter implementation.

Definition at line 827 of file trace_exporters.h.

Constructor & Destructor Documentation

◆ otlp_exporter()

kcenon::monitoring::otlp_exporter::otlp_exporter	(	const trace_export_config &	config,
		const otel_resource &	resource )

inlineexplicit

Definition at line 836 of file trace_exporters.h.

837 : config_(config), otel_adapter_(std::make_unique<opentelemetry_tracer_adapter>(resource)) {}

kcenon::monitoring::otlp_exporter::otel_adapter_

std::unique_ptr< opentelemetry_tracer_adapter > otel_adapter_

Definition trace_exporters.h:830

kcenon::monitoring::otlp_exporter::config_

trace_export_config config_

Definition trace_exporters.h:829

Member Function Documentation

◆ export_spans()

common::VoidResult kcenon::monitoring::otlp_exporter::export_spans ( const std::vector< trace_span > & spans )

inlineoverridevirtual

Export a batch of spans.

Implements kcenon::monitoring::trace_exporter_interface.

Definition at line 839 of file trace_exporters.h.

                                                                               {
        try {
            // Convert to OpenTelemetry format first
            auto otel_result = otel_adapter_->convert_spans(spans);
            if (otel_result.is_err()) {
                failed_exports_++;
                return common::VoidResult::err(error_info(monitoring_error_code::processing_failed,
                                 "Failed to convert spans to OTEL format: " + otel_result.error().message, "monitoring_system").to_common_error());
            }
 
            const auto& otel_spans = otel_result.value();
 
            // Send via appropriate OTLP protocol
            common::VoidResult send_result = common::ok();
            if (config_.format == trace_export_format::otlp_grpc) {
                send_result = send_grpc_batch(otel_spans);
            } else if (config_.format == trace_export_format::otlp_http_json) {
                send_result = send_http_json_batch(otel_spans);
            } else if (config_.format == trace_export_format::otlp_http_protobuf) {
                send_result = send_http_protobuf_batch(otel_spans);
            } else {
                return common::VoidResult::err(error_info(monitoring_error_code::invalid_configuration,
                                 "Invalid OTLP export format", "monitoring_system").to_common_error());
            }
 
            if (send_result.is_ok()) {
                exported_spans_ += spans.size();
            } else {
                failed_exports_++;
                return send_result;
            }
 
            return common::ok();
 
        } catch (const std::exception& e) {
            failed_exports_++;
            return common::VoidResult::err(error_info(monitoring_error_code::operation_failed,
                             "OTLP export failed: " + std::string(e.what()), "monitoring_system").to_common_error());
        }
    }

References config_, exported_spans_, failed_exports_, kcenon::monitoring::trace_export_config::format, kcenon::monitoring::invalid_configuration, kcenon::monitoring::operation_failed, otel_adapter_, kcenon::monitoring::otlp_grpc, kcenon::monitoring::otlp_http_json, kcenon::monitoring::otlp_http_protobuf, kcenon::monitoring::processing_failed, send_grpc_batch(), send_http_json_batch(), send_http_protobuf_batch(), and kcenon::monitoring::error_info::to_common_error().

Referenced by TEST_F(), TEST_F(), and TEST_F().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ flush()

common::VoidResult kcenon::monitoring::otlp_exporter::flush ( )

inlineoverridevirtual

Flush any pending spans.

Implements kcenon::monitoring::trace_exporter_interface.

Definition at line 880 of file trace_exporters.h.

                                      {
        // OTLP exporter typically sends immediately, so flush is a no-op
        return common::ok();
    }

Referenced by shutdown(), and TEST_F().

Here is the caller graph for this function:

◆ get_stats()

std::unordered_map< std::string, std::size_t > kcenon::monitoring::otlp_exporter::get_stats ( ) const

inlineoverridevirtual

Get exporter statistics.

Implements kcenon::monitoring::trace_exporter_interface.

Definition at line 889 of file trace_exporters.h.

                                                                      {
        return {
            {"exported_spans", exported_spans_.load()},
            {"failed_exports", failed_exports_.load()},
            {"dropped_spans", dropped_spans_.load()}
        };
    }

References dropped_spans_, exported_spans_, and failed_exports_.

Referenced by TEST_F(), and TEST_F().

Here is the caller graph for this function:

◆ send_grpc_batch()

common::VoidResult kcenon::monitoring::otlp_exporter::send_grpc_batch ( const std::vector< otel_span_data > & spans )

inlineprivate

Definition at line 898 of file trace_exporters.h.

                                                                             {
        // Simulate OTLP gRPC sending
        // In real implementation, this would use OTLP gRPC client
        (void)spans; // Suppress unused parameter warning
        return common::ok();
    }

Referenced by export_spans().

Here is the caller graph for this function:

◆ send_http_json_batch()

common::VoidResult kcenon::monitoring::otlp_exporter::send_http_json_batch ( const std::vector< otel_span_data > & spans )

inlineprivate

Definition at line 905 of file trace_exporters.h.

                                                                                  {
        // Simulate OTLP HTTP JSON sending
        // In real implementation, this would serialize OTEL spans to JSON and POST
        (void)spans; // Suppress unused parameter warning
        return common::ok();
    }

Referenced by export_spans().

Here is the caller graph for this function:

◆ send_http_protobuf_batch()

common::VoidResult kcenon::monitoring::otlp_exporter::send_http_protobuf_batch ( const std::vector< otel_span_data > & spans )

inlineprivate

Definition at line 912 of file trace_exporters.h.

                                                                                      {
        // Simulate OTLP HTTP protobuf sending
        // In real implementation, this would serialize OTEL spans to protobuf and POST
        (void)spans; // Suppress unused parameter warning
        return common::ok();
    }

Referenced by export_spans().

Here is the caller graph for this function:

◆ shutdown()

common::VoidResult kcenon::monitoring::otlp_exporter::shutdown ( )

inlineoverridevirtual

Shutdown the exporter.

Implements kcenon::monitoring::trace_exporter_interface.

Definition at line 885 of file trace_exporters.h.

                                         {
        return flush();
    }

References flush().

Referenced by TEST_F().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ config_

trace_export_config kcenon::monitoring::otlp_exporter::config_

private

Definition at line 829 of file trace_exporters.h.

Referenced by export_spans().

◆ dropped_spans_

std::atomic<std::size_t> kcenon::monitoring::otlp_exporter::dropped_spans_ {0}

private

Definition at line 833 of file trace_exporters.h.

833{0};

Referenced by get_stats().

◆ exported_spans_

std::atomic<std::size_t> kcenon::monitoring::otlp_exporter::exported_spans_ {0}

private

Definition at line 831 of file trace_exporters.h.

831{0};

Referenced by export_spans(), and get_stats().

◆ failed_exports_

std::atomic<std::size_t> kcenon::monitoring::otlp_exporter::failed_exports_ {0}

private

Definition at line 832 of file trace_exporters.h.

832{0};

Referenced by export_spans(), and get_stats().

◆ otel_adapter_

std::unique_ptr<opentelemetry_tracer_adapter> kcenon::monitoring::otlp_exporter::otel_adapter_

private

Definition at line 830 of file trace_exporters.h.

Referenced by export_spans().

The documentation for this class was generated from the following file:

include/kcenon/monitoring/exporters/trace_exporters.h

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ otlp_exporter()

Member Function Documentation

◆ export_spans()

◆ flush()

◆ get_stats()

◆ send_grpc_batch()

◆ send_http_json_batch()

◆ send_http_protobuf_batch()

◆ shutdown()

Member Data Documentation

◆ config_

◆ dropped_spans_

◆ exported_spans_

◆ failed_exports_

◆ otel_adapter_