kcenon::monitoring::time_point_data Struct Reference

Single data point in time series. More...

#include <time_series.h>

Collaboration diagram for kcenon::monitoring::time_point_data:

Public Member Functions
	time_point_data () noexcept
	time_point_data (std::chrono::system_clock::time_point ts, double val, uint32_t count=1) noexcept
void	merge (const time_point_data &other)
	Merge another data point (for aggregation)
bool	is_valid (std::chrono::system_clock::time_point cutoff) const noexcept
	Check if this point is within retention period.

Public Attributes
std::chrono::system_clock::time_point	timestamp
double	value
uint32_t	sample_count

Detailed Description

Single data point in time series.

Definition at line 71 of file time_series.h.

Constructor & Destructor Documentation

time_point_data() [1/2]

kcenon::monitoring::time_point_data::time_point_data ( )

inlinenoexcept

Definition at line 76 of file time_series.h.

: value(0.0), sample_count(0) {}

time_point_data() [2/2]

kcenon::monitoring::time_point_data::time_point_data ( std::chrono::system_clock::time_point ts, double val, uint32_t count = 1 )

inlinenoexcept

Definition at line 78 of file time_series.h.

        : timestamp(ts), value(val), sample_count(count) {}

Member Function Documentation

is_valid()

bool kcenon::monitoring::time_point_data::is_valid ( std::chrono::system_clock::time_point cutoff ) const

inlinenoexcept

Check if this point is within retention period.

Definition at line 102 of file time_series.h.

                                                                         {
        return timestamp >= cutoff;
    }

References timestamp.

merge()

void kcenon::monitoring::time_point_data::merge ( const time_point_data & other )

inline

Merge another data point (for aggregation)

Definition at line 84 of file time_series.h.

                                             {
        if (sample_count == 0) {
            *this = other;
        } else if (other.sample_count > 0) {
            double total_weight = sample_count + other.sample_count;
            value = (value * sample_count + other.value * other.sample_count) / total_weight;
            sample_count += other.sample_count;
            
            // Use the later timestamp
            if (other.timestamp > timestamp) {
                timestamp = other.timestamp;
            }
        }
    }

References kcenon::monitoring::other, sample_count, timestamp, and value.

Referenced by kcenon::monitoring::time_series::query().

Here is the caller graph for this function:

Member Data Documentation

sample_count

uint32_t kcenon::monitoring::time_point_data::sample_count

Definition at line 74 of file time_series.h.

Referenced by merge().

timestamp

std::chrono::system_clock::time_point kcenon::monitoring::time_point_data::timestamp

Definition at line 72 of file time_series.h.

Referenced by kcenon::monitoring::time_series::add_point(), is_valid(), merge(), and kcenon::monitoring::time_series::query().

value

double kcenon::monitoring::time_point_data::value

Definition at line 73 of file time_series.h.

Referenced by merge().

---

The documentation for this struct was generated from the following file:

• include/kcenon/monitoring/utils/time_series.h