diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-05-05 11:19:16 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-05-05 12:07:37 +0000 |
commit | b485aab7e71c1625cfc27e0f92c9509f42378458 (patch) | |
tree | ae9abe108601079d1679194de237c9a435ae5b55 /database/sqlite/sqlite_aclk.h | |
parent | Adding upstream version 1.44.3. (diff) | |
download | netdata-b485aab7e71c1625cfc27e0f92c9509f42378458.tar.xz netdata-b485aab7e71c1625cfc27e0f92c9509f42378458.zip |
Adding upstream version 1.45.3+dfsg.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'database/sqlite/sqlite_aclk.h')
-rw-r--r-- | database/sqlite/sqlite_aclk.h | 101 |
1 files changed, 0 insertions, 101 deletions
diff --git a/database/sqlite/sqlite_aclk.h b/database/sqlite/sqlite_aclk.h deleted file mode 100644 index 0db2647bf..000000000 --- a/database/sqlite/sqlite_aclk.h +++ /dev/null @@ -1,101 +0,0 @@ -// SPDX-License-Identifier: GPL-3.0-or-later - -#ifndef NETDATA_SQLITE_ACLK_H -#define NETDATA_SQLITE_ACLK_H - -#include "sqlite3.h" - -#ifndef ACLK_MAX_CHART_BATCH -#define ACLK_MAX_CHART_BATCH (200) -#endif -#ifndef ACLK_MAX_CHART_BATCH_COUNT -#define ACLK_MAX_CHART_BATCH_COUNT (10) -#endif -#define ACLK_MAX_ALERT_UPDATES "5" -#define ACLK_DATABASE_CLEANUP_FIRST (1200) -#define ACLK_DATABASE_CLEANUP_INTERVAL (3600) -#define ACLK_DELETE_ACK_ALERTS_INTERNAL (86400) -#define ACLK_SYNC_QUERY_SIZE 512 - -static inline void uuid_unparse_lower_fix(uuid_t *uuid, char *out) -{ - uuid_unparse_lower(*uuid, out); - out[8] = '_'; - out[13] = '_'; - out[18] = '_'; - out[23] = '_'; -} - -static inline int uuid_parse_fix(char *in, uuid_t uuid) -{ - in[8] = '-'; - in[13] = '-'; - in[18] = '-'; - in[23] = '-'; - return uuid_parse(in, uuid); -} - -static inline int claimed() -{ - return localhost->aclk_state.claimed_id != NULL; -} - -#define TABLE_ACLK_ALERT \ - "CREATE TABLE IF NOT EXISTS aclk_alert_%s (sequence_id INTEGER PRIMARY KEY, " \ - "alert_unique_id, date_created, date_submitted, date_cloud_ack, filtered_alert_unique_id NOT NULL, " \ - "UNIQUE(alert_unique_id))" - -#define INDEX_ACLK_ALERT1 "CREATE INDEX IF NOT EXISTS aclk_alert_index1_%s ON aclk_alert_%s (filtered_alert_unique_id)" -#define INDEX_ACLK_ALERT2 "CREATE INDEX IF NOT EXISTS aclk_alert_index2_%s ON aclk_alert_%s (date_submitted)" - -enum aclk_database_opcode { - ACLK_DATABASE_NOOP = 0, - - ACLK_DATABASE_CLEANUP, - ACLK_DATABASE_DELETE_HOST, - ACLK_DATABASE_NODE_STATE, - ACLK_DATABASE_PUSH_ALERT, - ACLK_DATABASE_PUSH_ALERT_CONFIG, - ACLK_DATABASE_PUSH_ALERT_SNAPSHOT, - ACLK_DATABASE_PUSH_ALERT_CHECKPOINT, - ACLK_DATABASE_QUEUE_REMOVED_ALERTS, - ACLK_DATABASE_NODE_UNREGISTER, - ACLK_DATABASE_TIMER, - - // leave this last - // we need it to check for worker utilization - ACLK_MAX_ENUMERATIONS_DEFINED -}; - -struct aclk_database_cmd { - enum aclk_database_opcode opcode; - void *param[2]; - struct completion *completion; - struct aclk_database_cmd *prev, *next; -}; - -typedef struct aclk_sync_cfg_t { - RRDHOST *host; - int alert_updates; - int alert_checkpoint_req; - int alert_queue_removed; - time_t node_info_send_time; - time_t node_collectors_send; - char uuid_str[UUID_STR_LEN]; - char node_id[UUID_STR_LEN]; - char *alerts_snapshot_uuid; // will contain the snapshot_uuid value if snapshot was requested - uint64_t alerts_log_first_sequence_id; - uint64_t alerts_log_last_sequence_id; -} aclk_sync_cfg_t; - -void sql_create_aclk_table(RRDHOST *host, uuid_t *host_uuid, uuid_t *node_id); -void sql_aclk_sync_init(void); -void aclk_push_alert_config(const char *node_id, const char *config_hash); -void aclk_push_node_alert_snapshot(const char *node_id); -void aclk_push_node_removed_alerts(const char *node_id); -void schedule_node_info_update(RRDHOST *host); -#ifdef ENABLE_ACLK -void unregister_node(const char *machine_guid); -#endif - -#endif //NETDATA_SQLITE_ACLK_H |