stats.h

Go to the documentation of this file.

#include "qev.h"

#define qev_stats_counter_inc(counter) qev_stats_counter_add(counter, 1);

#define qev_stats_counter_dec(counter) qev_stats_counter_add(counter, -1);

#define qev_stats_time(timer, block) { \
        gint64 qev_stats_timer_start = g_get_monotonic_time(); \
        block; \
        qev_stats_timer_record(timer, g_get_monotonic_time() - qev_stats_timer_start); }

struct qev_stats_threshold {
        gboolean active;

        gboolean has_warn;

        gboolean warn_greater;

        gint64 warn;

        gboolean has_crit;

        gboolean crit_greater;

        gint64 crit;
};

typedef gint (*qev_stats_monitor_fn)(
        const gint64 val,
        const struct qev_stats_threshold thresh,
        GString *msg);

typedef struct qev_stats_gauge qev_stats_gauge_t;

typedef struct qev_stats_counter qev_stats_counter_t;

typedef struct qev_stats_timer qev_stats_timer_t;

qev_stats_gauge_t* qev_stats_gauge(
        const gchar *prefix,
        const gchar *name,
        const gchar *description);

qev_stats_gauge_t* qev_stats_gauge_monitor(
        const gchar *prefix,
        const gchar *name,
        const qev_stats_monitor_fn monitor,
        const gchar *description);

void qev_stats_gauge_set(qev_stats_gauge_t *gauge, gint64 val);

gint64 qev_stats_gauge_get(qev_stats_gauge_t *gauge);

qev_stats_counter_t* qev_stats_counter(
        const gchar *prefix,
        const gchar *name,
        const gboolean reset_on_flush,
        const gchar *description);

qev_stats_counter_t* qev_stats_counter_monitor(
        const gchar *prefix,
        const gchar *name,
        const gboolean reset_on_flush,
        const qev_stats_monitor_fn monitor,
        const gchar *description);

gint64 qev_stats_counter_add(qev_stats_counter_t *counter, const gint64 val);

gint64 qev_stats_counter_get(qev_stats_counter_t *counter);

qev_stats_timer_t* qev_stats_timer(
        const gchar *prefix,
        const gchar *name,
        const gchar *description);

qev_stats_timer_t* qev_stats_timer_monitor(
        const gchar *prefix,
        const gchar *name,
        const qev_stats_monitor_fn monitor_sum,
        const qev_stats_monitor_fn monitor_stddev,
        const qev_stats_monitor_fn monitor_mean,
        const qev_stats_monitor_fn monitor_max,
        const qev_stats_monitor_fn monitor_min,
        const qev_stats_monitor_fn monitor_count,
        const gchar *description);

void qev_stats_timer_record(
        qev_stats_timer_t *timer,
        const gint64 us);