-
Notifications
You must be signed in to change notification settings - Fork 410
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' into fix_api_singleton_1520
- Loading branch information
Showing
27 changed files
with
869 additions
and
422 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,97 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| #ifndef ENABLE_METRICS_PREVIEW | ||
|
|
||
| # include "opentelemetry/exporters/otlp/otlp_grpc_metric_exporter_factory.h" | ||
| # include "opentelemetry/metrics/provider.h" | ||
| # include "opentelemetry/sdk/metrics/aggregation/default_aggregation.h" | ||
| # include "opentelemetry/sdk/metrics/export/periodic_exporting_metric_reader.h" | ||
| # include "opentelemetry/sdk/metrics/meter.h" | ||
| # include "opentelemetry/sdk/metrics/meter_provider.h" | ||
|
|
||
| # include <memory> | ||
| # include <thread> | ||
|
|
||
| # ifdef BAZEL_BUILD | ||
| # include "examples/common/metrics_foo_library/foo_library.h" | ||
| # else | ||
| # include "metrics_foo_library/foo_library.h" | ||
| # endif | ||
|
|
||
| namespace metric_sdk = opentelemetry::sdk::metrics; | ||
| namespace nostd = opentelemetry::nostd; | ||
| namespace common = opentelemetry::common; | ||
| namespace metrics_api = opentelemetry::metrics; | ||
| namespace otlp_exporter = opentelemetry::exporter::otlp; | ||
|
|
||
| namespace | ||
| { | ||
|
|
||
| otlp_exporter::OtlpGrpcMetricExporterOptions options; | ||
|
|
||
| void initMetrics() | ||
| { | ||
| auto exporter = otlp_exporter::OtlpGrpcMetricExporterFactory::Create(options); | ||
|
|
||
| std::string version{"1.2.0"}; | ||
| std::string schema{"https://opentelemetry.io/schemas/1.2.0"}; | ||
|
|
||
| // Initialize and set the global MeterProvider | ||
| metric_sdk::PeriodicExportingMetricReaderOptions options; | ||
| options.export_interval_millis = std::chrono::milliseconds(1000); | ||
| options.export_timeout_millis = std::chrono::milliseconds(500); | ||
| std::unique_ptr<metric_sdk::MetricReader> reader{ | ||
| new metric_sdk::PeriodicExportingMetricReader(std::move(exporter), options)}; | ||
| auto provider = std::shared_ptr<metrics_api::MeterProvider>(new metric_sdk::MeterProvider()); | ||
| auto p = std::static_pointer_cast<metric_sdk::MeterProvider>(provider); | ||
| p->AddMetricReader(std::move(reader)); | ||
|
|
||
| metrics_api::Provider::SetMeterProvider(provider); | ||
| } | ||
| } // namespace | ||
|
|
||
| int main(int argc, char *argv[]) | ||
| { | ||
| std::string example_type; | ||
| if (argc > 1) | ||
| { | ||
| options.endpoint = argv[1]; | ||
| if (argc > 2) | ||
| { | ||
| example_type = argv[2]; | ||
| if (argc > 3) | ||
| { | ||
| options.use_ssl_credentials = true; | ||
| options.ssl_credentials_cacert_path = argv[3]; | ||
| } | ||
| } | ||
| } | ||
| // Removing this line will leave the default noop MetricProvider in place. | ||
| initMetrics(); | ||
| std::string name{"otlp_grpc_metric_example"}; | ||
|
|
||
| if (example_type == "counter") | ||
| { | ||
| foo_library::counter_example(name); | ||
| } | ||
| else if (example_type == "observable_counter") | ||
| { | ||
| foo_library::observable_counter_example(name); | ||
| } | ||
| else if (example_type == "histogram") | ||
| { | ||
| foo_library::histogram_example(name); | ||
| } | ||
| else | ||
| { | ||
| std::thread counter_example{&foo_library::counter_example, name}; | ||
| std::thread observable_counter_example{&foo_library::observable_counter_example, name}; | ||
| std::thread histogram_example{&foo_library::histogram_example, name}; | ||
|
|
||
| counter_example.join(); | ||
| observable_counter_example.join(); | ||
| histogram_example.join(); | ||
| } | ||
| } | ||
| #endif |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.