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

1 files changed, 477 insertions, 477 deletions

diff --git a/library/cpp/monlib/encode/prometheus/prometheus_decoder_ut.cpp b/library/cpp/monlib/encode/prometheus/prometheus_decoder_ut.cpp
index 49c2244fb4..580b9c6617 100644
--- a/library/cpp/monlib/encode/prometheus/prometheus_decoder_ut.cpp
+++ b/library/cpp/monlib/encode/prometheus/prometheus_decoder_ut.cpp
@@ -1,478 +1,478 @@
-#include "prometheus.h"
-
-#include <library/cpp/monlib/encode/protobuf/protobuf.h>
-
+#include "prometheus.h" 
+ 
+#include <library/cpp/monlib/encode/protobuf/protobuf.h> 
+ 
 #include <library/cpp/testing/unittest/registar.h>
-
-using namespace NMonitoring;
-
-#define ASSERT_LABEL_EQUAL(label, name, value) do { \
-        UNIT_ASSERT_STRINGS_EQUAL((label).GetName(), name); \
-        UNIT_ASSERT_STRINGS_EQUAL((label).GetValue(), value); \
-    } while (false)
-
-#define ASSERT_DOUBLE_POINT(s, time, value) do { \
-        UNIT_ASSERT_VALUES_EQUAL((s).GetTime(), (time).MilliSeconds()); \
-        UNIT_ASSERT_EQUAL((s).GetValueCase(), NProto::TSingleSample::kFloat64); \
-        UNIT_ASSERT_DOUBLES_EQUAL((s).GetFloat64(), value, std::numeric_limits<double>::epsilon()); \
-    } while (false)
-
-#define ASSERT_UINT_POINT(s, time, value) do { \
-        UNIT_ASSERT_VALUES_EQUAL((s).GetTime(), (time).MilliSeconds()); \
-        UNIT_ASSERT_EQUAL((s).GetValueCase(), NProto::TSingleSample::kUint64); \
-        UNIT_ASSERT_VALUES_EQUAL((s).GetUint64(), value); \
-    } while (false)
-
-#define ASSERT_HIST_POINT(s, time, expected) do { \
-        UNIT_ASSERT_VALUES_EQUAL((s).GetTime(), time.MilliSeconds()); \
-        UNIT_ASSERT_EQUAL((s).GetValueCase(), NProto::TSingleSample::kHistogram);\
-        UNIT_ASSERT_VALUES_EQUAL((s).GetHistogram().BoundsSize(), (expected).Count()); \
-        UNIT_ASSERT_VALUES_EQUAL((s).GetHistogram().ValuesSize(), (expected).Count()); \
-        for (size_t i = 0; i < (s).GetHistogram().BoundsSize(); i++) { \
-            UNIT_ASSERT_DOUBLES_EQUAL((s).GetHistogram().GetBounds(i), (expected).UpperBound(i), Min<double>()); \
-            UNIT_ASSERT_VALUES_EQUAL((s).GetHistogram().GetValues(i), (expected).Value(i)); \
-        } \
-    } while (false)
-
-Y_UNIT_TEST_SUITE(TPrometheusDecoderTest) {
-
-    NProto::TSingleSamplesList Decode(TStringBuf data) {
-        NProto::TSingleSamplesList samples;
-        {
-            IMetricEncoderPtr e = EncoderProtobuf(&samples);
-            DecodePrometheus(data, e.Get());
-        }
-        return samples;
-    }
-
-    Y_UNIT_TEST(Empty) {
-        {
-            auto samples = Decode("");
-            UNIT_ASSERT_EQUAL(samples.SamplesSize(), 0);
-        }
-        {
-            auto samples = Decode("\n");
-            UNIT_ASSERT_EQUAL(samples.SamplesSize(), 0);
-        }
-        {
-            auto samples = Decode("\n \n \n");
-            UNIT_ASSERT_EQUAL(samples.SamplesSize(), 0);
-        }
-        {
-            auto samples = Decode("\t\n\t\n");
-            UNIT_ASSERT_EQUAL(samples.SamplesSize(), 0);
-        }
-    }
-
-    Y_UNIT_TEST(Minimal) {
-        auto samples = Decode(
-                "minimal_metric 1.234\n"
-                "another_metric -3e3 103948\n"
-                "# Even that:\n"
-                "no_labels{} 3\n"
-                "# HELP line for non-existing metric will be ignored.\n");
-
-        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 3);
-        {
-            auto& s = samples.GetSamples(0);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(1, s.LabelsSize());
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "minimal_metric");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 1.234);
-        }
-        {
-            auto& s = samples.GetSamples(1);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "another_metric");
-            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(103948), -3000.0);
-        }
-        {
-            auto& s = samples.GetSamples(2);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(1, s.LabelsSize());
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "no_labels");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 3.0);
-        }
-    }
-
-    Y_UNIT_TEST(Counter) {
-        auto samples = Decode(
-                "# A normal comment.\n"
-                "#\n"
-                "# TYPE name counter\n"
-                "name{labelname=\"val1\",basename=\"basevalue\"} NaN\n"
-                "name {labelname=\"val2\",basename=\"basevalue\"} 2.3 1234567890\n"
-                "# HELP name two-line\\n doc  str\\\\ing\n");
-
-        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 2);
-
-        {
-            auto& s = samples.GetSamples(0);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "name");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "basename", "basevalue");
-            ASSERT_LABEL_EQUAL(s.GetLabels(2), "labelname", "val1");
-            ASSERT_UINT_POINT(s, TInstant::Zero(), ui64(0));
-        }
-        {
-            auto& s = samples.GetSamples(1);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "name");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "basename", "basevalue");
-            ASSERT_LABEL_EQUAL(s.GetLabels(2), "labelname", "val2");
-            ASSERT_UINT_POINT(s, TInstant::MilliSeconds(1234567890), i64(2));
-        }
-    }
-
-    Y_UNIT_TEST(Gauge) {
-        auto samples = Decode(
-                "# A normal comment.\n"
-                "#\n"
-                " # HELP  name2  \tdoc str\"ing 2\n"
-                "  #    TYPE    name2 gauge\n"
-                "name2{labelname=\"val2\"\t,basename   =   \"basevalue2\"\t\t} +Inf 54321\n"
-                "name2{ labelname = \"val1\" , }-Inf\n");
-
-        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 2);
-
-        {
-            auto& s = samples.GetSamples(0);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "name2");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "basename", "basevalue2");
-            ASSERT_LABEL_EQUAL(s.GetLabels(2), "labelname", "val2");
-            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(54321), INFINITY);
-        }
-        {
-            auto& s = samples.GetSamples(1);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "name2");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "labelname", "val1");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), -INFINITY);
-        }
-    }
-
-    Y_UNIT_TEST(Summary) {
-        auto samples = Decode(
-                "# HELP \n"
-                "# TYPE my_summary summary\n"
-                "my_summary{n1=\"val1\",quantile=\"0.5\"} 110\n"
-                "my_summary{n1=\"val1\",quantile=\"0.9\"} 140 1\n"
-                "my_summary_count{n1=\"val1\"} 42\n"
-                "my_summary_sum{n1=\"val1\"} 08 15\n"
-                "# some\n"
-                "# funny comments\n"
-                "# HELP\n"
-                "# HELP my_summary\n"
-                "# HELP my_summary \n");
-
-        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 4);
-
-        {
-            auto& s = samples.GetSamples(0);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "my_summary");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.5");
-            ASSERT_LABEL_EQUAL(s.GetLabels(2), "n1", "val1");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 110.0);
-        }
-        {
-            auto& s = samples.GetSamples(1);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "my_summary");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.9");
-            ASSERT_LABEL_EQUAL(s.GetLabels(2), "n1", "val1");
-            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(1), 140.0);
-        }
-        {
-            auto& s = samples.GetSamples(2);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "my_summary_count");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "n1", "val1");
-            ASSERT_UINT_POINT(s, TInstant::Zero(), 42);
-        }
-        {
-            auto& s = samples.GetSamples(3);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "my_summary_sum");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "n1", "val1");
-            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(15), 8.0);
-        }
-    }
-
-    Y_UNIT_TEST(Histogram) {
-        auto samples = Decode(
-                "# HELP request_duration_microseconds The response latency.\n"
-                "# TYPE request_duration_microseconds histogram\n"
-                "request_duration_microseconds_bucket{le=\"0\"} 0\n"
-                "request_duration_microseconds_bucket{le=\"100\"} 123\n"
-                "request_duration_microseconds_bucket{le=\"120\"} 412\n"
-                "request_duration_microseconds_bucket{le=\"144\"} 592\n"
-                "request_duration_microseconds_bucket{le=\"172.8\"} 1524\n"
-                "request_duration_microseconds_bucket{le=\"+Inf\"} 2693\n"
-                "request_duration_microseconds_sum 1.7560473e+06\n"
-                "request_duration_microseconds_count 2693\n");
-
-        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 3);
-
-        {
-            auto& s = samples.GetSamples(0);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "request_duration_microseconds_sum");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 1756047.3);
-        }
-        {
-            auto& s = samples.GetSamples(1);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "request_duration_microseconds_count");
-            ASSERT_UINT_POINT(s, TInstant::Zero(), 2693);
-        }
-        {
-            auto& s = samples.GetSamples(2);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "request_duration_microseconds");
-            auto hist = ExplicitHistogramSnapshot(
-                    { 0, 100, 120, 144, 172.8, HISTOGRAM_INF_BOUND },
-                    { 0, 123, 289, 180, 932, 1169 });
-            ASSERT_HIST_POINT(s, TInstant::Zero(), *hist);
-        }
-    }
-
-    Y_UNIT_TEST(HistogramWithLabels) {
-        auto samples = Decode(
-                "# A histogram, which has a pretty complex representation in the text format:\n"
-                "# HELP http_request_duration_seconds A histogram of the request duration.\n"
-                "# TYPE http_request_duration_seconds histogram\n"
-                "http_request_duration_seconds_bucket{le=\"0.05\", method=\"POST\"} 24054\n"
-                "http_request_duration_seconds_bucket{method=\"POST\", le=\"0.1\"} 33444\n"
-                "http_request_duration_seconds_bucket{le=\"0.2\", method=\"POST\", } 100392\n"
-                "http_request_duration_seconds_bucket{le=\"0.5\",method=\"POST\",} 129389\n"
-                "http_request_duration_seconds_bucket{ method=\"POST\", le=\"1\", } 133988\n"
-                "http_request_duration_seconds_bucket{ le=\"+Inf\", method=\"POST\", } 144320\n"
-                "http_request_duration_seconds_sum{method=\"POST\"} 53423\n"
-                "http_request_duration_seconds_count{ method=\"POST\", } 144320\n");
-
-        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 3);
-
-        {
-            auto& s = samples.GetSamples(0);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_request_duration_seconds_sum");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "POST");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 53423.0);
-        }
-        {
-            auto& s = samples.GetSamples(1);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_request_duration_seconds_count");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "POST");
-            ASSERT_UINT_POINT(s, TInstant::Zero(), 144320);
-        }
-        {
-            auto& s = samples.GetSamples(2);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_request_duration_seconds");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "POST");
-            auto hist = ExplicitHistogramSnapshot(
-                    { 0.05, 0.1, 0.2, 0.5, 1, HISTOGRAM_INF_BOUND },
-                    { 24054, 9390, 66948, 28997, 4599, 10332 });
-            ASSERT_HIST_POINT(s, TInstant::Zero(), *hist);
-        }
-    }
-
-    Y_UNIT_TEST(MultipleHistograms) {
-        auto samples = Decode(
-                "# TYPE inboundBytesPerSec histogram\n"
-                "inboundBytesPerSec_bucket{client=\"mbus\", le=\"10.0\"} 1.0\n"
-                "inboundBytesPerSec_bucket{client=\"mbus\", le=\"20.0\"} 5.0\n"
-                "inboundBytesPerSec_bucket{client=\"mbus\", le=\"+Inf\"} 5.0\n"
-                "inboundBytesPerSec_count{client=\"mbus\"} 5.0\n"
-                "inboundBytesPerSec_bucket{client=\"grpc\", le=\"10.0\"} 1.0\n"
-                "inboundBytesPerSec_bucket{client=\"grpc\", le=\"20.0\"} 5.0\n"
-                "inboundBytesPerSec_bucket{client=\"grpc\", le=\"30.0\"} 5.0\n"
-                "inboundBytesPerSec_count{client=\"grpc\"} 5.0\n"
-                "# TYPE outboundBytesPerSec histogram\n"
-                "outboundBytesPerSec_bucket{client=\"grpc\", le=\"100.0\"} 1.0 1512216000000\n"
-                "outboundBytesPerSec_bucket{client=\"grpc\", le=\"200.0\"} 1.0 1512216000000\n"
-                "outboundBytesPerSec_bucket{client=\"grpc\", le=\"+Inf\"} 1.0 1512216000000\n"
-                "outboundBytesPerSec_count{client=\"grpc\"} 1.0 1512216000000\n");
-
-        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 6);
-
-        {
-            auto& s = samples.GetSamples(0);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "inboundBytesPerSec_count");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "mbus");
-            ASSERT_UINT_POINT(s, TInstant::Zero(), 5);
-        }
-        {
-            auto& s = samples.GetSamples(1);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "inboundBytesPerSec");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "mbus");
-            auto hist = ExplicitHistogramSnapshot(
-                    { 10, 20, HISTOGRAM_INF_BOUND },
-                    { 1, 4, 0 });
-            ASSERT_HIST_POINT(s, TInstant::Zero(), *hist);
-        }
-        {
-            auto& s = samples.GetSamples(2);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "inboundBytesPerSec_count");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "grpc");
-            ASSERT_UINT_POINT(s, TInstant::Zero(), 5);
-        }
-        {
-            auto& s = samples.GetSamples(3);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "inboundBytesPerSec");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "grpc");
-            auto hist = ExplicitHistogramSnapshot(
-                    { 10, 20, 30 },
-                    { 1, 4, 0 });
-            ASSERT_HIST_POINT(s, TInstant::Zero(), *hist);
-        }
-        {
-            auto& s = samples.GetSamples(4);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "outboundBytesPerSec_count");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "grpc");
-            ASSERT_UINT_POINT(s, TInstant::Seconds(1512216000), 1) ;
-        }
-        {
-            auto& s = samples.GetSamples(5);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "outboundBytesPerSec");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "grpc");
-            auto hist = ExplicitHistogramSnapshot(
-                    { 100, 200, HISTOGRAM_INF_BOUND },
-                    { 1, 0, 0 });
-            ASSERT_HIST_POINT(s, TInstant::Seconds(1512216000), *hist);
-        }
-    }
-
-    Y_UNIT_TEST(MixedTypes) {
-        auto samples = Decode(
-                "# HELP http_requests_total The total number of HTTP requests.\n"
-                "# TYPE http_requests_total counter\n"
-                "http_requests_total { } 1027 1395066363000\n"
-                "http_requests_total{method=\"post\",code=\"200\"} 1027 1395066363000\n"
-                "http_requests_total{method=\"post\",code=\"400\"}    3 1395066363000\n"
-                "\n"
-                "# Minimalistic line:\n"
-                "metric_without_timestamp_and_labels 12.47\n"
-                "\n"
-                "# HELP rpc_duration_seconds A summary of the RPC duration in seconds.\n"
-                "# TYPE rpc_duration_seconds summary\n"
-                "rpc_duration_seconds{quantile=\"0.01\"} 3102\n"
-                "rpc_duration_seconds{quantile=\"0.5\"} 4773\n"
-                "rpc_duration_seconds{quantile=\"0.9\"} 9001\n"
-                "rpc_duration_seconds_sum 1.7560473e+07\n"
-                "rpc_duration_seconds_count 2693\n"
-                "\n"
-                "# Another mMinimalistic line:\n"
-                "metric_with_timestamp 12.47 1234567890\n");
-
-        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 10);
-
-        {
-            auto& s = samples.GetSamples(0);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_requests_total");
-            ASSERT_UINT_POINT(s, TInstant::Seconds(1395066363), 1027);
-        }
-        {
-            auto& s = samples.GetSamples(1);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_requests_total");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "post");
-            ASSERT_LABEL_EQUAL(s.GetLabels(2), "code", "200");
-            ASSERT_UINT_POINT(s, TInstant::Seconds(1395066363), 1027);
-        }
-        {
-            auto& s = samples.GetSamples(2);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_requests_total");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "post");
-            ASSERT_LABEL_EQUAL(s.GetLabels(2), "code", "400");
-            ASSERT_UINT_POINT(s, TInstant::Seconds(1395066363), 3);
-        }
-        {
-            auto& s = samples.GetSamples(3);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "metric_without_timestamp_and_labels");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 12.47);
-        }
-        {
-            auto& s = samples.GetSamples(4);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.01");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 3102);
-        }
-        {
-            auto& s = samples.GetSamples(5);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.5");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 4773);
-        }
-        {
-            auto& s = samples.GetSamples(6);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds");
-            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.9");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 9001);
-        }
-        {
-            auto& s = samples.GetSamples(7);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds_sum");
-            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 17560473);
-        }
-        {
-            auto& s = samples.GetSamples(8);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds_count");
-            ASSERT_UINT_POINT(s, TInstant::Zero(), 2693);
-        }
-        {
-            auto& s = samples.GetSamples(9);
-            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE);
-            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1);
-            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "metric_with_timestamp");
-            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(1234567890), 12.47);
-        }
-    }
-}
+ 
+using namespace NMonitoring; 
+ 
+#define ASSERT_LABEL_EQUAL(label, name, value) do { \ 
+        UNIT_ASSERT_STRINGS_EQUAL((label).GetName(), name); \ 
+        UNIT_ASSERT_STRINGS_EQUAL((label).GetValue(), value); \ 
+    } while (false) 
+ 
+#define ASSERT_DOUBLE_POINT(s, time, value) do { \ 
+        UNIT_ASSERT_VALUES_EQUAL((s).GetTime(), (time).MilliSeconds()); \ 
+        UNIT_ASSERT_EQUAL((s).GetValueCase(), NProto::TSingleSample::kFloat64); \ 
+        UNIT_ASSERT_DOUBLES_EQUAL((s).GetFloat64(), value, std::numeric_limits<double>::epsilon()); \ 
+    } while (false) 
+ 
+#define ASSERT_UINT_POINT(s, time, value) do { \ 
+        UNIT_ASSERT_VALUES_EQUAL((s).GetTime(), (time).MilliSeconds()); \ 
+        UNIT_ASSERT_EQUAL((s).GetValueCase(), NProto::TSingleSample::kUint64); \ 
+        UNIT_ASSERT_VALUES_EQUAL((s).GetUint64(), value); \ 
+    } while (false) 
+ 
+#define ASSERT_HIST_POINT(s, time, expected) do { \ 
+        UNIT_ASSERT_VALUES_EQUAL((s).GetTime(), time.MilliSeconds()); \ 
+        UNIT_ASSERT_EQUAL((s).GetValueCase(), NProto::TSingleSample::kHistogram);\ 
+        UNIT_ASSERT_VALUES_EQUAL((s).GetHistogram().BoundsSize(), (expected).Count()); \ 
+        UNIT_ASSERT_VALUES_EQUAL((s).GetHistogram().ValuesSize(), (expected).Count()); \ 
+        for (size_t i = 0; i < (s).GetHistogram().BoundsSize(); i++) { \ 
+            UNIT_ASSERT_DOUBLES_EQUAL((s).GetHistogram().GetBounds(i), (expected).UpperBound(i), Min<double>()); \ 
+            UNIT_ASSERT_VALUES_EQUAL((s).GetHistogram().GetValues(i), (expected).Value(i)); \ 
+        } \ 
+    } while (false) 
+ 
+Y_UNIT_TEST_SUITE(TPrometheusDecoderTest) { 
+ 
+    NProto::TSingleSamplesList Decode(TStringBuf data) { 
+        NProto::TSingleSamplesList samples; 
+        { 
+            IMetricEncoderPtr e = EncoderProtobuf(&samples); 
+            DecodePrometheus(data, e.Get()); 
+        } 
+        return samples; 
+    } 
+ 
+    Y_UNIT_TEST(Empty) { 
+        { 
+            auto samples = Decode(""); 
+            UNIT_ASSERT_EQUAL(samples.SamplesSize(), 0); 
+        } 
+        { 
+            auto samples = Decode("\n"); 
+            UNIT_ASSERT_EQUAL(samples.SamplesSize(), 0); 
+        } 
+        { 
+            auto samples = Decode("\n \n \n"); 
+            UNIT_ASSERT_EQUAL(samples.SamplesSize(), 0); 
+        } 
+        { 
+            auto samples = Decode("\t\n\t\n"); 
+            UNIT_ASSERT_EQUAL(samples.SamplesSize(), 0); 
+        } 
+    } 
+ 
+    Y_UNIT_TEST(Minimal) { 
+        auto samples = Decode( 
+                "minimal_metric 1.234\n" 
+                "another_metric -3e3 103948\n" 
+                "# Even that:\n" 
+                "no_labels{} 3\n" 
+                "# HELP line for non-existing metric will be ignored.\n"); 
+ 
+        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 3); 
+        { 
+            auto& s = samples.GetSamples(0); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(1, s.LabelsSize()); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "minimal_metric"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 1.234); 
+        } 
+        { 
+            auto& s = samples.GetSamples(1); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "another_metric"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(103948), -3000.0); 
+        } 
+        { 
+            auto& s = samples.GetSamples(2); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(1, s.LabelsSize()); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "no_labels"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 3.0); 
+        } 
+    } 
+ 
+    Y_UNIT_TEST(Counter) { 
+        auto samples = Decode( 
+                "# A normal comment.\n" 
+                "#\n" 
+                "# TYPE name counter\n" 
+                "name{labelname=\"val1\",basename=\"basevalue\"} NaN\n" 
+                "name {labelname=\"val2\",basename=\"basevalue\"} 2.3 1234567890\n" 
+                "# HELP name two-line\\n doc  str\\\\ing\n"); 
+ 
+        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 2); 
+ 
+        { 
+            auto& s = samples.GetSamples(0); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "name"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "basename", "basevalue"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(2), "labelname", "val1"); 
+            ASSERT_UINT_POINT(s, TInstant::Zero(), ui64(0)); 
+        } 
+        { 
+            auto& s = samples.GetSamples(1); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "name"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "basename", "basevalue"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(2), "labelname", "val2"); 
+            ASSERT_UINT_POINT(s, TInstant::MilliSeconds(1234567890), i64(2)); 
+        } 
+    } 
+ 
+    Y_UNIT_TEST(Gauge) { 
+        auto samples = Decode( 
+                "# A normal comment.\n" 
+                "#\n" 
+                " # HELP  name2  \tdoc str\"ing 2\n" 
+                "  #    TYPE    name2 gauge\n" 
+                "name2{labelname=\"val2\"\t,basename   =   \"basevalue2\"\t\t} +Inf 54321\n" 
+                "name2{ labelname = \"val1\" , }-Inf\n"); 
+ 
+        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 2); 
+ 
+        { 
+            auto& s = samples.GetSamples(0); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "name2"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "basename", "basevalue2"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(2), "labelname", "val2"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(54321), INFINITY); 
+        } 
+        { 
+            auto& s = samples.GetSamples(1); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "name2"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "labelname", "val1"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), -INFINITY); 
+        } 
+    } 
+ 
+    Y_UNIT_TEST(Summary) { 
+        auto samples = Decode( 
+                "# HELP \n" 
+                "# TYPE my_summary summary\n" 
+                "my_summary{n1=\"val1\",quantile=\"0.5\"} 110\n" 
+                "my_summary{n1=\"val1\",quantile=\"0.9\"} 140 1\n" 
+                "my_summary_count{n1=\"val1\"} 42\n" 
+                "my_summary_sum{n1=\"val1\"} 08 15\n" 
+                "# some\n" 
+                "# funny comments\n" 
+                "# HELP\n" 
+                "# HELP my_summary\n" 
+                "# HELP my_summary \n"); 
+ 
+        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 4); 
+ 
+        { 
+            auto& s = samples.GetSamples(0); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "my_summary"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.5"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(2), "n1", "val1"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 110.0); 
+        } 
+        { 
+            auto& s = samples.GetSamples(1); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "my_summary"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.9"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(2), "n1", "val1"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(1), 140.0); 
+        } 
+        { 
+            auto& s = samples.GetSamples(2); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "my_summary_count"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "n1", "val1"); 
+            ASSERT_UINT_POINT(s, TInstant::Zero(), 42); 
+        } 
+        { 
+            auto& s = samples.GetSamples(3); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "my_summary_sum"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "n1", "val1"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(15), 8.0); 
+        } 
+    } 
+ 
+    Y_UNIT_TEST(Histogram) { 
+        auto samples = Decode( 
+                "# HELP request_duration_microseconds The response latency.\n" 
+                "# TYPE request_duration_microseconds histogram\n" 
+                "request_duration_microseconds_bucket{le=\"0\"} 0\n" 
+                "request_duration_microseconds_bucket{le=\"100\"} 123\n" 
+                "request_duration_microseconds_bucket{le=\"120\"} 412\n" 
+                "request_duration_microseconds_bucket{le=\"144\"} 592\n" 
+                "request_duration_microseconds_bucket{le=\"172.8\"} 1524\n" 
+                "request_duration_microseconds_bucket{le=\"+Inf\"} 2693\n" 
+                "request_duration_microseconds_sum 1.7560473e+06\n" 
+                "request_duration_microseconds_count 2693\n"); 
+ 
+        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 3); 
+ 
+        { 
+            auto& s = samples.GetSamples(0); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "request_duration_microseconds_sum"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 1756047.3); 
+        } 
+        { 
+            auto& s = samples.GetSamples(1); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "request_duration_microseconds_count"); 
+            ASSERT_UINT_POINT(s, TInstant::Zero(), 2693); 
+        } 
+        { 
+            auto& s = samples.GetSamples(2); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "request_duration_microseconds"); 
+            auto hist = ExplicitHistogramSnapshot( 
+                    { 0, 100, 120, 144, 172.8, HISTOGRAM_INF_BOUND }, 
+                    { 0, 123, 289, 180, 932, 1169 }); 
+            ASSERT_HIST_POINT(s, TInstant::Zero(), *hist); 
+        } 
+    } 
+ 
+    Y_UNIT_TEST(HistogramWithLabels) { 
+        auto samples = Decode( 
+                "# A histogram, which has a pretty complex representation in the text format:\n" 
+                "# HELP http_request_duration_seconds A histogram of the request duration.\n" 
+                "# TYPE http_request_duration_seconds histogram\n" 
+                "http_request_duration_seconds_bucket{le=\"0.05\", method=\"POST\"} 24054\n" 
+                "http_request_duration_seconds_bucket{method=\"POST\", le=\"0.1\"} 33444\n" 
+                "http_request_duration_seconds_bucket{le=\"0.2\", method=\"POST\", } 100392\n" 
+                "http_request_duration_seconds_bucket{le=\"0.5\",method=\"POST\",} 129389\n" 
+                "http_request_duration_seconds_bucket{ method=\"POST\", le=\"1\", } 133988\n" 
+                "http_request_duration_seconds_bucket{ le=\"+Inf\", method=\"POST\", } 144320\n" 
+                "http_request_duration_seconds_sum{method=\"POST\"} 53423\n" 
+                "http_request_duration_seconds_count{ method=\"POST\", } 144320\n"); 
+ 
+        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 3); 
+ 
+        { 
+            auto& s = samples.GetSamples(0); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_request_duration_seconds_sum"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "POST"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 53423.0); 
+        } 
+        { 
+            auto& s = samples.GetSamples(1); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_request_duration_seconds_count"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "POST"); 
+            ASSERT_UINT_POINT(s, TInstant::Zero(), 144320); 
+        } 
+        { 
+            auto& s = samples.GetSamples(2); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_request_duration_seconds"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "POST"); 
+            auto hist = ExplicitHistogramSnapshot( 
+                    { 0.05, 0.1, 0.2, 0.5, 1, HISTOGRAM_INF_BOUND }, 
+                    { 24054, 9390, 66948, 28997, 4599, 10332 }); 
+            ASSERT_HIST_POINT(s, TInstant::Zero(), *hist); 
+        } 
+    } 
+ 
+    Y_UNIT_TEST(MultipleHistograms) { 
+        auto samples = Decode( 
+                "# TYPE inboundBytesPerSec histogram\n" 
+                "inboundBytesPerSec_bucket{client=\"mbus\", le=\"10.0\"} 1.0\n" 
+                "inboundBytesPerSec_bucket{client=\"mbus\", le=\"20.0\"} 5.0\n" 
+                "inboundBytesPerSec_bucket{client=\"mbus\", le=\"+Inf\"} 5.0\n" 
+                "inboundBytesPerSec_count{client=\"mbus\"} 5.0\n" 
+                "inboundBytesPerSec_bucket{client=\"grpc\", le=\"10.0\"} 1.0\n" 
+                "inboundBytesPerSec_bucket{client=\"grpc\", le=\"20.0\"} 5.0\n" 
+                "inboundBytesPerSec_bucket{client=\"grpc\", le=\"30.0\"} 5.0\n" 
+                "inboundBytesPerSec_count{client=\"grpc\"} 5.0\n" 
+                "# TYPE outboundBytesPerSec histogram\n" 
+                "outboundBytesPerSec_bucket{client=\"grpc\", le=\"100.0\"} 1.0 1512216000000\n" 
+                "outboundBytesPerSec_bucket{client=\"grpc\", le=\"200.0\"} 1.0 1512216000000\n" 
+                "outboundBytesPerSec_bucket{client=\"grpc\", le=\"+Inf\"} 1.0 1512216000000\n" 
+                "outboundBytesPerSec_count{client=\"grpc\"} 1.0 1512216000000\n"); 
+ 
+        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 6); 
+ 
+        { 
+            auto& s = samples.GetSamples(0); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "inboundBytesPerSec_count"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "mbus"); 
+            ASSERT_UINT_POINT(s, TInstant::Zero(), 5); 
+        } 
+        { 
+            auto& s = samples.GetSamples(1); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "inboundBytesPerSec"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "mbus"); 
+            auto hist = ExplicitHistogramSnapshot( 
+                    { 10, 20, HISTOGRAM_INF_BOUND }, 
+                    { 1, 4, 0 }); 
+            ASSERT_HIST_POINT(s, TInstant::Zero(), *hist); 
+        } 
+        { 
+            auto& s = samples.GetSamples(2); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "inboundBytesPerSec_count"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "grpc"); 
+            ASSERT_UINT_POINT(s, TInstant::Zero(), 5); 
+        } 
+        { 
+            auto& s = samples.GetSamples(3); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "inboundBytesPerSec"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "grpc"); 
+            auto hist = ExplicitHistogramSnapshot( 
+                    { 10, 20, 30 }, 
+                    { 1, 4, 0 }); 
+            ASSERT_HIST_POINT(s, TInstant::Zero(), *hist); 
+        } 
+        { 
+            auto& s = samples.GetSamples(4); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "outboundBytesPerSec_count"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "grpc"); 
+            ASSERT_UINT_POINT(s, TInstant::Seconds(1512216000), 1) ; 
+        } 
+        { 
+            auto& s = samples.GetSamples(5); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::HIST_RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "outboundBytesPerSec"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "client", "grpc"); 
+            auto hist = ExplicitHistogramSnapshot( 
+                    { 100, 200, HISTOGRAM_INF_BOUND }, 
+                    { 1, 0, 0 }); 
+            ASSERT_HIST_POINT(s, TInstant::Seconds(1512216000), *hist); 
+        } 
+    } 
+ 
+    Y_UNIT_TEST(MixedTypes) { 
+        auto samples = Decode( 
+                "# HELP http_requests_total The total number of HTTP requests.\n" 
+                "# TYPE http_requests_total counter\n" 
+                "http_requests_total { } 1027 1395066363000\n" 
+                "http_requests_total{method=\"post\",code=\"200\"} 1027 1395066363000\n" 
+                "http_requests_total{method=\"post\",code=\"400\"}    3 1395066363000\n" 
+                "\n" 
+                "# Minimalistic line:\n" 
+                "metric_without_timestamp_and_labels 12.47\n" 
+                "\n" 
+                "# HELP rpc_duration_seconds A summary of the RPC duration in seconds.\n" 
+                "# TYPE rpc_duration_seconds summary\n" 
+                "rpc_duration_seconds{quantile=\"0.01\"} 3102\n" 
+                "rpc_duration_seconds{quantile=\"0.5\"} 4773\n" 
+                "rpc_duration_seconds{quantile=\"0.9\"} 9001\n" 
+                "rpc_duration_seconds_sum 1.7560473e+07\n" 
+                "rpc_duration_seconds_count 2693\n" 
+                "\n" 
+                "# Another mMinimalistic line:\n" 
+                "metric_with_timestamp 12.47 1234567890\n"); 
+ 
+        UNIT_ASSERT_EQUAL(samples.SamplesSize(), 10); 
+ 
+        { 
+            auto& s = samples.GetSamples(0); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_requests_total"); 
+            ASSERT_UINT_POINT(s, TInstant::Seconds(1395066363), 1027); 
+        } 
+        { 
+            auto& s = samples.GetSamples(1); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_requests_total"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "post"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(2), "code", "200"); 
+            ASSERT_UINT_POINT(s, TInstant::Seconds(1395066363), 1027); 
+        } 
+        { 
+            auto& s = samples.GetSamples(2); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 3); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "http_requests_total"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "method", "post"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(2), "code", "400"); 
+            ASSERT_UINT_POINT(s, TInstant::Seconds(1395066363), 3); 
+        } 
+        { 
+            auto& s = samples.GetSamples(3); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "metric_without_timestamp_and_labels"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 12.47); 
+        } 
+        { 
+            auto& s = samples.GetSamples(4); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.01"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 3102); 
+        } 
+        { 
+            auto& s = samples.GetSamples(5); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.5"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 4773); 
+        } 
+        { 
+            auto& s = samples.GetSamples(6); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 2); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds"); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(1), "quantile", "0.9"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 9001); 
+        } 
+        { 
+            auto& s = samples.GetSamples(7); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds_sum"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::Zero(), 17560473); 
+        } 
+        { 
+            auto& s = samples.GetSamples(8); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::RATE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "rpc_duration_seconds_count"); 
+            ASSERT_UINT_POINT(s, TInstant::Zero(), 2693); 
+        } 
+        { 
+            auto& s = samples.GetSamples(9); 
+            UNIT_ASSERT_EQUAL(s.GetMetricType(), NProto::EMetricType::GAUGE); 
+            UNIT_ASSERT_EQUAL(s.LabelsSize(), 1); 
+            ASSERT_LABEL_EQUAL(s.GetLabels(0), "sensor", "metric_with_timestamp"); 
+            ASSERT_DOUBLE_POINT(s, TInstant::MilliSeconds(1234567890), 12.47); 
+        } 
+    } 
+}