mirror of
https://github.com/netdata/netdata.git
synced 2025-05-18 15:11:22 +00:00
080e0aee27
* faster rrdeng_load_metric_next() * no need to check validity for number - already done at the query side * solve discrepancy between query create and free * inline unpack_storage_number
119 lines
5.5 KiB
C
119 lines
5.5 KiB
C
// SPDX-License-Identifier: GPL-3.0-or-later
|
|
|
|
#ifndef NETDATA_QUERIES_RRDR_H
|
|
#define NETDATA_QUERIES_RRDR_H
|
|
|
|
#include "libnetdata/libnetdata.h"
|
|
|
|
typedef enum rrdr_options {
|
|
RRDR_OPTION_NONZERO = 0x00000001, // don't output dimensions with just zero values
|
|
RRDR_OPTION_REVERSED = 0x00000002, // output the rows in reverse order (oldest to newest)
|
|
RRDR_OPTION_ABSOLUTE = 0x00000004, // values positive, for DATASOURCE_SSV before summing
|
|
RRDR_OPTION_MIN2MAX = 0x00000008, // when adding dimensions, use max - min, instead of sum
|
|
RRDR_OPTION_SECONDS = 0x00000010, // output seconds, instead of dates
|
|
RRDR_OPTION_MILLISECONDS = 0x00000020, // output milliseconds, instead of dates
|
|
RRDR_OPTION_NULL2ZERO = 0x00000040, // do not show nulls, convert them to zeros
|
|
RRDR_OPTION_OBJECTSROWS = 0x00000080, // each row of values should be an object, not an array
|
|
RRDR_OPTION_GOOGLE_JSON = 0x00000100, // comply with google JSON/JSONP specs
|
|
RRDR_OPTION_JSON_WRAP = 0x00000200, // wrap the response in a JSON header with info about the result
|
|
RRDR_OPTION_LABEL_QUOTES = 0x00000400, // in CSV output, wrap header labels in double quotes
|
|
RRDR_OPTION_PERCENTAGE = 0x00000800, // give values as percentage of total
|
|
RRDR_OPTION_NOT_ALIGNED = 0x00001000, // do not align charts for persistent timeframes
|
|
RRDR_OPTION_DISPLAY_ABS = 0x00002000, // for badges, display the absolute value, but calculate colors with sign
|
|
RRDR_OPTION_MATCH_IDS = 0x00004000, // when filtering dimensions, match only IDs
|
|
RRDR_OPTION_MATCH_NAMES = 0x00008000, // when filtering dimensions, match only names
|
|
RRDR_OPTION_CUSTOM_VARS = 0x00010000, // when wrapping response in a JSON, return custom variables in response
|
|
RRDR_OPTION_ALLOW_PAST = 0x00020000, // The after parameter can extend in the past before the first entry
|
|
RRDR_OPTION_ANOMALY_BIT = 0x00040000, // Return the anomaly bit stored in each collected_number
|
|
} RRDR_OPTIONS;
|
|
|
|
typedef enum rrdr_value_flag {
|
|
RRDR_VALUE_NOTHING = 0x00, // no flag set (a good default)
|
|
RRDR_VALUE_EMPTY = 0x01, // the database value is empty
|
|
RRDR_VALUE_RESET = 0x02, // the database value is marked as reset (overflown)
|
|
} RRDR_VALUE_FLAGS;
|
|
|
|
typedef enum rrdr_dimension_flag {
|
|
RRDR_DIMENSION_DEFAULT = 0x00,
|
|
RRDR_DIMENSION_HIDDEN = 0x04, // the dimension is hidden (not to be presented to callers)
|
|
RRDR_DIMENSION_NONZERO = 0x08, // the dimension is non zero (contains non-zero values)
|
|
RRDR_DIMENSION_SELECTED = 0x10, // the dimension is selected for evaluation in this RRDR
|
|
} RRDR_DIMENSION_FLAGS;
|
|
|
|
// RRDR result options
|
|
typedef enum rrdr_result_flags {
|
|
RRDR_RESULT_OPTION_ABSOLUTE = 0x00000001, // the query uses absolute time-frames
|
|
// (can be cached by browsers and proxies)
|
|
RRDR_RESULT_OPTION_RELATIVE = 0x00000002, // the query uses relative time-frames
|
|
// (should not to be cached by browsers and proxies)
|
|
RRDR_RESULT_OPTION_VARIABLE_STEP = 0x00000004, // the query uses variable-step time-frames
|
|
RRDR_RESULT_OPTION_CANCEL = 0x00000008, // the query needs to be cancelled
|
|
} RRDR_RESULT_FLAGS;
|
|
|
|
typedef struct rrdresult {
|
|
struct rrdset *st; // the chart this result refers to
|
|
|
|
RRDR_RESULT_FLAGS result_options; // RRDR_RESULT_OPTION_*
|
|
|
|
int d; // the number of dimensions
|
|
long n; // the number of values in the arrays
|
|
long rows; // the number of rows used
|
|
|
|
RRDR_DIMENSION_FLAGS *od; // the options for the dimensions
|
|
|
|
time_t *t; // array of n timestamps
|
|
calculated_number *v; // array n x d values
|
|
RRDR_VALUE_FLAGS *o; // array n x d options for each value returned
|
|
|
|
long group; // how many collected values were grouped for each row
|
|
int update_every; // what is the suggested update frequency in seconds
|
|
|
|
calculated_number min;
|
|
calculated_number max;
|
|
|
|
time_t before;
|
|
time_t after;
|
|
|
|
int has_st_lock; // if st is read locked by us
|
|
uint8_t st_needs_lock; // if ST should be locked
|
|
|
|
// internal rrd2rrdr() members below this point
|
|
struct {
|
|
long points_wanted;
|
|
long resampling_group;
|
|
calculated_number resampling_divisor;
|
|
|
|
void (*grouping_create)(struct rrdresult *r);
|
|
void (*grouping_reset)(struct rrdresult *r);
|
|
void (*grouping_free)(struct rrdresult *r);
|
|
void (*grouping_add)(struct rrdresult *r, calculated_number value);
|
|
calculated_number (*grouping_flush)(struct rrdresult *r, RRDR_VALUE_FLAGS *rrdr_value_options_ptr);
|
|
void *grouping_data;
|
|
|
|
#ifdef NETDATA_INTERNAL_CHECKS
|
|
const char *log;
|
|
#endif
|
|
|
|
size_t db_points_read;
|
|
size_t result_points_generated;
|
|
} internal;
|
|
} RRDR;
|
|
|
|
#define rrdr_rows(r) ((r)->rows)
|
|
|
|
#include "database/rrd.h"
|
|
extern void rrdr_free(ONEWAYALLOC *owa, RRDR *r);
|
|
extern RRDR *rrdr_create(ONEWAYALLOC *owa, struct rrdset *st, long n, struct context_param *context_param_list);
|
|
|
|
#include "../web_api_v1.h"
|
|
#include "web/api/queries/query.h"
|
|
|
|
extern RRDR *rrd2rrdr(
|
|
ONEWAYALLOC *owa,
|
|
RRDSET *st, long points_requested, long long after_requested, long long before_requested,
|
|
RRDR_GROUPING group_method, long resampling_time_requested, RRDR_OPTIONS options, const char *dimensions,
|
|
struct context_param *context_param_list, int timeout);
|
|
|
|
#include "query.h"
|
|
|
|
#endif //NETDATA_QUERIES_RRDR_H
|