aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/monlib/encode/buffered/buffered_encoder_base.h
diff options
context:
space:
mode:
authormsherbakov <msherbakov@yandex-team.ru>2022-02-10 16:49:17 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:17 +0300
commita0ffafe83b7d6229709a32fa942c71d672ac989c (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/monlib/encode/buffered/buffered_encoder_base.h
parentc224a621661ddd69699f9476922eb316607ef57e (diff)
downloadydb-a0ffafe83b7d6229709a32fa942c71d672ac989c.tar.gz
Restoring authorship annotation for <msherbakov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/monlib/encode/buffered/buffered_encoder_base.h')
-rw-r--r--library/cpp/monlib/encode/buffered/buffered_encoder_base.h148
1 files changed, 74 insertions, 74 deletions
diff --git a/library/cpp/monlib/encode/buffered/buffered_encoder_base.h b/library/cpp/monlib/encode/buffered/buffered_encoder_base.h
index 38f63eac1d..fe3714e58f 100644
--- a/library/cpp/monlib/encode/buffered/buffered_encoder_base.h
+++ b/library/cpp/monlib/encode/buffered/buffered_encoder_base.h
@@ -1,100 +1,100 @@
-#pragma once
-
-#include "string_pool.h"
-
+#pragma once
+
+#include "string_pool.h"
+
#include <library/cpp/monlib/encode/encoder.h>
#include <library/cpp/monlib/encode/encoder_state.h>
#include <library/cpp/monlib/encode/format.h>
#include <library/cpp/monlib/metrics/metric_value.h>
-
-#include <util/datetime/base.h>
-#include <util/digest/numeric.h>
-
-
-namespace NMonitoring {
-
+
+#include <util/datetime/base.h>
+#include <util/digest/numeric.h>
+
+
+namespace NMonitoring {
+
class TBufferedEncoderBase : public IMetricEncoder {
-public:
- void OnStreamBegin() override;
- void OnStreamEnd() override;
-
- void OnCommonTime(TInstant time) override;
-
+public:
+ void OnStreamBegin() override;
+ void OnStreamEnd() override;
+
+ void OnCommonTime(TInstant time) override;
+
void OnMetricBegin(EMetricType type) override;
void OnMetricEnd() override;
-
- void OnLabelsBegin() override;
- void OnLabelsEnd() override;
+
+ void OnLabelsBegin() override;
+ void OnLabelsEnd() override;
void OnLabel(TStringBuf name, TStringBuf value) override;
void OnLabel(ui32 name, ui32 value) override;
std::pair<ui32, ui32> PrepareLabel(TStringBuf name, TStringBuf value) override;
-
- void OnDouble(TInstant time, double value) override;
+
+ void OnDouble(TInstant time, double value) override;
void OnInt64(TInstant time, i64 value) override;
- void OnUint64(TInstant time, ui64 value) override;
-
+ void OnUint64(TInstant time, ui64 value) override;
+
void OnHistogram(TInstant time, IHistogramSnapshotPtr snapshot) override;
void OnSummaryDouble(TInstant time, ISummaryDoubleSnapshotPtr snapshot) override;
void OnLogHistogram(TInstant, TLogHistogramSnapshotPtr) override;
-protected:
- using TPooledStr = TStringPoolBuilder::TValue;
-
- struct TPooledLabel {
- TPooledLabel(const TPooledStr* key, const TPooledStr* value)
- : Key{key}
- , Value{value}
- {
- }
-
- bool operator==(const TPooledLabel& other) const {
- return std::tie(Key, Value) == std::tie(other.Key, other.Value);
- }
-
- bool operator!=(const TPooledLabel& other) const {
- return !(*this == other);
- }
-
- const TPooledStr* Key;
- const TPooledStr* Value;
- };
-
- using TPooledLabels = TVector<TPooledLabel>;
-
- struct TPooledLabelsHash {
- size_t operator()(const TPooledLabels& val) const {
- size_t hash{0};
-
- for (auto v : val) {
- hash = CombineHashes<size_t>(hash, reinterpret_cast<size_t>(v.Key));
- hash = CombineHashes<size_t>(hash, reinterpret_cast<size_t>(v.Value));
- }
-
- return hash;
- }
- };
-
+protected:
+ using TPooledStr = TStringPoolBuilder::TValue;
+
+ struct TPooledLabel {
+ TPooledLabel(const TPooledStr* key, const TPooledStr* value)
+ : Key{key}
+ , Value{value}
+ {
+ }
+
+ bool operator==(const TPooledLabel& other) const {
+ return std::tie(Key, Value) == std::tie(other.Key, other.Value);
+ }
+
+ bool operator!=(const TPooledLabel& other) const {
+ return !(*this == other);
+ }
+
+ const TPooledStr* Key;
+ const TPooledStr* Value;
+ };
+
+ using TPooledLabels = TVector<TPooledLabel>;
+
+ struct TPooledLabelsHash {
+ size_t operator()(const TPooledLabels& val) const {
+ size_t hash{0};
+
+ for (auto v : val) {
+ hash = CombineHashes<size_t>(hash, reinterpret_cast<size_t>(v.Key));
+ hash = CombineHashes<size_t>(hash, reinterpret_cast<size_t>(v.Value));
+ }
+
+ return hash;
+ }
+ };
+
using TMetricMap = THashMap<TPooledLabels, size_t, TPooledLabelsHash>;
-
+
struct TMetric {
EMetricType MetricType = EMetricType::UNKNOWN;
- TPooledLabels Labels;
+ TPooledLabels Labels;
TMetricTimeSeries TimeSeries;
- };
-
+ };
+
protected:
TString FormatLabels(const TPooledLabels& labels) const;
protected:
- TEncoderState State_;
-
- TStringPoolBuilder LabelNamesPool_;
- TStringPoolBuilder LabelValuesPool_;
- TInstant CommonTime_ = TInstant::Zero();
- TPooledLabels CommonLabels_;
+ TEncoderState State_;
+
+ TStringPoolBuilder LabelNamesPool_;
+ TStringPoolBuilder LabelValuesPool_;
+ TInstant CommonTime_ = TInstant::Zero();
+ TPooledLabels CommonLabels_;
TVector<TMetric> Metrics_;
TMetricMap MetricMap_;
EMetricsMergingMode MetricsMergingMode_ = EMetricsMergingMode::DEFAULT;
-};
-
-}
+};
+
+}