1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
// SPDX-License-Identifier: GPL-3.0-or-later
#ifndef NETDATA_SQLITE_FUNCTIONS_H
#define NETDATA_SQLITE_FUNCTIONS_H
#include "daemon/common.h"
#include "sqlite3.h"
// return a node list
struct node_instance_list {
uuid_t node_id;
uuid_t host_id;
char *hostname;
int live;
int queryable;
int hops;
};
typedef enum db_check_action_type {
DB_CHECK_NONE = 0x0000,
DB_CHECK_INTEGRITY = 0x0001,
DB_CHECK_FIX_DB = 0x0002,
DB_CHECK_RECLAIM_SPACE = 0x0004,
DB_CHECK_CONT = 0x00008
} db_check_action_type_t;
#define SQL_MAX_RETRY (100)
#define SQLITE_INSERT_DELAY (10) // Insert delay in case of lock
#define CHECK_SQLITE_CONNECTION(db_meta) \
if (unlikely(!db_meta)) { \
if (default_rrd_memory_mode != RRD_MEMORY_MODE_DBENGINE) { \
return 1; \
} \
error_report("Database has not been initialized"); \
return 1; \
}
SQLITE_API int sqlite3_step_monitored(sqlite3_stmt *stmt);
SQLITE_API int sqlite3_exec_monitored(
sqlite3 *db, /* An open database */
const char *sql, /* SQL to be evaluated */
int (*callback)(void*,int,char**,char**), /* Callback function */
void *data, /* 1st argument to callback */
char **errmsg /* Error msg written here */
);
// Initialization and shutdown
int init_database_batch(sqlite3 *database, int rebuild, int init_type, const char *batch[]);
int sql_init_database(db_check_action_type_t rebuild, int memory);
void sql_close_database(void);
// Helpers
int bind_text_null(sqlite3_stmt *res, int position, const char *text, bool can_be_null);
int prepare_statement(sqlite3 *database, const char *query, sqlite3_stmt **statement);
int execute_insert(sqlite3_stmt *res);
int file_is_migrated(char *path);
int exec_statement_with_uuid(const char *sql, uuid_t *uuid);
void add_migrated_file(char *path, uint64_t file_size);
void db_execute(const char *cmd);
// Look up functions
int get_node_id(uuid_t *host_id, uuid_t *node_id);
int get_host_id(uuid_t *node_id, uuid_t *host_id);
struct node_instance_list *get_node_list(void);
void sql_load_node_id(RRDHOST *host);
char *get_hostname_by_node_id(char *node_id);
int sql_find_chart_uuid(RRDHOST *host, RRDSET *st, uuid_t *store_uuid);
int sql_find_dimension_uuid(RRDSET *st, RRDDIM *rd, uuid_t *store_uuid);
// Help build archived hosts in memory when agent starts
void sql_build_host_system_info(uuid_t *host_id, struct rrdhost_system_info *system_info);
DICTIONARY *sql_load_host_labels(uuid_t *host_id);
// For queries: To be removed when context queries are implemented
void sql_rrdset2json(RRDHOST *host, BUFFER *wb);
// TODO: move to metadata
int update_node_id(uuid_t *host_id, uuid_t *node_id);
void invalidate_node_instances(uuid_t *host_id, uuid_t *claim_id);
// Provide statistics
int sql_metadata_cache_stats(int op);
#endif //NETDATA_SQLITE_FUNCTIONS_H
|
