Program Listing for File multi_metric_storage.h
↰ Return to documentation for file (/home/docs/checkouts/readthedocs.org/user_builds/opentelemetry-cpp/checkouts/v1.8.1/sdk/include/opentelemetry/sdk/metrics/state/multi_metric_storage.h
)
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
#pragma once
#include "opentelemetry/common/key_value_iterable_view.h"
#include "opentelemetry/sdk/metrics/instruments.h"
#include "opentelemetry/sdk/metrics/state/metric_storage.h"
#include <memory>
OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
{
namespace metrics
{
class SyncMultiMetricStorage : public SyncWritableMetricStorage
{
public:
void AddStorage(std::shared_ptr<SyncWritableMetricStorage> storage)
{
storages_.push_back(storage);
}
virtual void RecordLong(int64_t value,
const opentelemetry::context::Context &context) noexcept override
{
for (auto &s : storages_)
{
s->RecordLong(value, context);
}
}
virtual void RecordLong(int64_t value,
const opentelemetry::common::KeyValueIterable &attributes,
const opentelemetry::context::Context &context) noexcept override
{
for (auto &s : storages_)
{
s->RecordLong(value, attributes, context);
}
}
virtual void RecordDouble(double value,
const opentelemetry::context::Context &context) noexcept override
{
for (auto &s : storages_)
{
s->RecordDouble(value, context);
}
}
virtual void RecordDouble(double value,
const opentelemetry::common::KeyValueIterable &attributes,
const opentelemetry::context::Context &context) noexcept override
{
for (auto &s : storages_)
{
s->RecordDouble(value, attributes, context);
}
}
private:
std::vector<std::shared_ptr<SyncWritableMetricStorage>> storages_;
};
class AsyncMultiMetricStorage : public AsyncWritableMetricStorage
{
public:
void AddStorage(std::shared_ptr<AsyncWritableMetricStorage> storage)
{
storages_.push_back(storage);
}
void RecordLong(
const std::unordered_map<MetricAttributes, int64_t, AttributeHashGenerator> &measurements,
opentelemetry::common::SystemTimestamp observation_time) noexcept override
{
for (auto &s : storages_)
{
s->RecordLong(measurements, observation_time);
}
}
void RecordDouble(
const std::unordered_map<MetricAttributes, double, AttributeHashGenerator> &measurements,
opentelemetry::common::SystemTimestamp observation_time) noexcept override
{
for (auto &s : storages_)
{
s->RecordDouble(measurements, observation_time);
}
}
private:
std::vector<std::shared_ptr<AsyncWritableMetricStorage>> storages_;
};
} // namespace metrics
} // namespace sdk
OPENTELEMETRY_END_NAMESPACE