exporters.cpp File Reference

Implementation of tracing configuration and exporters. More...

#include "kcenon/network/detail/tracing/tracing_config.h"
#include "kcenon/network/detail/tracing/span.h"
#include "kcenon/network/detail/tracing/trace_context.h"
#include <atomic>
#include <iomanip>
#include <iostream>
#include <mutex>
#include <sstream>
#include <vector>

Include dependency graph for exporters.cpp:

Go to the source code of this file.

Namespaces
namespace	kcenon
namespace	kcenon::network
	Main namespace for all Network System components.
namespace	kcenon::network::tracing

Functions
void	kcenon::network::tracing::configure_tracing (const tracing_config &config)
	Initialize the tracing system with configuration.
void	kcenon::network::tracing::shutdown_tracing ()
	Shutdown the tracing system.
void	kcenon::network::tracing::flush_tracing ()
	Force flush all pending spans.
auto	kcenon::network::tracing::is_tracing_enabled () -> bool
	Check if tracing is enabled.
void	kcenon::network::tracing::register_span_processor (span_processor_callback callback)
	Register a custom span processor.
void	kcenon::network::tracing::export_span (const span &s)
	Export a completed span.

Detailed Description

Implementation of tracing configuration and exporters.

Definition in file exporters.cpp.

Variable Documentation

batch_mutex

std::mutex batch_mutex

Definition at line 35 of file exporters.cpp.

batch_queue

std::vector<std::string> batch_queue

Definition at line 34 of file exporters.cpp.

config

tracing_config config

Examples

grpc_service_example.cpp.

Definition at line 29 of file exporters.cpp.

Referenced by kcenon::network::tracing::configure_tracing(), kcenon::network::protocol::quic::connect(), kcenon::network::protocol::quic::connect(), kcenon::network::tracing::tracing_config::console(), kcenon::network::facade::http_facade::create_client(), kcenon::network::facade::quic_facade::create_client(), kcenon::network::facade::tcp_facade::create_client(), kcenon::network::facade::udp_facade::create_client(), kcenon::network::facade::websocket_facade::create_client(), kcenon::network::protocol::quic::create_connection(), kcenon::network::facade::tcp_facade::create_connection_pool(), kcenon::network::protocol::quic::create_listener(), kcenon::network::facade::http_facade::create_server(), kcenon::network::facade::quic_facade::create_server(), kcenon::network::facade::tcp_facade::create_server(), kcenon::network::facade::udp_facade::create_server(), kcenon::network::facade::websocket_facade::create_server(), kcenon::network::protocols::grpc::grpc_client::grpc_client(), kcenon::network::protocols::grpc::grpc_server::grpc_server(), kcenon::network::core::unified_session_manager::impl::impl(), kcenon::network::protocols::grpc::grpc_client::impl::impl(), kcenon::network::protocols::grpc::grpc_server::impl::impl(), kcenon::network::protocols::grpc::service_registry::impl::impl(), kcenon::network::initialize(), kcenon::network::integration::messaging_bridge::initialize(), kcenon::network::integration::NetworkSystemBridge::Impl::initialize(), kcenon::network::integration::NetworkSystemBridge::initialize(), kcenon::network::integration::ObservabilityBridge::initialize(), kcenon::network::integration::ThreadPoolBridge::initialize(), kcenon::network::internal::tls_config::insecure_for_testing(), kcenon::network::tracing::tracing_config::jaeger(), kcenon::network::internal::tls_config::legacy_compatible(), kcenon::network::protocol::quic::listen(), kcenon::network::protocol::quic::listen(), main(), kcenon::network::tracing::tracing_config::otlp_grpc(), kcenon::network::tracing::tracing_config::otlp_http(), kcenon::network::protocols::quic::pmtud_controller::pmtud_controller(), kcenon::network::unified::adapters::quic_connection_adapter::quic_connection_adapter(), kcenon::network::unified::adapters::quic_listener_adapter::quic_listener_adapter(), kcenon::network::internal::tls_config::secure_defaults(), kcenon::network::protocols::grpc::service_registry::service_registry(), kcenon::network::core::session_manager::session_manager(), kcenon::network::core::session_manager_base< SessionType >::session_manager_base(), kcenon::network::internal::adapters::quic_client_adapter::start(), kcenon::network::internal::adapters::quic_server_adapter::start(), kcenon::network::core::messaging_quic_client::start_client(), kcenon::network::core::messaging_ws_client::start_client(), kcenon::network::core::messaging_quic_server::start_server(), kcenon::network::core::messaging_ws_server::start_server(), kcenon::network::protocols::http2::http2_server::start_tls(), kcenon::network::internal::tcp_socket::tcp_socket(), kcenon::network::core::unified_session_manager::unified_session_manager(), kcenon::network::facade::http_facade::validate_client_config(), kcenon::network::facade::quic_facade::validate_client_config(), kcenon::network::facade::tcp_facade::validate_client_config(), kcenon::network::facade::udp_facade::validate_client_config(), kcenon::network::facade::websocket_facade::validate_client_config(), kcenon::network::facade::http_facade::validate_server_config(), kcenon::network::facade::quic_facade::validate_server_config(), kcenon::network::facade::tcp_facade::validate_server_config(), kcenon::network::facade::udp_facade::validate_server_config(), kcenon::network::facade::websocket_facade::validate_server_config(), and kcenon::network::core::ws_session_manager::ws_session_manager().

enabled

std::atomic<bool> enabled {false}

Definition at line 28 of file exporters.cpp.

{false};

Referenced by kcenon::network::integration::basic_monitoring::impl::set_logging_enabled(), and kcenon::network::integration::basic_monitoring::set_logging_enabled().

mutex

std::mutex mutex

Definition at line 31 of file exporters.cpp.

processors

std::vector<span_processor_callback> processors

Definition at line 30 of file exporters.cpp.

queued_count

std::atomic<size_t> queued_count {0}

Definition at line 36 of file exporters.cpp.

{0};