stream_aggregator.h File Reference

Streaming statistical aggregation for real-time metrics. More...

#include "../core/result_types.h"
#include "../core/error_codes.h"
#include <algorithm>
#include <atomic>
#include <chrono>
#include <cmath>
#include <deque>
#include <map>
#include <mutex>
#include <optional>
#include <shared_mutex>
#include <vector>

Include dependency graph for stream_aggregator.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	kcenon::monitoring::streaming_statistics
	Statistical summary from streaming computation. More...
class	kcenon::monitoring::online_statistics
	Welford's algorithm for computing streaming statistics. More...
class	kcenon::monitoring::quantile_estimator
	P² algorithm for streaming quantile estimation. More...
class	kcenon::monitoring::moving_window_aggregator< T >
	Time-windowed value collection. More...
struct	kcenon::monitoring::moving_window_aggregator< T >::entry
struct	kcenon::monitoring::stream_aggregator_config
	Configuration for stream aggregator. More...
class	kcenon::monitoring::stream_aggregator
	Full-featured streaming aggregation. More...

Namespaces
namespace	kcenon
namespace	kcenon::monitoring

Functions
double	kcenon::monitoring::pearson_correlation (const std::vector< double > &x, const std::vector< double > &y)
	Calculate Pearson correlation coefficient.

Detailed Description

Streaming statistical aggregation for real-time metrics.

This file provides streaming aggregation capabilities including:

• online_statistics: Welford's algorithm for streaming statistics
• quantile_estimator: P² algorithm for streaming quantile estimation
• moving_window_aggregator: Time-windowed value collection
• stream_aggregator: Full-featured streaming aggregation

Definition in file stream_aggregator.h.