mirror of
https://github.com/netdata/netdata.git
synced 2025-05-19 15:31:48 +00:00
6e1e97c5e8
* move old health log tables to one * change table in sqlite_health * remove check for off period of agent * changes in aclk_alert * fixes * add new field insert_mark_timestamp * cleanup * remove hostname, create the health log table during sqlite init * create the health_log during migration * move source from health_log to alert_hash. Remove class, component and type field from health_log * Register now_usec sqlite function * use global_id instead of insert_mark_timestamp. Use function now_usec to populate it * create functions earlier to have them during migration * small unit test fix * create additional health_log_detail table. Do the insert of an alert event on both * do the update on health_log_detail * change more queries * more indexes, fix inject removed * change last executed and select health log queries * random uuid for sqlite * do migration from old tables * queries to send alerts to cloud * cleanup queries * get an alarm id from db if not found in memory * small fix on query * add info when migration completes * dont pick health_log_detail during migration * check proper old health_log table * safer migration * proper log sent alerts. small fix in claimed cleanup * cleanups * extra check for cleanup * also get an alarm_event_id from sql * check for empty source * remove cleanup of main health log table --------- Co-authored-by: Stelios Fragkakis <52996999+stelfrag@users.noreply.github.com>
105 lines
3 KiB
C
105 lines
3 KiB
C
// 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_ALERT "CREATE INDEX IF NOT EXISTS aclk_alert_index_%s ON aclk_alert_%s (alert_unique_id);"
|
|
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_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;
|
|
};
|
|
|
|
#define ACLK_DATABASE_CMD_Q_MAX_SIZE (1024)
|
|
|
|
struct aclk_database_cmdqueue {
|
|
unsigned head, tail;
|
|
struct aclk_database_cmd cmd_array[ACLK_DATABASE_CMD_Q_MAX_SIZE];
|
|
};
|
|
|
|
struct aclk_sync_host_config {
|
|
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;
|
|
};
|
|
|
|
extern sqlite3 *db_meta;
|
|
|
|
int aclk_database_enq_cmd_noblock(struct aclk_database_cmd *cmd);
|
|
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_health_log(const char *node_id);
|
|
void aclk_push_node_removed_alerts(const char *node_id);
|
|
void schedule_node_info_update(RRDHOST *host);
|
|
|
|
#endif //NETDATA_SQLITE_ACLK_H
|