aboutsummaryrefslogblamecommitdiffstats
path: root/library/cpp/monlib/metrics/metric_consumer.h
blob: 1152b51c4af8989074e67ac3556728864bd6a59e (plain) (tree)
1
2
3
4
5
6


                                
                                   

















                                                                    
                                                    





                                                                                      
                                                                                          
                                                                                            


                                                



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

        virtual void OnMemOnly(bool isMemOnly) {
            Y_UNUSED(isMemOnly);
        }
    };

    using IMetricConsumerPtr = THolder<IMetricConsumer>;

}