diff options
Diffstat (limited to 'src/jaegertracing/opentelemetry-cpp/sdk/include/opentelemetry/sdk/metrics/aggregation/default_aggregation.h')
| -rw-r--r-- | src/jaegertracing/opentelemetry-cpp/sdk/include/opentelemetry/sdk/metrics/aggregation/default_aggregation.h | 146 |
1 files changed, 146 insertions, 0 deletions
diff --git a/src/jaegertracing/opentelemetry-cpp/sdk/include/opentelemetry/sdk/metrics/aggregation/default_aggregation.h b/src/jaegertracing/opentelemetry-cpp/sdk/include/opentelemetry/sdk/metrics/aggregation/default_aggregation.h new file mode 100644 index 000000000..887e1beb9 --- /dev/null +++ b/src/jaegertracing/opentelemetry-cpp/sdk/include/opentelemetry/sdk/metrics/aggregation/default_aggregation.h @@ -0,0 +1,146 @@ +// Copyright The OpenTelemetry Authors +// SPDX-License-Identifier: Apache-2.0 + +#pragma once +#ifndef ENABLE_METRICS_PREVIEW +# include "opentelemetry/common/spin_lock_mutex.h" +# include "opentelemetry/sdk/metrics/aggregation/aggregation.h" +# include "opentelemetry/sdk/metrics/aggregation/drop_aggregation.h" +# include "opentelemetry/sdk/metrics/aggregation/histogram_aggregation.h" +# include "opentelemetry/sdk/metrics/aggregation/lastvalue_aggregation.h" +# include "opentelemetry/sdk/metrics/aggregation/sum_aggregation.h" +# include "opentelemetry/sdk/metrics/instruments.h" + +# include <mutex> + +OPENTELEMETRY_BEGIN_NAMESPACE +namespace sdk +{ +namespace metrics +{ +class DefaultAggregation +{ +public: + static std::unique_ptr<Aggregation> CreateAggregation( + const opentelemetry::sdk::metrics::InstrumentDescriptor &instrument_descriptor) + { + switch (instrument_descriptor.type_) + { + case InstrumentType::kCounter: + case InstrumentType::kUpDownCounter: + case InstrumentType::kObservableCounter: + case InstrumentType::kObservableUpDownCounter: + return (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + ? std::move(std::unique_ptr<Aggregation>(new LongSumAggregation())) + : std::move(std::unique_ptr<Aggregation>(new DoubleSumAggregation())); + break; + case InstrumentType::kHistogram: + return (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + ? std::move(std::unique_ptr<Aggregation>(new LongHistogramAggregation())) + : std::move(std::unique_ptr<Aggregation>(new DoubleHistogramAggregation())); + break; + case InstrumentType::kObservableGauge: + return (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + ? std::move(std::unique_ptr<Aggregation>(new LongLastValueAggregation())) + : std::move(std::unique_ptr<Aggregation>(new DoubleLastValueAggregation())); + break; + default: + return std::move(std::unique_ptr<Aggregation>(new DropAggregation())); + }; + } + + static std::unique_ptr<Aggregation> CreateAggregation(AggregationType aggregation_type, + InstrumentDescriptor instrument_descriptor) + { + switch (aggregation_type) + { + case AggregationType::kDrop: + return std::unique_ptr<Aggregation>(new DropAggregation()); + break; + case AggregationType::kHistogram: + if (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + { + return std::unique_ptr<Aggregation>(new LongHistogramAggregation()); + } + else + { + return std::unique_ptr<Aggregation>(new DoubleHistogramAggregation()); + } + break; + case AggregationType::kLastValue: + if (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + { + return std::unique_ptr<Aggregation>(new LongLastValueAggregation()); + } + else + { + return std::unique_ptr<Aggregation>(new DoubleLastValueAggregation()); + } + break; + case AggregationType::kSum: + if (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + { + return std::unique_ptr<Aggregation>(new LongSumAggregation()); + } + else + { + return std::unique_ptr<Aggregation>(new DoubleSumAggregation()); + } + break; + default: + return DefaultAggregation::CreateAggregation(instrument_descriptor); + } + } + + static std::unique_ptr<Aggregation> CloneAggregation(AggregationType aggregation_type, + InstrumentDescriptor instrument_descriptor, + const Aggregation &to_copy) + { + const PointType point_data = to_copy.ToPoint(); + switch (aggregation_type) + { + case AggregationType::kDrop: + return std::unique_ptr<Aggregation>(new DropAggregation()); + case AggregationType::kHistogram: + if (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + { + return std::unique_ptr<Aggregation>( + new LongHistogramAggregation(nostd::get<HistogramPointData>(point_data))); + } + else + { + return std::unique_ptr<Aggregation>( + new DoubleHistogramAggregation(nostd::get<HistogramPointData>(point_data))); + } + case AggregationType::kLastValue: + if (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + { + return std::unique_ptr<Aggregation>( + new LongLastValueAggregation(nostd::get<LastValuePointData>(point_data))); + } + else + { + return std::unique_ptr<Aggregation>( + new DoubleLastValueAggregation(nostd::get<LastValuePointData>(point_data))); + } + case AggregationType::kSum: + if (instrument_descriptor.value_type_ == InstrumentValueType::kLong) + { + return std::unique_ptr<Aggregation>( + new LongSumAggregation(nostd::get<SumPointData>(point_data))); + } + else + { + return std::unique_ptr<Aggregation>( + new DoubleSumAggregation(nostd::get<SumPointData>(point_data))); + } + default: + return DefaultAggregation::CreateAggregation(instrument_descriptor); + } + } +}; + +} // namespace metrics +} // namespace sdk +OPENTELEMETRY_END_NAMESPACE +#endif
\ No newline at end of file |