X-Git-Url: https://git.tokkee.org/?p=sysdb.git;a=blobdiff_plain;f=src%2Fcore%2Fstore-private.h;h=2f9d96cd068b989f908ad94b88c071bbf19f3924;hp=3c23ebbb5ad102cdff7794f285a508d4be14b741;hb=b54d9fff4bc9e70efe83123403a4c9f935efb74e;hpb=dfa8850d084337223b41c03385317bf7359c8643 diff --git a/src/core/store-private.h b/src/core/store-private.h index 3c23ebb..2f9d96c 100644 --- a/src/core/store-private.h +++ b/src/core/store-private.h @@ -26,7 +26,7 @@ */ /* - * private data structures used by the store module + * private data structures used by the memstore module */ #ifndef SDB_CORE_STORE_PRIVATE_H @@ -46,8 +46,9 @@ extern "C" { * core types */ -struct sdb_store_obj { +struct sdb_memstore_obj { sdb_object_t super; +#define _name super.name /* object type */ int type; @@ -57,172 +58,200 @@ struct sdb_store_obj { sdb_time_t interval; /* moving average */ char **backends; size_t backends_num; - sdb_store_obj_t *parent; + sdb_memstore_obj_t *parent; }; -#define STORE_OBJ(obj) ((sdb_store_obj_t *)(obj)) -#define STORE_CONST_OBJ(obj) ((const sdb_store_obj_t *)(obj)) +#define STORE_OBJ(obj) ((sdb_memstore_obj_t *)(obj)) +#define STORE_CONST_OBJ(obj) ((const sdb_memstore_obj_t *)(obj)) typedef struct { - sdb_store_obj_t super; + sdb_memstore_obj_t super; sdb_data_t value; -} sdb_attribute_t; -#define ATTR(obj) ((sdb_attribute_t *)(obj)) -#define CONST_ATTR(obj) ((const sdb_attribute_t *)(obj)) +} attr_t; +#define ATTR(obj) ((attr_t *)(obj)) +#define CONST_ATTR(obj) ((const attr_t *)(obj)) typedef struct { - sdb_store_obj_t super; + sdb_memstore_obj_t super; sdb_avltree_t *attributes; -} sdb_service_t; -#define SVC(obj) ((sdb_service_t *)(obj)) -#define CONST_SVC(obj) ((const sdb_service_t *)(obj)) +} service_t; +#define SVC(obj) ((service_t *)(obj)) +#define CONST_SVC(obj) ((const service_t *)(obj)) typedef struct { - sdb_store_obj_t super; + sdb_memstore_obj_t super; sdb_avltree_t *attributes; -} sdb_metric_t; -#define METRIC(obj) ((sdb_metric_t *)(obj)) + struct { + char *type; + char *id; + } store; +} metric_t; +#define METRIC(obj) ((metric_t *)(obj)) typedef struct { - sdb_store_obj_t super; + sdb_memstore_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)) +} host_t; +#define HOST(obj) ((host_t *)(obj)) +#define CONST_HOST(obj) ((const host_t *)(obj)) /* shortcuts for accessing service/host attributes */ #define _last_update super.last_update #define _interval super.interval /* - * conditionals + * querying */ -/* compares an object using the specified conditional and taking the specified - * filter into account */ -typedef int (*cmp_cb)(sdb_store_obj_t *, sdb_store_cond_t *, - sdb_store_matcher_t *); - -struct sdb_store_cond { +struct sdb_memstore_query { sdb_object_t super; - cmp_cb cmp; + sdb_ast_node_t *ast; + sdb_memstore_matcher_t *matcher; + sdb_memstore_matcher_t *filter; }; +#define QUERY(m) ((sdb_memstore_query_t *)(m)) -typedef struct { - sdb_store_cond_t super; - char *name; - sdb_store_expr_t *expr; -} attr_cond_t; -#define ATTR_C(obj) ((attr_cond_t *)(obj)) +/* + * expressions + */ -typedef struct { - sdb_store_cond_t super; - int field; - sdb_store_expr_t *expr; -} obj_cond_t; -#define OBJ_C(obj) ((obj_cond_t *)(obj)) +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_memstore_expr { + sdb_object_t super; + + int type; /* see above */ + int data_type; + + sdb_memstore_expr_t *left; + sdb_memstore_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, + + /* unary operators */ + MATCHER_ISNULL, + MATCHER_ISTRUE, + MATCHER_ISFALSE, + + /* ary operators */ MATCHER_LT, MATCHER_LE, MATCHER_EQ, + MATCHER_NE, MATCHER_GE, MATCHER_GT, - MATCHER_ISNULL, + 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_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_ISNULL) ? "IS NULL" \ + : ((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 { +struct sdb_memstore_matcher { sdb_object_t super; /* type of the matcher */ int type; }; -#define M(m) ((sdb_store_matcher_t *)(m)) +#define M(m) ((sdb_memstore_matcher_t *)(m)) /* infix operator matcher */ typedef struct { - sdb_store_matcher_t super; + sdb_memstore_matcher_t super; /* left and right hand operands */ - sdb_store_matcher_t *left; - sdb_store_matcher_t *right; + sdb_memstore_matcher_t *left; + sdb_memstore_matcher_t *right; } op_matcher_t; #define OP_M(m) ((op_matcher_t *)(m)) /* unary operator matcher */ typedef struct { - sdb_store_matcher_t super; + sdb_memstore_matcher_t super; /* operand */ - sdb_store_matcher_t *op; + sdb_memstore_matcher_t *op; } 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; - - int obj_type; - string_matcher_t name; -} name_matcher_t; -#define NAME_M(m) ((name_matcher_t *)(m)) + sdb_memstore_matcher_t super; + sdb_memstore_expr_t *iter; + sdb_memstore_matcher_t *m; +} iter_matcher_t; +#define ITER_M(m) ((iter_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)) + sdb_memstore_matcher_t super; -typedef struct { - sdb_store_matcher_t super; - char *attr_name; /* we only support matching attributes */ -} isnull_matcher_t; -#define ISNULL_M(m) ((isnull_matcher_t *)(m)) + /* left and right hand expressions */ + sdb_memstore_expr_t *left; + sdb_memstore_expr_t *right; +} cmp_matcher_t; +#define CMP_M(m) ((cmp_matcher_t *)(m)) -/* match using conditionals */ typedef struct { - sdb_store_matcher_t super; - sdb_store_cond_t *cond; -} cond_matcher_t; -#define COND_M(m) ((cond_matcher_t *)(m)) + sdb_memstore_matcher_t super; + sdb_memstore_expr_t *expr; +} unary_matcher_t; +#define UNARY_M(m) ((unary_matcher_t *)(m)) #ifdef __cplusplus } /* extern "C" */