src/health.h

   1 #ifndef NETDATA_HEALTH_H
   2 #define NETDATA_HEALTH_H
   3
   4 extern int health_enabled;
   5
   6 extern int rrdvar_compare(void *a, void *b);
   7
   8 #define RRDVAR_TYPE_CALCULATED 1
   9 #define RRDVAR_TYPE_TIME_T     2
  10 #define RRDVAR_TYPE_COLLECTED  3
  11 #define RRDVAR_TYPE_TOTAL      4
  12 #define RRDVAR_TYPE_INT        5
  13
  14 // the variables as stored in the variables indexes
  15 // there are 3 indexes:
  16 // 1. at each chart   (RRDSET.variables_root_index)
  17 // 2. at each context (RRDFAMILY.variables_root_index)
  18 // 3. at each host    (RRDHOST.variables_root_index)
  19 typedef struct rrdvar {
  20     avl avl;
  21
  22     char *name;
  23     uint32_t hash;
  24
  25     int type;
  26     void *value;
  27
  28     time_t last_updated;
  29 } RRDVAR;
  30
  31 // variables linked to charts
  32 // We link variables to point to the values that are already
  33 // calculated / processed by the normal data collection process
  34 // This means, there will be no speed penalty for using
  35 // these variables
  36 typedef struct rrdsetvar {
  37     char *fullid;               // chart type.chart id.variable
  38     char *fullname;             // chart type.chart name.variable
  39     char *variable;             // variable
  40
  41     int type;
  42     void *value;
  43
  44     uint32_t options;
  45
  46     RRDVAR *local;
  47     RRDVAR *family;
  48     RRDVAR *host;
  49     RRDVAR *family_name;
  50     RRDVAR *host_name;
  51
  52     struct rrdset *rrdset;
  53
  54     struct rrdsetvar *next;
  55 } RRDSETVAR;
  56
  57
  58 // variables linked to individual dimensions
  59 // We link variables to point the values that are already
  60 // calculated / processed by the normal data collection process
  61 // This means, there will be no speed penalty for using
  62 // these variables
  63 typedef struct rrddimvar {
  64     char *prefix;
  65     char *suffix;
  66
  67     char *id;                   // dimension id
  68     char *name;                 // dimension name
  69     char *fullidid;             // chart type.chart id.dimension id
  70     char *fullidname;           // chart type.chart id.dimension name
  71     char *fullnameid;           // chart type.chart name.dimension id
  72     char *fullnamename;         // chart type.chart name.dimension name
  73
  74     int type;
  75     void *value;
  76
  77     uint32_t options;
  78
  79     RRDVAR *local_id;
  80     RRDVAR *local_name;
  81
  82     RRDVAR *family_id;
  83     RRDVAR *family_name;
  84
  85     RRDVAR *host_fullidid;
  86     RRDVAR *host_fullidname;
  87     RRDVAR *host_fullnameid;
  88     RRDVAR *host_fullnamename;
  89
  90     struct rrddim *rrddim;
  91
  92     struct rrddimvar *next;
  93 } RRDDIMVAR;
  94
  95 // calculated variables (defined in health configuration)
  96 // These aggregate time-series data at fixed intervals
  97 // (defined in their update_every member below)
  98 // These increase the overhead of netdata.
  99 //
 100 // These calculations are allocated and linked (->next)
 101 // under RRDHOST.
 102 // Then are also linked to RRDSET (of course only when the
 103 // chart is found, via ->rrdset_next and ->rrdset_prev).
 104 // This double-linked list is maintained sorted at all times
 105 // having as RRDSET.calculations the RRDCALC to be processed
 106 // next.
 107
 108 #define RRDCALC_STATUS_REMOVED       -2
 109 #define RRDCALC_STATUS_UNDEFINED     -1
 110 #define RRDCALC_STATUS_UNINITIALIZED  0
 111 #define RRDCALC_STATUS_CLEAR          1
 112 #define RRDCALC_STATUS_RAISED         2
 113 #define RRDCALC_STATUS_WARNING        3
 114 #define RRDCALC_STATUS_CRITICAL       4
 115
 116 #define RRDCALC_FLAG_DB_ERROR      0x00000001
 117 #define RRDCALC_FLAG_DB_NAN        0x00000002
 118 #define RRDCALC_FLAG_DB_STALE      0x00000004
 119 #define RRDCALC_FLAG_CALC_ERROR    0x00000008
 120 #define RRDCALC_FLAG_WARN_ERROR    0x00000010
 121 #define RRDCALC_FLAG_CRIT_ERROR    0x00000020
 122
 123 typedef struct rrdcalc {
 124     uint32_t id;
 125     uint32_t next_event_id;
 126
 127     char *name;
 128     uint32_t hash;
 129
 130     char *exec;
 131     char *recipient;
 132
 133     char *chart;        // the chart id this should be linked to
 134     uint32_t hash_chart;
 135
 136     char *source;       // the source of this calculation
 137     char *units;
 138     char *info;
 139
 140     char *dimensions;   // the chart dimensions
 141
 142     int group;          // grouping method: average, max, etc.
 143     int before;         // ending point in time-series
 144     int after;          // starting point in time-series
 145     uint32_t options;   // calculation options
 146     int update_every;   // update frequency for the calculation
 147
 148     time_t last_updated;
 149     time_t next_update;
 150
 151     EVAL_EXPRESSION *calculation;
 152     EVAL_EXPRESSION *warning;
 153     EVAL_EXPRESSION *critical;
 154
 155     uint32_t rrdcalc_flags;
 156     int status;
 157
 158     time_t db_after;
 159     time_t db_before;
 160     time_t last_status_change;
 161
 162     calculated_number value;
 163     calculated_number old_value;
 164
 165     calculated_number green;
 166     calculated_number red;
 167
 168     RRDVAR *local;
 169     RRDVAR *family;
 170     RRDVAR *hostid;
 171     RRDVAR *hostname;
 172
 173     struct rrdset *rrdset;
 174     struct rrdcalc *rrdset_next;
 175     struct rrdcalc *rrdset_prev;
 176
 177     struct rrdcalc *next;
 178 } RRDCALC;
 179
 180 #define RRDCALC_HAS_DB_LOOKUP(rc) ((rc)->after)
 181
 182 // RRDCALCTEMPLATE
 183 // these are to be applied to charts found dynamically
 184 // based on their context.
 185 typedef struct rrdcalctemplate {
 186     char *name;
 187     uint32_t hash_name;
 188
 189     char *exec;
 190     char *recipient;
 191
 192     char *context;
 193     uint32_t hash_context;
 194
 195     char *source;       // the source of this template
 196     char *units;
 197     char *info;
 198
 199     char *dimensions;
 200
 201     int group;          // grouping method: average, max, etc.
 202     int before;         // ending point in time-series
 203     int after;          // starting point in time-series
 204     uint32_t options;   // calculation options
 205     int update_every;   // update frequency for the calculation
 206
 207     EVAL_EXPRESSION *calculation;
 208     EVAL_EXPRESSION *warning;
 209     EVAL_EXPRESSION *critical;
 210
 211     calculated_number green;
 212     calculated_number red;
 213
 214     struct rrdcalctemplate *next;
 215 } RRDCALCTEMPLATE;
 216
 217 #define RRDCALCTEMPLATE_HAS_CALCULATION(rt) ((rt)->after)
 218
 219 #define HEALTH_ENTRY_NOTIFICATIONS_PROCESSED    0x00000001
 220 #define HEALTH_ENTRY_NOTIFICATIONS_UPDATED      0x00000002
 221 #define HEALTH_ENTRY_NOTIFICATIONS_EXEC_RUN     0x00000004
 222 #define HEALTH_ENTRY_NOTIFICATIONS_EXEC_FAILED  0x00000008
 223
 224 typedef struct alarm_entry {
 225     uint32_t unique_id;
 226     uint32_t alarm_id;
 227     uint32_t alarm_event_id;
 228
 229     time_t when;
 230     time_t duration;
 231     time_t non_clear_duration;
 232
 233     char *name;
 234     uint32_t hash_name;
 235
 236     char *chart;
 237     uint32_t hash_chart;
 238
 239     char *family;
 240
 241     char *exec;
 242     char *recipient;
 243     int exec_code;
 244
 245     char *source;
 246     char *units;
 247     char *info;
 248
 249     calculated_number old_value;
 250     calculated_number new_value;
 251     int old_status;
 252     int new_status;
 253
 254     uint32_t notifications;
 255
 256     struct alarm_entry *updated_by;
 257     struct alarm_entry *next;
 258 } ALARM_ENTRY;
 259
 260 typedef struct alarm_log {
 261     uint32_t next_log_id;
 262     uint32_t next_alarm_id;
 263     unsigned int count;
 264     unsigned int max;
 265     ALARM_ENTRY *alarms;
 266     pthread_rwlock_t alarm_log_rwlock;
 267 } ALARM_LOG;
 268
 269 #include "rrd.h"
 270
 271 extern void rrdsetvar_rename_all(RRDSET *st);
 272 extern RRDSETVAR *rrdsetvar_create(RRDSET *st, const char *variable, int type, void *value, uint32_t options);
 273 extern void rrdsetvar_free(RRDSETVAR *rs);
 274
 275 extern void rrddimvar_rename_all(RRDDIM *rd);
 276 extern RRDDIMVAR *rrddimvar_create(RRDDIM *rd, int type, const char *prefix, const char *suffix, void *value, uint32_t options);
 277 extern void rrddimvar_free(RRDDIMVAR *rs);
 278
 279 extern void rrdsetcalc_link_matching(RRDSET *st);
 280 extern void rrdsetcalc_unlink(RRDCALC *rc);
 281 extern void rrdcalctemplate_link_matching(RRDSET *st);
 282 extern RRDCALC *rrdcalc_find(RRDSET *st, const char *name);
 283
 284 extern void health_init(void);
 285 extern void *health_main(void *ptr);
 286
 287 extern void health_reload(void);
 288
 289 extern int health_variable_lookup(const char *variable, uint32_t hash, RRDCALC *rc, calculated_number *result);
 290 extern void health_alarms2json(RRDHOST *host, BUFFER *wb, int all);
 291 extern void health_alarm_log2json(RRDHOST *host, BUFFER *wb, uint32_t after);
 292
 293 #endif //NETDATA_HEALTH_H