123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103 |
- // SPDX-License-Identifier: GPL-3.0-or-later
- #ifndef NETDATA_AGENT_CLOUD_LINK_H
- #define NETDATA_AGENT_CLOUD_LINK_H
- #include "../daemon/common.h"
- #include "mqtt.h"
- #define ACLK_JSON_IN_MSGID "msg-id"
- #define ACLK_JSON_IN_TYPE "type"
- #define ACLK_JSON_IN_VERSION "version"
- #define ACLK_JSON_IN_TOPIC "callback-topic"
- #define ACLK_JSON_IN_URL "payload"
- #define ACLK_MSG_TYPE_CHART "chart"
- #define ACLK_ALARMS_TOPIC "alarms"
- #define ACLK_METADATA_TOPIC "meta"
- #define ACLK_COMMAND_TOPIC "cmd"
- #define ACLK_TOPIC_STRUCTURE "/agent/%s"
- #define ACLK_STARTUP_WAIT 30 // Seconds to wait before establishing initialization process
- #define ACLK_INITIALIZATION_WAIT 60 // Wait for link to initialize in seconds (per msg)
- #define ACLK_INITIALIZATION_SLEEP_WAIT 1 // Wait time @ spin lock for MQTT initialization in seconds
- #define ACLK_QOS 1
- #define ACLK_PING_INTERVAL 60
- #define ACLK_LOOP_TIMEOUT 5 // seconds to wait for operations in the library loop
- #define ACLK_MAX_TOPIC 255
- #define ACLK_RECONNECT_DELAY 1 // reconnect delay -- with backoff stragegy fow now
- #define ACLK_MAX_RECONNECT_DELAY 120
- #define ACLK_VERSION "1"
- #define CONFIG_SECTION_ACLK "agent_cloud_link"
- struct aclk_request {
- char *type_id;
- char *msg_id;
- char *topic;
- char *url;
- int version;
- };
- typedef enum publish_topic_action {
- PUBLICH_TOPIC_GET,
- PUBLICH_TOPIC_FREE,
- PUBLICH_TOPIC_REBUILD
- } PUBLISH_TOPIC_ACTION;
- typedef enum aclk_init_action {
- ACLK_INIT,
- ACLK_REINIT
- } ACLK_INIT_ACTION;
- #define GET_PUBLISH_BASE_TOPIC get_publish_base_topic(0)
- #define FREE_PUBLISH_BASE_TOPIC get_publish_base_topic(1)
- #define REBUILD_PUBLISH_BASE_TOPIC get_publish_base_topic(2)
- void *aclk_main(void *ptr);
- #define NETDATA_ACLK_HOOK \
- { \
- .name = "AgentCloudLink", \
- .config_section = NULL, \
- .config_name = NULL, \
- .enabled = 1, \
- .thread = NULL, \
- .init_routine = NULL, \
- .start_routine = aclk_main \
- },
- extern int aclk_send_message(char *sub_topic, char *message);
- int aclk_init();
- char *get_base_topic();
- extern char *is_agent_claimed(void);
- // callbacks for agent cloud link
- int aclk_subscribe(char *topic, int qos);
- void aclk_shutdown();
- //void aclk_message_callback(struct mosquitto *moqs, void *obj, const struct mosquitto_message *msg);
- int cloud_to_agent_parse(JSON_ENTRY *e);
- void aclk_disconnect(void *conn);
- void aclk_connect(void *conn);
- void aclk_create_metadata_message(BUFFER *dest, char *type, char *msg_id, BUFFER *contents);
- int aclk_send_metadata();
- int aclk_wait_for_initialization();
- //int aclk_send_charts(RRDHOST *host, BUFFER *wb);
- int aclk_send_single_chart(char *host, char *chart);
- int aclk_queue_query(char *token, char *data, char *msg_type, char *query, int run_after, int internal);
- struct aclk_query *aclk_query_find(char *token, char *data, char *msg_id, char *query);
- //void aclk_rrdset2json(RRDSET *st, BUFFER *wb, char *hostname, int is_slave);
- int aclk_update_chart(RRDHOST *host, char *chart_name);
- int aclk_update_alarm(RRDHOST *host, char *alarm_name);
- void aclk_create_header(BUFFER *dest, char *type, char *msg_id);
- int aclk_handle_cloud_request(char *payload);
- int aclk_submit_request(struct aclk_request *);
- #endif //NETDATA_AGENT_CLOUD_LINK_H
|