BaseServerStats Class Reference

#include <BaseServerStats.hpp>

Inheritance diagram for BaseServerStats:

Protected Member Functions
void	initBaseStats (const std::shared_ptr< prometheus::Registry > &reg, const std::string &name)
void	consumeBaseStats (uint64_t succeeded, uint64_t failed, double processingTime)

Private Attributes
prometheus::Summary *	_processingTime {nullptr}
	Value of the command processing performance.
prometheus::Gauge *	_maxProcessingTime {nullptr}
	Maximum value of the command processing performance.
prometheus::Gauge *	_minProcessingTime {nullptr}
	Minimum value of the command processing performance.
prometheus::Counter *	_succeededCommand {nullptr}
	Number of succeeded commands.
prometheus::Counter *	_failedCommand {nullptr}
	Number of failed commands.
prometheus::Counter *	_totalCommand {nullptr}
	Number of total received commands.

Detailed Description

Represents the base statistics for a server.

Definition at line 12 of file BaseServerStats.hpp.

Member Function Documentation

consumeBaseStats()

void BaseServerStats::consumeBaseStats ( uint64_t succeeded, uint64_t failed, double processingTime )

protected

Definition at line 46 of file BaseServerStats.cpp.

{
    // Command stats
    _succeededCommand->Increment(static_cast<double>(succeeded));
    _failedCommand->Increment(static_cast<double>(failed));
    _totalCommand->Increment(static_cast<double>(succeeded + failed));
 
    // Performance stats
    if (processingTime > 0)
    {
        _processingTime->Observe(processingTime);
        _maxProcessingTime->Set(std::max(_maxProcessingTime->Value(), processingTime));
        _minProcessingTime->Set(std::min(_minProcessingTime->Value(), processingTime));
    }
}

Here is the caller graph for this function:

initBaseStats()

void BaseServerStats::initBaseStats ( const std::shared_ptr< prometheus::Registry > & reg, const std::string & name )

protected

Definition at line 6 of file BaseServerStats.cpp.

{
    // Command stats
    _succeededCommand = &prometheus::BuildCounter()
                             .Name(name + "succeeded_commands")
                             .Help("Number of succeeded commands")
                             .Register(*reg)
                             .Add({});
    _failedCommand = &prometheus::BuildCounter()
                          .Name(name + "failed_commands")
                          .Help("Number of failed commands")
                          .Register(*reg)
                          .Add({});
    _totalCommand = &prometheus::BuildCounter()
                         .Name(name + "received_commands")
                         .Help("Number of received commands")
                         .Register(*reg)
                         .Add({});
 
    // Performance stats
    _processingTime = &prometheus::BuildSummary()
                           .Name(name + "processing_time")
                           .Help("Command processing performance")
                           .Register(*reg)
                           .Add({}, QUANTILE_DEFAULTS);
    _maxProcessingTime = &prometheus::BuildGauge()
                              .Name(name + "maximum_processing_time")
                              .Help("Maximum value of the command processing performance")
                              .Register(*reg)
                              .Add({});
    _minProcessingTime = &prometheus::BuildGauge()
                              .Name(name + "minimum_processing_time")
                              .Help("Minimum value of the command processing performance")
                              .Register(*reg)
                              .Add({});
 
    // Set defaults
    _minProcessingTime->Set(std::numeric_limits<int>::max());
}

Here is the caller graph for this function:

Member Data Documentation

_failedCommand

prometheus::Counter* BaseServerStats::_failedCommand {nullptr}

private

Number of failed commands.

Definition at line 18 of file BaseServerStats.hpp.

{nullptr};   

_maxProcessingTime

prometheus::Gauge* BaseServerStats::_maxProcessingTime {nullptr}

private

Maximum value of the command processing performance.

Definition at line 15 of file BaseServerStats.hpp.

{nullptr};   

_minProcessingTime

prometheus::Gauge* BaseServerStats::_minProcessingTime {nullptr}

private

Minimum value of the command processing performance.

Definition at line 16 of file BaseServerStats.hpp.

{nullptr};   

_processingTime

prometheus::Summary* BaseServerStats::_processingTime {nullptr}

private

Value of the command processing performance.

Definition at line 14 of file BaseServerStats.hpp.

{nullptr};   

_succeededCommand

prometheus::Counter* BaseServerStats::_succeededCommand {nullptr}

private

Number of succeeded commands.

Definition at line 17 of file BaseServerStats.hpp.

{nullptr}; 

_totalCommand

prometheus::Counter* BaseServerStats::_totalCommand {nullptr}

private

Number of total received commands.

Definition at line 19 of file BaseServerStats.hpp.

{nullptr};   

---

The documentation for this class was generated from the following files:

• /__w/Repo-Init/Repo-Init/include/utils/BaseServerStats.hpp
• /__w/Repo-Init/Repo-Init/src/utils/BaseServerStats.cpp