TelnetStats.hpp

Go to the documentation of this file.

#pragma once
 
#include "utils/BaseServerStats.hpp"
 
#include <prometheus/registry.h>
 
struct TelnetSessionStats {
    std::chrono::high_resolution_clock::time_point connectTime;    
    std::chrono::high_resolution_clock::time_point disconnectTime; 
    size_t uploadBytes{};                                          
    size_t downloadBytes{};                                        
    uint64_t successCmdCtr{};                                      
    uint64_t failCmdCtr{};                                         
};
 
struct TelnetServerStats {
    std::chrono::high_resolution_clock::time_point processingTimeStart; 
    std::chrono::high_resolution_clock::time_point processingTimeEnd;   
    uint64_t activeConnectionCtr{};                                     
    uint64_t acceptedConnectionCtr{};                                   
    uint64_t refusedConnectionCtr{};                                    
};
 
class TelnetStats : private BaseServerStats {
  private:
    prometheus::Family<prometheus::Info> *_infoFamily; 
    prometheus::Gauge *_activeConnection;              
    prometheus::Counter *_refusedConnection;           
    prometheus::Counter *_totalConnection;             
    prometheus::Counter *_totalUploadBytes;            
    prometheus::Counter *_totalDownloadBytes;          
    prometheus::Summary *_sessionDuration;             
    prometheus::Gauge *_maxSessionDuration;            
    prometheus::Gauge *_minSessionDuration;            
 
  public:
    TelnetStats(const std::shared_ptr<prometheus::Registry> &reg, uint16_t portNumber,
                const std::string &prependName = "");
 
    void consumeStats(const TelnetSessionStats &stat, bool sessionClosed);
 
    void consumeStats(const TelnetServerStats &stat);
};