X-Git-Url: https://git.tokkee.org/?p=sysdb.git;a=blobdiff_plain;f=src%2Fcore%2Fstore-private.h;h=4ea2f94bf469aa177f0803fccc2a1218d0b25907;hp=6af3c8e5fb8c08e59002308e45fe4e4d9ea665be;hb=1426e3fcf927d6321fd2cf8595394f817bb1a0e2;hpb=033aa984a8b4be78ced113a3715422841a48d9a8 diff --git a/src/core/store-private.h b/src/core/store-private.h index 6af3c8e..4ea2f94 100644 --- a/src/core/store-private.h +++ b/src/core/store-private.h @@ -33,6 +33,7 @@ #define SDB_CORE_STORE_PRIVATE_H 1 #include "core/store.h" +#include "utils/avltree.h" #include #include @@ -41,6 +42,10 @@ extern "C" { #endif +/* + * core types + */ + struct sdb_store_obj { sdb_object_t super; @@ -50,6 +55,8 @@ struct sdb_store_obj { /* common meta information */ sdb_time_t last_update; sdb_time_t interval; /* moving average */ + char **backends; + size_t backends_num; sdb_store_obj_t *parent; }; #define STORE_OBJ(obj) ((sdb_store_obj_t *)(obj)) @@ -66,7 +73,7 @@ typedef struct { typedef struct { sdb_store_obj_t super; - sdb_llist_t *attributes; + sdb_avltree_t *attributes; } sdb_service_t; #define SVC(obj) ((sdb_service_t *)(obj)) #define CONST_SVC(obj) ((const sdb_service_t *)(obj)) @@ -74,8 +81,20 @@ typedef struct { typedef struct { sdb_store_obj_t super; - sdb_llist_t *services; - sdb_llist_t *attributes; + sdb_avltree_t *attributes; + struct { + char *type; + char *id; + } store; +} sdb_metric_t; +#define METRIC(obj) ((sdb_metric_t *)(obj)) + +typedef struct { + sdb_store_obj_t super; + + sdb_avltree_t *services; + sdb_avltree_t *metrics; + sdb_avltree_t *attributes; } sdb_host_t; #define HOST(obj) ((sdb_host_t *)(obj)) #define CONST_HOST(obj) ((const sdb_host_t *)(obj)) @@ -85,62 +104,105 @@ typedef struct { #define _interval super.interval /* - * conditionals + * querying */ -/* compares a store object using the specified conditional */ -typedef int (*cmp_cb)(sdb_store_obj_t *, sdb_store_cond_t *); - -struct sdb_store_cond { +struct sdb_store_query { sdb_object_t super; - cmp_cb cmp; + sdb_ast_node_t *ast; + sdb_store_matcher_t *matcher; + sdb_store_matcher_t *filter; }; +#define QUERY(m) ((sdb_store_query_t *)(m)) -typedef struct { - sdb_store_cond_t super; - char *name; - sdb_data_t value; -} attr_cond_t; -#define ATTR_C(obj) ((attr_cond_t *)(obj)) +/* + * expressions + */ + +enum { + TYPED_EXPR = -3, /* obj type stored in data.data.integer */ + ATTR_VALUE = -2, /* attr name stored in data.data.string */ + FIELD_VALUE = -1, /* field type stored in data.data.integer */ + /* 0: const value (stored in data) */ + /* >0: operator id */ +}; + +struct sdb_store_expr { + sdb_object_t super; + + int type; /* see above */ + int data_type; + + sdb_store_expr_t *left; + sdb_store_expr_t *right; + + sdb_data_t data; +}; +#define CONST_EXPR(v) { SDB_OBJECT_INIT, 0, (v).type, NULL, NULL, (v) } +#define EXPR_TO_STRING(e) \ + (((e)->type == TYPED_EXPR) ? "" \ + : ((e)->type == ATTR_VALUE) ? "attribute" \ + : ((e)->type == FIELD_VALUE) ? SDB_FIELD_TO_NAME((e)->data.data.integer) \ + : ((e)->type == 0) ? "" \ + : ((e)->type > 0) ? SDB_DATA_OP_TO_STRING((e)->type) \ + : "") /* * matchers */ -/* when adding to this, also update 'matchers' and 'matchers_tostring' - * in store_lookup.c */ +/* when adding to this, also update 'MATCHER_SYM' below and 'matchers' in + * store_lookup.c */ enum { MATCHER_OR, MATCHER_AND, MATCHER_NOT, - MATCHER_NAME, - MATCHER_ATTR, + MATCHER_ANY, + MATCHER_ALL, + MATCHER_IN, + MATCHER_NIN, + + /* unary operators */ + MATCHER_ISNULL, + MATCHER_ISTRUE, + MATCHER_ISFALSE, + + /* ary operators */ MATCHER_LT, MATCHER_LE, MATCHER_EQ, + MATCHER_NE, MATCHER_GE, MATCHER_GT, + MATCHER_REGEX, + MATCHER_NREGEX, + + /* a generic query */ + MATCHER_QUERY, }; #define MATCHER_SYM(t) \ (((t) == MATCHER_OR) ? "OR" \ : ((t) == MATCHER_AND) ? "AND" \ : ((t) == MATCHER_NOT) ? "NOT" \ - : ((t) == MATCHER_NAME) ? "NAME" \ - : ((t) == MATCHER_ATTR) ? "ATTR" \ + : ((t) == MATCHER_ANY) ? "ANY" \ + : ((t) == MATCHER_ALL) ? "ALL" \ + : ((t) == MATCHER_IN) ? "IN" \ + : ((t) == MATCHER_NIN) ? "NOT IN" \ + : ((t) == MATCHER_ISNULL) ? "IS NULL" \ + : ((t) == MATCHER_ISTRUE) ? "IS TRUE" \ + : ((t) == MATCHER_ISFALSE) ? "IS FALSE" \ : ((t) == MATCHER_LT) ? "<" \ : ((t) == MATCHER_LE) ? "<=" \ : ((t) == MATCHER_EQ) ? "=" \ + : ((t) == MATCHER_NE) ? "!=" \ : ((t) == MATCHER_GE) ? ">=" \ : ((t) == MATCHER_GT) ? ">" \ + : ((t) == MATCHER_REGEX) ? "=~" \ + : ((t) == MATCHER_NREGEX) ? "!~" \ + : ((t) == MATCHER_QUERY) ? "QUERY" \ : "UNKNOWN") -/* match the name of something */ -typedef struct { - char *name; - regex_t *name_re; -} string_matcher_t; - /* matcher base type */ struct sdb_store_matcher { sdb_object_t super; @@ -168,29 +230,29 @@ typedef struct { } uop_matcher_t; #define UOP_M(m) ((uop_matcher_t *)(m)) -/* match any type of object by it's name */ +/* iter matcher */ typedef struct { sdb_store_matcher_t super; + sdb_store_expr_t *iter; + sdb_store_matcher_t *m; +} iter_matcher_t; +#define ITER_M(m) ((iter_matcher_t *)(m)) - int obj_type; - string_matcher_t name; -} name_matcher_t; -#define NAME_M(m) ((name_matcher_t *)(m)) - -/* match attributes */ +/* compare operator matcher */ typedef struct { sdb_store_matcher_t super; - char *name; - string_matcher_t value; -} attr_matcher_t; -#define ATTR_M(m) ((attr_matcher_t *)(m)) -/* match using conditionals */ + /* left and right hand expressions */ + sdb_store_expr_t *left; + sdb_store_expr_t *right; +} cmp_matcher_t; +#define CMP_M(m) ((cmp_matcher_t *)(m)) + typedef struct { sdb_store_matcher_t super; - sdb_store_cond_t *cond; -} cond_matcher_t; -#define COND_M(m) ((cond_matcher_t *)(m)) + sdb_store_expr_t *expr; +} unary_matcher_t; +#define UNARY_M(m) ((unary_matcher_t *)(m)) #ifdef __cplusplus } /* extern "C" */