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>; 
 
}