summaryrefslogtreecommitdiffstats
path: root/database/sqlite/sqlite_aclk.h
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-05 11:19:16 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-05 12:07:37 +0000
commitb485aab7e71c1625cfc27e0f92c9509f42378458 (patch)
treeae9abe108601079d1679194de237c9a435ae5b55 /database/sqlite/sqlite_aclk.h
parentAdding upstream version 1.44.3. (diff)
downloadnetdata-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.h101
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