ZeroMQStats.hpp

Go to the documentation of this file.

#pragma once
 
#include "utils/BaseServerStats.hpp"
 
#include <prometheus/registry.h>
#include <zmq.hpp>
 
struct ZeroMQServerStats {
    std::chrono::high_resolution_clock::time_point processingTimeStart; 
    std::chrono::high_resolution_clock::time_point processingTimeEnd;   
    bool isSuccessful{false}; 
};
 
class ZeroMQStats : private BaseServerStats {
  private:
    prometheus::Family<prometheus::Info> *_infoFamily; 
    prometheus::Counter *_succeededCommandParts;       
    prometheus::Counter *_failedCommandParts;          
    prometheus::Counter *_totalCommandParts;           
    prometheus::Counter *_totalUploadBytes;            
    prometheus::Counter *_totalDownloadBytes;          
 
  public:
    explicit ZeroMQStats(const std::shared_ptr<prometheus::Registry> &reg, const std::string &prependName = "");
 
    void consumeStats(const std::vector<zmq::message_t> &recvMsgs, const std::vector<zmq::message_t> &sendMsgs,
                      const ZeroMQServerStats &serverStats);
};