1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// SPDX-License-Identifier: GPL-3.0-or-later
#include "claim.h"
const char *cloud_status_to_string(CLOUD_STATUS status) {
switch(status) {
default:
case CLOUD_STATUS_AVAILABLE:
return "available";
case CLOUD_STATUS_BANNED:
return "banned";
case CLOUD_STATUS_OFFLINE:
return "offline";
case CLOUD_STATUS_ONLINE:
return "online";
case CLOUD_STATUS_INDIRECT:
return "indirect";
}
}
CLOUD_STATUS cloud_status(void) {
if(unlikely(aclk_disable_runtime))
return CLOUD_STATUS_BANNED;
if(likely(aclk_online()))
return CLOUD_STATUS_ONLINE;
if(localhost->sender &&
rrdhost_flag_check(localhost, RRDHOST_FLAG_RRDPUSH_SENDER_READY_4_METRICS) &&
stream_has_capability(localhost->sender, STREAM_CAP_NODE_ID) &&
!UUIDiszero(localhost->node_id) &&
!UUIDiszero(localhost->aclk.claim_id_of_parent))
return CLOUD_STATUS_INDIRECT;
if(is_agent_claimed())
return CLOUD_STATUS_OFFLINE;
return CLOUD_STATUS_AVAILABLE;
}
time_t cloud_last_change(void) {
time_t ret = MAX(last_conn_time_mqtt, last_disconnect_time);
if(!ret) ret = netdata_start_time;
return ret;
}
time_t cloud_next_connection_attempt(void) {
return next_connection_attempt;
}
size_t cloud_connection_id(void) {
return aclk_connection_counter;
}
const char *cloud_status_aclk_offline_reason() {
if(aclk_disable_runtime)
return "banned";
return aclk_status_to_string();
}
const char *cloud_status_aclk_base_url() {
return aclk_cloud_base_url;
}
CLOUD_STATUS buffer_json_cloud_status(BUFFER *wb, time_t now_s) {
CLOUD_STATUS status = cloud_status();
buffer_json_member_add_object(wb, "cloud");
{
size_t id = cloud_connection_id();
time_t last_change = cloud_last_change();
time_t next_connect = cloud_next_connection_attempt();
buffer_json_member_add_uint64(wb, "id", id);
buffer_json_member_add_string(wb, "status", cloud_status_to_string(status));
buffer_json_member_add_time_t(wb, "since", last_change);
buffer_json_member_add_time_t(wb, "age", now_s - last_change);
switch(status) {
default:
case CLOUD_STATUS_AVAILABLE:
// the agent is not claimed
buffer_json_member_add_string(wb, "url", cloud_config_url_get());
buffer_json_member_add_string(wb, "reason", claim_agent_failure_reason_get());
break;
case CLOUD_STATUS_BANNED: {
// the agent is claimed, but has been banned from NC
CLAIM_ID claim_id = claim_id_get();
buffer_json_member_add_string(wb, "claim_id", claim_id.str);
buffer_json_member_add_string(wb, "url", cloud_status_aclk_base_url());
buffer_json_member_add_string(wb, "reason", "Agent is banned from Netdata Cloud");
buffer_json_member_add_string(wb, "url", cloud_config_url_get());
break;
}
case CLOUD_STATUS_OFFLINE: {
// the agent is claimed, but cannot get online
CLAIM_ID claim_id = claim_id_get();
buffer_json_member_add_string(wb, "claim_id", claim_id.str);
buffer_json_member_add_string(wb, "url", cloud_status_aclk_base_url());
buffer_json_member_add_string(wb, "reason", cloud_status_aclk_offline_reason());
if (next_connect > now_s) {
buffer_json_member_add_time_t(wb, "next_check", next_connect);
buffer_json_member_add_time_t(wb, "next_in", next_connect - now_s);
}
break;
}
case CLOUD_STATUS_ONLINE: {
// the agent is claimed and online
CLAIM_ID claim_id = claim_id_get();
buffer_json_member_add_string(wb, "claim_id", claim_id.str);
buffer_json_member_add_string(wb, "url", cloud_status_aclk_base_url());
buffer_json_member_add_string(wb, "reason", "");
break;
}
case CLOUD_STATUS_INDIRECT: {
CLAIM_ID claim_id = rrdhost_claim_id_get(localhost);
buffer_json_member_add_string(wb, "claim_id", claim_id.str);
buffer_json_member_add_string(wb, "url", cloud_config_url_get());
break;
}
}
}
buffer_json_object_close(wb); // cloud
return status;
}
|
