X-Git-Url: https://git.tokkee.org/?p=sysdb.git;a=blobdiff_plain;f=src%2Fcore%2Fstore-private.h;h=e8514879c1e8ba43ad5af1ec89791a09452357e0;hp=3f070678dad16393c5ada4a6f0bf98fa13c861ff;hb=ed2c9fc3e4ca6840a5a31c735f0cfc02fd21d4fc;hpb=0e369b5129e64580e444e7d7ef4033a9d2995a28 diff --git a/src/core/store-private.h b/src/core/store-private.h index 3f07067..e851487 100644 --- a/src/core/store-private.h +++ b/src/core/store-private.h @@ -48,6 +48,7 @@ extern "C" { struct sdb_store_obj { sdb_object_t super; +#define _name super.name /* object type */ int type; @@ -66,99 +67,141 @@ typedef struct { sdb_store_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_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_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)) +} 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_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_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_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, + + /* 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 { sdb_object_t super; @@ -186,35 +229,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)) -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_store_expr_t *left; + sdb_store_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_store_expr_t *expr; +} unary_matcher_t; +#define UNARY_M(m) ((unary_matcher_t *)(m)) #ifdef __cplusplus } /* extern "C" */