Restoring authorship annotation for Sergey Polovko <sergey@polovko.me>. Commit 2 of 2.

1 files changed, 198 insertions, 198 deletions

diff --git a/library/cpp/monlib/encode/protobuf/protobuf_encoder.cpp b/library/cpp/monlib/encode/protobuf/protobuf_encoder.cpp
index 57fbbba605..2d11b9d5ba 100644
--- a/library/cpp/monlib/encode/protobuf/protobuf_encoder.cpp
+++ b/library/cpp/monlib/encode/protobuf/protobuf_encoder.cpp
@@ -1,42 +1,42 @@
-#include "protobuf.h" 
- 
-#include <util/datetime/base.h> 
- 
-namespace NMonitoring { 
-    namespace { 
-        NProto::EMetricType ConvertMetricType(EMetricType type) { 
-            switch (type) { 
-                case EMetricType::GAUGE: 
-                    return NProto::GAUGE; 
-                case EMetricType::COUNTER: 
-                    return NProto::COUNTER; 
-                case EMetricType::RATE: 
-                    return NProto::RATE; 
-                case EMetricType::IGAUGE: 
-                    return NProto::IGAUGE; 
-                case EMetricType::HIST: 
+#include "protobuf.h"
+
+#include <util/datetime/base.h>
+
+namespace NMonitoring {
+    namespace {
+        NProto::EMetricType ConvertMetricType(EMetricType type) {
+            switch (type) {
+                case EMetricType::GAUGE:
+                    return NProto::GAUGE;
+                case EMetricType::COUNTER:
+                    return NProto::COUNTER;
+                case EMetricType::RATE:
+                    return NProto::RATE;
+                case EMetricType::IGAUGE:
+                    return NProto::IGAUGE;
+                case EMetricType::HIST:
                     return NProto::HISTOGRAM;
-                case EMetricType::HIST_RATE: 
+                case EMetricType::HIST_RATE:
                     return NProto::HIST_RATE;
-                case EMetricType::DSUMMARY: 
+                case EMetricType::DSUMMARY:
                     return NProto::DSUMMARY;
                 case EMetricType::LOGHIST:
                     return NProto::LOGHISTOGRAM;
-                case EMetricType::UNKNOWN: 
-                    return NProto::UNKNOWN; 
-            } 
-        } 
- 
-        void FillHistogram( 
-                const IHistogramSnapshot& snapshot, 
-                NProto::THistogram* histogram) 
-        { 
-            for (ui32 i = 0; i < snapshot.Count(); i++) { 
-                histogram->AddBounds(snapshot.UpperBound(i)); 
-                histogram->AddValues(snapshot.Value(i)); 
-            } 
-        } 
- 
+                case EMetricType::UNKNOWN:
+                    return NProto::UNKNOWN;
+            }
+        }
+
+        void FillHistogram(
+                const IHistogramSnapshot& snapshot,
+                NProto::THistogram* histogram)
+        {
+            for (ui32 i = 0; i < snapshot.Count(); i++) {
+                histogram->AddBounds(snapshot.UpperBound(i));
+                histogram->AddValues(snapshot.Value(i));
+            }
+        }
+
         void FillSummaryDouble(const ISummaryDoubleSnapshot& snapshot, NProto::TSummaryDouble* summary) {
             summary->SetSum(snapshot.GetSum());
             summary->SetMin(snapshot.GetMin());
@@ -54,195 +54,195 @@ namespace NMonitoring {
             }
         }
 
-        /////////////////////////////////////////////////////////////////////////////// 
-        // TSingleamplesEncoder 
-        /////////////////////////////////////////////////////////////////////////////// 
-        class TSingleSamplesEncoder final: public IMetricEncoder { 
-        public: 
-            TSingleSamplesEncoder(NProto::TSingleSamplesList* samples) 
-                : Samples_(samples) 
-                , Sample_(nullptr) 
-            { 
-            } 
- 
-        private: 
-            void OnStreamBegin() override { 
-            } 
-            void OnStreamEnd() override { 
-            } 
- 
-            void OnCommonTime(TInstant time) override { 
-                Samples_->SetCommonTime(time.MilliSeconds()); 
-            } 
- 
-            void OnMetricBegin(EMetricType type) override { 
-                Sample_ = Samples_->AddSamples(); 
-                Sample_->SetMetricType(ConvertMetricType(type)); 
-            } 
- 
-            void OnMetricEnd() override { 
-                Sample_ = nullptr; 
-            } 
- 
-            void OnLabelsBegin() override { 
-            } 
-            void OnLabelsEnd() override { 
-            } 
- 
-            void OnLabel(TStringBuf name, TStringBuf value) override { 
-                NProto::TLabel* label = (Sample_ == nullptr) 
-                                            ? Samples_->AddCommonLabels() 
-                                            : Sample_->AddLabels(); 
+        ///////////////////////////////////////////////////////////////////////////////
+        // TSingleamplesEncoder
+        ///////////////////////////////////////////////////////////////////////////////
+        class TSingleSamplesEncoder final: public IMetricEncoder {
+        public:
+            TSingleSamplesEncoder(NProto::TSingleSamplesList* samples)
+                : Samples_(samples)
+                , Sample_(nullptr)
+            {
+            }
+
+        private:
+            void OnStreamBegin() override {
+            }
+            void OnStreamEnd() override {
+            }
+
+            void OnCommonTime(TInstant time) override {
+                Samples_->SetCommonTime(time.MilliSeconds());
+            }
+
+            void OnMetricBegin(EMetricType type) override {
+                Sample_ = Samples_->AddSamples();
+                Sample_->SetMetricType(ConvertMetricType(type));
+            }
+
+            void OnMetricEnd() override {
+                Sample_ = nullptr;
+            }
+
+            void OnLabelsBegin() override {
+            }
+            void OnLabelsEnd() override {
+            }
+
+            void OnLabel(TStringBuf name, TStringBuf value) override {
+                NProto::TLabel* label = (Sample_ == nullptr)
+                                            ? Samples_->AddCommonLabels()
+                                            : Sample_->AddLabels();
                 label->SetName(TString{name});
                 label->SetValue(TString{value});
-            } 
- 
-            void OnDouble(TInstant time, double value) override { 
-                Y_ENSURE(Sample_, "metric not started"); 
-                Sample_->SetTime(time.MilliSeconds()); 
-                Sample_->SetFloat64(value); 
-            } 
- 
-            void OnInt64(TInstant time, i64 value) override { 
-                Y_ENSURE(Sample_, "metric not started"); 
-                Sample_->SetTime(time.MilliSeconds()); 
-                Sample_->SetInt64(value); 
-            } 
- 
-            void OnUint64(TInstant time, ui64 value) override { 
-                Y_ENSURE(Sample_, "metric not started"); 
-                Sample_->SetTime(time.MilliSeconds()); 
-                Sample_->SetUint64(value); 
-            } 
- 
-            void OnHistogram(TInstant time, IHistogramSnapshotPtr snapshot) override { 
-                Y_ENSURE(Sample_, "metric not started"); 
-                Sample_->SetTime(time.MilliSeconds()); 
-                FillHistogram(*snapshot, Sample_->MutableHistogram()); 
-            } 
- 
+            }
+
+            void OnDouble(TInstant time, double value) override {
+                Y_ENSURE(Sample_, "metric not started");
+                Sample_->SetTime(time.MilliSeconds());
+                Sample_->SetFloat64(value);
+            }
+
+            void OnInt64(TInstant time, i64 value) override {
+                Y_ENSURE(Sample_, "metric not started");
+                Sample_->SetTime(time.MilliSeconds());
+                Sample_->SetInt64(value);
+            }
+
+            void OnUint64(TInstant time, ui64 value) override {
+                Y_ENSURE(Sample_, "metric not started");
+                Sample_->SetTime(time.MilliSeconds());
+                Sample_->SetUint64(value);
+            }
+
+            void OnHistogram(TInstant time, IHistogramSnapshotPtr snapshot) override {
+                Y_ENSURE(Sample_, "metric not started");
+                Sample_->SetTime(time.MilliSeconds());
+                FillHistogram(*snapshot, Sample_->MutableHistogram());
+            }
+
             void OnSummaryDouble(TInstant time, ISummaryDoubleSnapshotPtr snapshot) override {
-                Y_ENSURE(Sample_, "metric not started"); 
+                Y_ENSURE(Sample_, "metric not started");
                 Sample_->SetTime(time.MilliSeconds());
                 FillSummaryDouble(*snapshot, Sample_->MutableSummaryDouble());
             }
 
             void OnLogHistogram(TInstant time, TLogHistogramSnapshotPtr snapshot) override {
-                Y_ENSURE(Sample_, "metric not started"); 
+                Y_ENSURE(Sample_, "metric not started");
                 Sample_->SetTime(time.MilliSeconds());
                 FillLogHistogram(*snapshot, Sample_->MutableLogHistogram());
             }
 
-            void Close() override { 
-            } 
- 
-        private: 
-            NProto::TSingleSamplesList* Samples_; 
-            NProto::TSingleSample* Sample_; 
-        }; 
- 
-        /////////////////////////////////////////////////////////////////////////////// 
-        // TMultiSamplesEncoder 
-        /////////////////////////////////////////////////////////////////////////////// 
-        class TMultiSamplesEncoder final: public IMetricEncoder { 
-        public: 
-            TMultiSamplesEncoder(NProto::TMultiSamplesList* samples) 
-                : Samples_(samples) 
-                , Sample_(nullptr) 
-            { 
-            } 
- 
-        private: 
-            void OnStreamBegin() override { 
-            } 
-            void OnStreamEnd() override { 
-            } 
- 
-            void OnCommonTime(TInstant time) override { 
-                Samples_->SetCommonTime(time.MilliSeconds()); 
-            } 
- 
-            void OnMetricBegin(EMetricType type) override { 
-                Sample_ = Samples_->AddSamples(); 
-                Sample_->SetMetricType(ConvertMetricType(type)); 
-            } 
- 
-            void OnMetricEnd() override { 
-                Sample_ = nullptr; 
-            } 
- 
-            void OnLabelsBegin() override { 
-            } 
-            void OnLabelsEnd() override { 
-            } 
- 
-            void OnLabel(TStringBuf name, TStringBuf value) override { 
-                NProto::TLabel* label = (Sample_ == nullptr) 
-                                            ? Samples_->AddCommonLabels() 
-                                            : Sample_->AddLabels(); 
- 
+            void Close() override {
+            }
+
+        private:
+            NProto::TSingleSamplesList* Samples_;
+            NProto::TSingleSample* Sample_;
+        };
+
+        ///////////////////////////////////////////////////////////////////////////////
+        // TMultiSamplesEncoder
+        ///////////////////////////////////////////////////////////////////////////////
+        class TMultiSamplesEncoder final: public IMetricEncoder {
+        public:
+            TMultiSamplesEncoder(NProto::TMultiSamplesList* samples)
+                : Samples_(samples)
+                , Sample_(nullptr)
+            {
+            }
+
+        private:
+            void OnStreamBegin() override {
+            }
+            void OnStreamEnd() override {
+            }
+
+            void OnCommonTime(TInstant time) override {
+                Samples_->SetCommonTime(time.MilliSeconds());
+            }
+
+            void OnMetricBegin(EMetricType type) override {
+                Sample_ = Samples_->AddSamples();
+                Sample_->SetMetricType(ConvertMetricType(type));
+            }
+
+            void OnMetricEnd() override {
+                Sample_ = nullptr;
+            }
+
+            void OnLabelsBegin() override {
+            }
+            void OnLabelsEnd() override {
+            }
+
+            void OnLabel(TStringBuf name, TStringBuf value) override {
+                NProto::TLabel* label = (Sample_ == nullptr)
+                                            ? Samples_->AddCommonLabels()
+                                            : Sample_->AddLabels();
+
                 label->SetName(TString{name});
                 label->SetValue(TString{value});
-            } 
- 
-            void OnDouble(TInstant time, double value) override { 
-                Y_ENSURE(Sample_, "metric not started"); 
-                NProto::TPoint* point = Sample_->AddPoints(); 
-                point->SetTime(time.MilliSeconds()); 
-                point->SetFloat64(value); 
-            } 
- 
-            void OnInt64(TInstant time, i64 value) override { 
-                Y_ENSURE(Sample_, "metric not started"); 
-                NProto::TPoint* point = Sample_->AddPoints(); 
-                point->SetTime(time.MilliSeconds()); 
-                point->SetInt64(value); 
-            } 
- 
-            void OnUint64(TInstant time, ui64 value) override { 
-                Y_ENSURE(Sample_, "metric not started"); 
-                NProto::TPoint* point = Sample_->AddPoints(); 
-                point->SetTime(time.MilliSeconds()); 
-                point->SetUint64(value); 
-            } 
- 
-            void OnHistogram(TInstant time, IHistogramSnapshotPtr snapshot) override { 
-                Y_ENSURE(Sample_, "metric not started"); 
-                NProto::TPoint* point = Sample_->AddPoints(); 
-                point->SetTime(time.MilliSeconds()); 
-                FillHistogram(*snapshot, point->MutableHistogram()); 
-            } 
- 
+            }
+
+            void OnDouble(TInstant time, double value) override {
+                Y_ENSURE(Sample_, "metric not started");
+                NProto::TPoint* point = Sample_->AddPoints();
+                point->SetTime(time.MilliSeconds());
+                point->SetFloat64(value);
+            }
+
+            void OnInt64(TInstant time, i64 value) override {
+                Y_ENSURE(Sample_, "metric not started");
+                NProto::TPoint* point = Sample_->AddPoints();
+                point->SetTime(time.MilliSeconds());
+                point->SetInt64(value);
+            }
+
+            void OnUint64(TInstant time, ui64 value) override {
+                Y_ENSURE(Sample_, "metric not started");
+                NProto::TPoint* point = Sample_->AddPoints();
+                point->SetTime(time.MilliSeconds());
+                point->SetUint64(value);
+            }
+
+            void OnHistogram(TInstant time, IHistogramSnapshotPtr snapshot) override {
+                Y_ENSURE(Sample_, "metric not started");
+                NProto::TPoint* point = Sample_->AddPoints();
+                point->SetTime(time.MilliSeconds());
+                FillHistogram(*snapshot, point->MutableHistogram());
+            }
+
             void OnSummaryDouble(TInstant time, ISummaryDoubleSnapshotPtr snapshot) override {
-                Y_ENSURE(Sample_, "metric not started"); 
+                Y_ENSURE(Sample_, "metric not started");
                 NProto::TPoint* point = Sample_->AddPoints();
                 point->SetTime(time.MilliSeconds());
                 FillSummaryDouble(*snapshot, point->MutableSummaryDouble());
             }
 
             void OnLogHistogram(TInstant time, TLogHistogramSnapshotPtr snapshot) override {
-                Y_ENSURE(Sample_, "metric not started"); 
+                Y_ENSURE(Sample_, "metric not started");
                 NProto::TPoint* point = Sample_->AddPoints();
                 point->SetTime(time.MilliSeconds());
                 FillLogHistogram(*snapshot, point->MutableLogHistogram());
             }
 
-            void Close() override { 
-            } 
- 
-        private: 
-            NProto::TMultiSamplesList* Samples_; 
-            NProto::TMultiSample* Sample_; 
-        }; 
- 
-    } 
- 
-    IMetricEncoderPtr EncoderProtobuf(NProto::TSingleSamplesList* samples) { 
+            void Close() override {
+            }
+
+        private:
+            NProto::TMultiSamplesList* Samples_;
+            NProto::TMultiSample* Sample_;
+        };
+
+    }
+
+    IMetricEncoderPtr EncoderProtobuf(NProto::TSingleSamplesList* samples) {
         return MakeHolder<TSingleSamplesEncoder>(samples);
-    } 
- 
-    IMetricEncoderPtr EncoderProtobuf(NProto::TMultiSamplesList* samples) { 
+    }
+
+    IMetricEncoderPtr EncoderProtobuf(NProto::TMultiSamplesList* samples) {
         return MakeHolder<TMultiSamplesEncoder>(samples);
-    } 
- 
-} 
+    }
+
+}