1 files changed, 63 insertions, 0 deletions
diff --git a/src/database/sqlite/sqlite_aclk.h b/src/database/sqlite/sqlite_aclk.h
new file mode 100644
index 000000000..ec8cfa9dd
--- /dev/null
+++ b/src/database/sqlite/sqlite_aclk.h
@@ -0,0 +1,63 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_SQLITE_ACLK_H
+#define NETDATA_SQLITE_ACLK_H
+
+#define ACLK_MAX_ALERT_UPDATES  "50"
+#define ACLK_SYNC_QUERY_SIZE 512
+
+static inline int uuid_parse_fix(char *in, nd_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;
+}
+
+enum aclk_database_opcode {
+    ACLK_DATABASE_NOOP = 0,
+    ACLK_DATABASE_NODE_STATE,
+    ACLK_DATABASE_PUSH_ALERT,
+    ACLK_DATABASE_PUSH_ALERT_CONFIG,
+    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 aclk_database_cmd *prev, *next;
+};
+
+typedef struct aclk_sync_cfg_t {
+    RRDHOST *host;
+    int8_t send_snapshot;
+    bool stream_alerts;
+    int alert_count;
+    int snapshot_count;
+    int checkpoint_count;
+    time_t node_info_send_time;
+    time_t node_collectors_send;
+    char node_id[UUID_STR_LEN];
+    char *alerts_snapshot_uuid;        // will contain the snapshot_uuid value if snapshot was requested
+} aclk_sync_cfg_t;
+
+void create_aclk_config(RRDHOST *host, nd_uuid_t *host_uuid, nd_uuid_t *node_id);
+void sql_aclk_sync_init(void);
+void aclk_push_alert_config(const char *node_id, const char *config_hash);
+void schedule_node_info_update(RRDHOST *host);
+#ifdef ENABLE_ACLK
+void unregister_node(const char *machine_guid);
+#endif
+
+#endif //NETDATA_SQLITE_ACLK_H