agent_cloud_link.h 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109
  1. // SPDX-License-Identifier: GPL-3.0-or-later
  2. #ifndef NETDATA_AGENT_CLOUD_LINK_H
  3. #define NETDATA_AGENT_CLOUD_LINK_H
  4. #include "../daemon/common.h"
  5. #include "mqtt.h"
  6. #define ACLK_VERSION 1
  7. #define ACLK_THREAD_NAME "ACLK_Query"
  8. #define ACLK_CHART_TOPIC "outbound/meta"
  9. #define ACLK_ALARMS_TOPIC "outbound/alarms"
  10. #define ACLK_METADATA_TOPIC "outbound/meta"
  11. #define ACLK_COMMAND_TOPIC "inbound/cmd"
  12. #define ACLK_TOPIC_STRUCTURE "/agent/%s"
  13. #define ACLK_MAX_BACKOFF_DELAY 1024 // maximum backoff delay in seconds
  14. #define ACLK_INITIALIZATION_WAIT 60 // Wait for link to initialize in seconds (per msg)
  15. #define ACLK_INITIALIZATION_SLEEP_WAIT 1 // Wait time @ spin lock for MQTT initialization in seconds
  16. #define ACLK_QOS 1
  17. #define ACLK_PING_INTERVAL 60
  18. #define ACLK_LOOP_TIMEOUT 5 // seconds to wait for operations in the library loop
  19. #define ACLK_MAX_TOPIC 255
  20. #define ACLK_RECONNECT_DELAY 1 // reconnect delay -- with backoff stragegy fow now
  21. #define ACLK_STABLE_TIMEOUT 3 // Minimum delay to mark AGENT as stable
  22. #define ACLK_DEFAULT_PORT 9002
  23. #define ACLK_DEFAULT_HOST "localhost"
  24. struct aclk_request {
  25. char *type_id;
  26. char *msg_id;
  27. char *callback_topic;
  28. char *payload;
  29. int version;
  30. };
  31. typedef enum aclk_cmd {
  32. ACLK_CMD_CLOUD,
  33. ACLK_CMD_ONCONNECT,
  34. ACLK_CMD_INFO,
  35. ACLK_CMD_CHART,
  36. ACLK_CMD_CHARTDEL,
  37. ACLK_CMD_ALARM,
  38. ACLK_CMD_MAX
  39. } ACLK_CMD;
  40. typedef enum aclk_metadata_state {
  41. ACLK_METADATA_REQUIRED,
  42. ACLK_METADATA_CMD_QUEUED,
  43. ACLK_METADATA_SENT
  44. } ACLK_METADATA_STATE;
  45. typedef enum agent_state {
  46. AGENT_INITIALIZING,
  47. AGENT_STABLE
  48. } AGENT_STATE;
  49. typedef enum aclk_init_action { ACLK_INIT, ACLK_REINIT } ACLK_INIT_ACTION;
  50. void *aclk_main(void *ptr);
  51. #define NETDATA_ACLK_HOOK \
  52. { .name = "ACLK_Main", \
  53. .config_section = NULL, \
  54. .config_name = NULL, \
  55. .enabled = 1, \
  56. .thread = NULL, \
  57. .init_routine = NULL, \
  58. .start_routine = aclk_main },
  59. extern int aclk_send_message(char *sub_topic, char *message, char *msg_id);
  60. extern char *is_agent_claimed(void);
  61. extern void aclk_lws_wss_mqtt_layer_disconect_notif();
  62. char *create_uuid();
  63. // callbacks for agent cloud link
  64. int aclk_subscribe(char *topic, int qos);
  65. int cloud_to_agent_parse(JSON_ENTRY *e);
  66. void aclk_disconnect();
  67. void aclk_connect();
  68. int aclk_send_metadata();
  69. int aclk_send_info_metadata();
  70. int aclk_wait_for_initialization();
  71. char *create_publish_base_topic();
  72. int aclk_send_single_chart(char *host, char *chart);
  73. int aclk_queue_query(char *token, char *data, char *msg_type, char *query, int run_after, int internal, ACLK_CMD cmd);
  74. struct aclk_query *
  75. aclk_query_find(char *token, char *data, char *msg_id, char *query, ACLK_CMD cmd, struct aclk_query **last_query);
  76. int aclk_update_chart(RRDHOST *host, char *chart_name, ACLK_CMD aclk_cmd);
  77. int aclk_update_alarm(RRDHOST *host, ALARM_ENTRY *ae);
  78. void aclk_create_header(BUFFER *dest, char *type, char *msg_id, time_t ts_secs, usec_t ts_us);
  79. int aclk_handle_cloud_request(char *payload);
  80. int aclk_submit_request(struct aclk_request *);
  81. void aclk_add_collector(const char *hostname, const char *plugin_name, const char *module_name);
  82. void aclk_del_collector(const char *hostname, const char *plugin_name, const char *module_name);
  83. void aclk_alarm_reload();
  84. void aclk_send_alarm_metadata();
  85. int aclk_execute_query(struct aclk_query *query);
  86. unsigned long int aclk_reconnect_delay(int mode);
  87. extern void health_alarm_entry2json_nolock(BUFFER *wb, ALARM_ENTRY *ae, RRDHOST *host);
  88. void aclk_single_update_enable();
  89. void aclk_single_update_disable();
  90. #endif //NETDATA_AGENT_CLOUD_LINK_H