// Copyright The OpenTelemetry Authors // SPDX-License-Identifier: Apache-2.0 #include #include #include #include #include "opentelemetry/exporters/otlp/otlp_file_client_options.h" #include "opentelemetry/exporters/otlp/otlp_file_exporter_factory.h" #include "opentelemetry/exporters/otlp/otlp_file_exporter_options.h" #include "opentelemetry/exporters/otlp/otlp_file_log_record_exporter_factory.h" #include "opentelemetry/exporters/otlp/otlp_file_log_record_exporter_options.h" #include "opentelemetry/logs/logger_provider.h" #include "opentelemetry/nostd/shared_ptr.h" #include "opentelemetry/sdk/logs/exporter.h" #include "opentelemetry/sdk/logs/logger_provider.h" #include "opentelemetry/sdk/logs/logger_provider_factory.h" #include "opentelemetry/sdk/logs/processor.h" #include "opentelemetry/sdk/logs/provider.h" #include "opentelemetry/sdk/logs/simple_log_record_processor_factory.h" #include "opentelemetry/sdk/trace/exporter.h" #include "opentelemetry/sdk/trace/processor.h" #include "opentelemetry/sdk/trace/provider.h" #include "opentelemetry/sdk/trace/simple_processor_factory.h" #include "opentelemetry/sdk/trace/tracer_provider.h" #include "opentelemetry/sdk/trace/tracer_provider_factory.h" #include "opentelemetry/trace/tracer_provider.h" #ifdef BAZEL_BUILD # include "examples/common/logs_foo_library/foo_library.h" #else # include "logs_foo_library/foo_library.h" #endif namespace trace = opentelemetry::trace; namespace nostd = opentelemetry::nostd; namespace otlp = opentelemetry::exporter::otlp; namespace logs_sdk = opentelemetry::sdk::logs; namespace logs = opentelemetry::logs; namespace trace_sdk = opentelemetry::sdk::trace; namespace { opentelemetry::exporter::otlp::OtlpFileExporterOptions opts; opentelemetry::exporter::otlp::OtlpFileLogRecordExporterOptions log_opts; std::shared_ptr tracer_provider; std::shared_ptr logger_provider; void InitTracer() { // Create OTLP exporter instance auto exporter = otlp::OtlpFileExporterFactory::Create(opts); auto processor = trace_sdk::SimpleSpanProcessorFactory::Create(std::move(exporter)); tracer_provider = trace_sdk::TracerProviderFactory::Create(std::move(processor)); // Set the global trace provider std::shared_ptr api_provider = tracer_provider; trace_sdk::Provider::SetTracerProvider(api_provider); } void CleanupTracer() { // We call ForceFlush to prevent to cancel running exportings, It's optional. if (tracer_provider) { tracer_provider->ForceFlush(); } tracer_provider.reset(); std::shared_ptr none; trace_sdk::Provider::SetTracerProvider(none); } void InitLogger() { // Create OTLP exporter instance auto exporter = otlp::OtlpFileLogRecordExporterFactory::Create(log_opts); auto processor = logs_sdk::SimpleLogRecordProcessorFactory::Create(std::move(exporter)); logger_provider = logs_sdk::LoggerProviderFactory::Create(std::move(processor)); std::shared_ptr api_provider = logger_provider; logs_sdk::Provider::SetLoggerProvider(api_provider); } void CleanupLogger() { // We call ForceFlush to prevent to cancel running exportings, It's optional. if (logger_provider) { logger_provider->ForceFlush(); } logger_provider.reset(); nostd::shared_ptr none; logs_sdk::Provider::SetLoggerProvider(none); } } // namespace int main(int argc, char *argv[]) { if (argc > 1) { opentelemetry::exporter::otlp::OtlpFileClientFileSystemOptions fs_backend; fs_backend.file_pattern = argv[1]; opts.backend_options = fs_backend; if (argc > 2) { opentelemetry::exporter::otlp::OtlpFileClientFileSystemOptions logs_fs_backend; logs_fs_backend.file_pattern = argv[2]; log_opts.backend_options = logs_fs_backend; } else { log_opts.backend_options = std::ref(std::cout); } } else { opts.backend_options = std::ref(std::cout); } InitLogger(); InitTracer(); foo_library(); CleanupTracer(); CleanupLogger(); return 0; }