library/cpp/monlib/metrics/metric_consumer.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

#pragma once

#include "metric_type.h"
#include "histogram_collector.h"
#include "summary_collector.h"
#include "log_histogram_snapshot.h"

class TInstant;

namespace NMonitoring {
    class IMetricConsumer {
    public:
        virtual ~IMetricConsumer() = default;

        virtual void OnStreamBegin() = 0;
        virtual void OnStreamEnd() = 0;

        virtual void OnCommonTime(TInstant time) = 0;

        virtual void OnMetricBegin(EMetricType type) = 0;
        virtual void OnMetricEnd() = 0;

        virtual void OnLabelsBegin() = 0;
        virtual void OnLabelsEnd() = 0;
        virtual void OnLabel(TStringBuf name, TStringBuf value) = 0;
        virtual void OnLabel(ui32 name, ui32 value);
        virtual std::pair<ui32, ui32> PrepareLabel(TStringBuf name, TStringBuf value);

        virtual void OnDouble(TInstant time, double value) = 0;
        virtual void OnInt64(TInstant time, i64 value) = 0;
        virtual void OnUint64(TInstant time, ui64 value) = 0;

        virtual void OnHistogram(TInstant time, IHistogramSnapshotPtr snapshot) = 0;
        virtual void OnLogHistogram(TInstant time, TLogHistogramSnapshotPtr snapshot) = 0;
        virtual void OnSummaryDouble(TInstant time, ISummaryDoubleSnapshotPtr snapshot) = 0;
    };

    using IMetricConsumerPtr = THolder<IMetricConsumer>;

}