X-Git-Url: https://git.tokkee.org/?p=sysdb.git;a=blobdiff_plain;f=src%2Fcore%2Fstore-private.h;h=1342a5b58fca93508d93f00571753be9b7e3d5db;hp=a5bf0267b7e41bd598135ee28048f697ec3d93f7;hb=d8d03b18f0e0a4c39e2adec3cc2cd093d52c1f93;hpb=2f08ce28937ba7755da12aa47a4a520ad39694a8 diff --git a/src/core/store-private.h b/src/core/store-private.h index a5bf026..1342a5b 100644 --- a/src/core/store-private.h +++ b/src/core/store-private.h @@ -33,12 +33,20 @@ #define SDB_CORE_STORE_PRIVATE_H 1 #include "core/store.h" +#include "utils/avltree.h" + +#include +#include #ifdef __cplusplus extern "C" { #endif -struct sdb_store_base { +/* + * core types + */ + +struct sdb_store_obj { sdb_object_t super; /* object type */ @@ -47,43 +55,201 @@ struct sdb_store_base { /* common meta information */ sdb_time_t last_update; sdb_time_t interval; /* moving average */ - sdb_store_base_t *parent; + char **backends; + size_t backends_num; + sdb_store_obj_t *parent; }; -#define STORE_BASE(obj) ((sdb_store_base_t *)(obj)) -#define STORE_CONST_BASE(obj) ((const sdb_store_base_t *)(obj)) +#define STORE_OBJ(obj) ((sdb_store_obj_t *)(obj)) +#define STORE_CONST_OBJ(obj) ((const sdb_store_obj_t *)(obj)) typedef struct { - sdb_store_base_t super; + sdb_store_obj_t super; sdb_data_t value; } sdb_attribute_t; -#define SDB_ATTR(obj) ((sdb_attribute_t *)(obj)) -#define SDB_CONST_ATTR(obj) ((const sdb_attribute_t *)(obj)) +#define ATTR(obj) ((sdb_attribute_t *)(obj)) +#define CONST_ATTR(obj) ((const sdb_attribute_t *)(obj)) typedef struct { - sdb_store_base_t super; + sdb_store_obj_t super; - sdb_llist_t *children; - sdb_llist_t *attributes; -} sdb_store_obj_t; -#define SDB_STORE_OBJ(obj) ((sdb_store_obj_t *)(obj)) -#define SDB_CONST_STORE_OBJ(obj) ((const sdb_store_obj_t *)(obj)) + sdb_avltree_t *attributes; +} sdb_service_t; +#define SVC(obj) ((sdb_service_t *)(obj)) +#define CONST_SVC(obj) ((const sdb_service_t *)(obj)) -enum { - SDB_HOST = 1, - SDB_SERVICE, - SDB_ATTRIBUTE, -}; -#define TYPE_TO_NAME(t) \ - (((t) == SDB_HOST) ? "host" \ - : ((t) == SDB_SERVICE) ? "service" \ - : ((t) == SDB_ATTRIBUTE) ? "attribute" : "unknown") +typedef struct { + sdb_store_obj_t super; -/* shortcuts for accessing the sdb_store_obj_t attributes - * of inheriting objects */ + 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)) + +/* shortcuts for accessing service/host attributes */ #define _last_update super.last_update #define _interval super.interval +/* + * querying + */ + +struct sdb_store_query { + sdb_object_t super; + sdb_ast_node_t *ast; + sdb_store_matcher_t *matcher; + sdb_store_matcher_t *filter; +}; +#define QUERY(m) ((sdb_store_query_t *)(m)) + +/* + * 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 'MATCHER_SYM' below and 'matchers' in + * store_lookup.c */ +enum { + MATCHER_OR, + MATCHER_AND, + MATCHER_NOT, + MATCHER_ANY, + MATCHER_ALL, + MATCHER_IN, + MATCHER_NIN, + + /* unary operators */ + MATCHER_ISNULL, + + /* 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_ANY) ? "ANY" \ + : ((t) == MATCHER_ALL) ? "ALL" \ + : ((t) == MATCHER_IN) ? "IN" \ + : ((t) == MATCHER_NIN) ? "NOT IN" \ + : ((t) == MATCHER_ISNULL) ? "IS NULL" \ + : ((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") + +/* matcher base type */ +struct sdb_store_matcher { + sdb_object_t super; + /* type of the matcher */ + int type; +}; +#define M(m) ((sdb_store_matcher_t *)(m)) + +/* infix operator matcher */ +typedef struct { + sdb_store_matcher_t super; + + /* left and right hand operands */ + sdb_store_matcher_t *left; + sdb_store_matcher_t *right; +} op_matcher_t; +#define OP_M(m) ((op_matcher_t *)(m)) + +/* unary operator matcher */ +typedef struct { + sdb_store_matcher_t super; + + /* operand */ + sdb_store_matcher_t *op; +} uop_matcher_t; +#define UOP_M(m) ((uop_matcher_t *)(m)) + +/* 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)) + +/* compare operator matcher */ +typedef struct { + sdb_store_matcher_t super; + + /* 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_expr_t *expr; +} isnull_matcher_t; +#define ISNULL_M(m) ((isnull_matcher_t *)(m)) + #ifdef __cplusplus } /* extern "C" */ #endif