summaryrefslogtreecommitdiffstats
path: root/aclk/agent_cloud_link.c
diff options
context:
space:
mode:
authorStelios Fragkakis <52996999+stelfrag@users.noreply.github.com>2020-06-12 10:35:17 +0300
committerGitHub <noreply@github.com>2020-06-12 10:35:17 +0300
commit1bd8a255441de6056a0d51a7bb787f76b590ffb6 (patch)
tree5b0ae5ca07d19e2323e202e72ca15247409b0a2d /aclk/agent_cloud_link.c
parent45747d3e47cde80589bf702c92ff9557fe8b7f7d (diff)
Add support for persistent metadata (#9324)
* Implemented collector metadata logging * Added persistent GUIDs for charts and dimensions * Added metadata log replay and automatic compaction * Added detection of charts with no active collector (archived) * Added new endpoint to report archived charts via `/api/v1/archivedcharts` * Added support for collector metadata update Co-authored-by: Markos Fountoulakis <44345837+mfundul@users.noreply.github.com>
Diffstat (limited to 'aclk/agent_cloud_link.c')
-rw-r--r--aclk/agent_cloud_link.c14
1 files changed, 13 insertions, 1 deletions
diff --git a/aclk/agent_cloud_link.c b/aclk/agent_cloud_link.c
index cc366a8332..7b5aad5c4a 100644
--- a/aclk/agent_cloud_link.c
+++ b/aclk/agent_cloud_link.c
@@ -680,6 +680,9 @@ static struct _collector *_add_collector(const char *hostname, const char *plugi
void aclk_add_collector(const char *hostname, const char *plugin_name, const char *module_name)
{
struct _collector *tmp_collector;
+ if (unlikely(!netdata_ready)) {
+ return;
+ }
COLLECTOR_LOCK;
@@ -711,6 +714,9 @@ void aclk_add_collector(const char *hostname, const char *plugin_name, const cha
void aclk_del_collector(const char *hostname, const char *plugin_name, const char *module_name)
{
struct _collector *tmp_collector;
+ if (unlikely(!netdata_ready)) {
+ return;
+ }
COLLECTOR_LOCK;
@@ -1752,7 +1758,7 @@ int aclk_send_info_metadata()
debug(D_ACLK, "Metadata %s with info has %zu bytes", msg_id, local_buffer->len);
buffer_sprintf(local_buffer, ", \n\t \"charts\" : ");
- charts2json(localhost, local_buffer, 1);
+ charts2json(localhost, local_buffer, 1, 0);
buffer_sprintf(local_buffer, "\n}\n}");
debug(D_ACLK, "Metadata %s with chart has %zu bytes", msg_id, local_buffer->len);
@@ -1859,6 +1865,9 @@ int aclk_update_chart(RRDHOST *host, char *chart_name, ACLK_CMD aclk_cmd)
UNUSED(chart_name);
return 0;
#else
+ if (unlikely(!netdata_ready))
+ return 0;
+
if (!netdata_cloud_setting)
return 0;
@@ -1886,6 +1895,9 @@ int aclk_update_alarm(RRDHOST *host, ALARM_ENTRY *ae)
{
BUFFER *local_buffer = NULL;
+ if (unlikely(!netdata_ready))
+ return 0;
+
if (host != localhost)
return 0;