master
c 981 lines 59.1 KB
Raw
1 // SPDX-License-Identifier: GPL-3.0-or-later
2
3 #include "function-netdata-streaming.h"
4
5 #include <ctype.h>
6
7 #define STREAMING_FUNCTION_UPDATE_EVERY 10
8
9 #define GROUP_BY_COLUMN(name, descr) \
10 buffer_json_member_add_object(wb, name);\
11 {\
12 buffer_json_member_add_string(wb, "name", descr);\
13 buffer_json_member_add_array(wb, "columns");\
14 {\
15 buffer_json_add_array_item_string(wb, name);\
16 }\
17 buffer_json_array_close(wb);\
18 }\
19 buffer_json_object_close(wb);
20
21 int function_netdata_streaming(BUFFER *wb, const char *function __maybe_unused, BUFFER *payload __maybe_unused, const char *source __maybe_unused) {
22
23 time_t now = now_realtime_sec();
24
25 buffer_flush(wb);
26 wb->content_type = CT_APPLICATION_JSON;
27 buffer_json_initialize(wb, "\"", "\"", 0, true, BUFFER_JSON_OPTIONS_DEFAULT);
28
29 buffer_json_member_add_string(wb, "hostname", rrdhost_hostname(localhost));
30 buffer_json_member_add_uint64(wb, "status", HTTP_RESP_OK);
31 buffer_json_member_add_string(wb, "type", "table");
32 buffer_json_member_add_time_t(wb, "update_every", STREAMING_FUNCTION_UPDATE_EVERY);
33 buffer_json_member_add_boolean(wb, "has_history", false);
34 buffer_json_member_add_string(wb, "help", RRDFUNCTIONS_STREAMING_HELP);
35 buffer_json_member_add_array(wb, "data");
36
37 size_t max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_MAX] = { 0 };
38 size_t max_db_metrics = 0, max_db_instances = 0, max_db_contexts = 0;
39 size_t max_collection_replication_instances = 0, max_streaming_replication_instances = 0;
40 size_t max_ml_anomalous = 0, max_ml_normal = 0, max_ml_trained = 0, max_ml_pending = 0, max_ml_silenced = 0;
41
42 time_t
43 max_db_duration = 0,
44 max_db_from = 0,
45 max_db_to = 0,
46 max_in_age = 0,
47 max_out_age = 0,
48 max_out_attempt_age = 0;
49
50 uint64_t
51 max_in_since = 0,
52 max_out_since = 0,
53 max_out_attempt_since = 0;
54
55 int16_t
56 max_in_hops = -1,
57 max_out_hops = -1;
58
59 int
60 max_in_local_port = 0,
61 max_in_remote_port = 0,
62 max_out_local_port = 0,
63 max_out_remote_port = 0;
64
65 uint32_t
66 max_in_connections = 0,
67 max_out_connections = 0;
68
69 {
70 RRDHOST *host;
71 dfe_start_read(rrdhost_root_index, host) {
72 RRDHOST_STATUS s;
73 rrdhost_status(host, now, &s, RRDHOST_STATUS_ALL);
74 buffer_json_add_array_item_array(wb);
75
76 if(s.db.metrics > max_db_metrics)
77 max_db_metrics = s.db.metrics;
78
79 if(s.db.instances > max_db_instances)
80 max_db_instances = s.db.instances;
81
82 if(s.db.contexts > max_db_contexts)
83 max_db_contexts = s.db.contexts;
84
85 if(s.ingest.replication.instances > max_collection_replication_instances)
86 max_collection_replication_instances = s.ingest.replication.instances;
87
88 if(s.stream.replication.instances > max_streaming_replication_instances)
89 max_streaming_replication_instances = s.stream.replication.instances;
90
91 for(int i = 0; i < STREAM_TRAFFIC_TYPE_MAX ;i++) {
92 if (s.stream.sent_bytes_on_this_connection_per_type[i] >
93 max_sent_bytes_on_this_connection_per_type[i])
94 max_sent_bytes_on_this_connection_per_type[i] =
95 s.stream.sent_bytes_on_this_connection_per_type[i];
96 }
97
98 // Node
99 buffer_json_add_array_item_string(wb, rrdhost_hostname(s.host));
100
101 // rowOptions
102 buffer_json_add_array_item_object(wb);
103 {
104 const char *severity = NULL; // normal, debug, notice, warning, critical
105 if(!rrdhost_option_check(host, RRDHOST_OPTION_EPHEMERAL_HOST)) {
106 switch(s.ingest.status) {
107 case RRDHOST_INGEST_STATUS_OFFLINE:
108 case RRDHOST_INGEST_STATUS_ARCHIVED:
109 severity = "critical";
110 break;
111
112 default:
113 case RRDHOST_INGEST_STATUS_INITIALIZING:
114 case RRDHOST_INGEST_STATUS_ONLINE:
115 case RRDHOST_INGEST_STATUS_REPLICATING:
116 break;
117 }
118
119 switch(s.stream.status) {
120 case RRDHOST_STREAM_STATUS_OFFLINE:
121 if(!severity && s.stream.reason != STREAM_HANDSHAKE_SP_NO_DESTINATION)
122 severity = "warning";
123 break;
124
125 default:
126 case RRDHOST_STREAM_STATUS_REPLICATING:
127 case RRDHOST_STREAM_STATUS_ONLINE:
128 break;
129 }
130 }
131 buffer_json_member_add_string(wb, "severity", severity ? severity : "normal");
132 }
133 buffer_json_object_close(wb); // rowOptions
134
135 // Ephemerality
136 buffer_json_add_array_item_string(wb, rrdhost_option_check(s.host, RRDHOST_OPTION_EPHEMERAL_HOST) ? "ephemeral" : "permanent");
137
138 // AgentName and AgentVersion
139 buffer_json_add_array_item_string(wb, rrdhost_program_name(host));
140 buffer_json_add_array_item_string(wb, rrdhost_program_version(host));
141
142 // System Info
143 rrdhost_system_info_to_streaming_function_array(wb, s.host->system_info);
144
145 // retention
146 buffer_json_add_array_item_uint64(wb, s.db.first_time_s * MSEC_PER_SEC); // dbFrom
147 if(s.db.first_time_s > max_db_from) max_db_from = s.db.first_time_s;
148
149 buffer_json_add_array_item_uint64(wb, s.db.last_time_s * MSEC_PER_SEC); // dbTo
150 if(s.db.last_time_s > max_db_to) max_db_to = s.db.last_time_s;
151
152 if(s.db.first_time_s && s.db.last_time_s && s.db.last_time_s > s.db.first_time_s) {
153 time_t db_duration = s.db.last_time_s - s.db.first_time_s;
154 buffer_json_add_array_item_uint64(wb, db_duration); // dbDuration
155 if(db_duration > max_db_duration) max_db_duration = db_duration;
156 }
157 else
158 buffer_json_add_array_item_string(wb, NULL); // dbDuration
159
160 buffer_json_add_array_item_uint64(wb, s.db.metrics); // dbMetrics
161 buffer_json_add_array_item_uint64(wb, s.db.instances); // dbInstances
162 buffer_json_add_array_item_uint64(wb, s.db.contexts); // dbContexts
163
164 // statuses
165 buffer_json_add_array_item_string(wb, rrdhost_ingest_status_to_string(s.ingest.status)); // InStatus
166 buffer_json_add_array_item_string(wb, rrdhost_streaming_status_to_string(s.stream.status)); // OutStatus
167 buffer_json_add_array_item_string(wb, rrdhost_ml_status_to_string(s.ml.status)); // MLStatus
168
169 // collection
170
171 // InConnections
172 buffer_json_add_array_item_uint64(wb, s.host->stream.rcv.status.connections);
173 if(s.host->stream.rcv.status.connections > max_in_connections)
174 max_in_connections = s.host->stream.rcv.status.connections;
175
176 if(s.ingest.since) {
177 uint64_t in_since = s.ingest.since * MSEC_PER_SEC;
178 buffer_json_add_array_item_uint64(wb, in_since); // InSince
179 if(in_since > max_in_since) max_in_since = in_since;
180
181 time_t in_age = s.now - s.ingest.since;
182 buffer_json_add_array_item_time_t(wb, in_age); // InAge
183 if(in_age > max_in_age) max_in_age = in_age;
184 }
185 else {
186 buffer_json_add_array_item_string(wb, NULL); // InSince
187 buffer_json_add_array_item_string(wb, NULL); // InAge
188 }
189
190 // InReason
191 if(s.ingest.type == RRDHOST_INGEST_TYPE_LOCALHOST)
192 buffer_json_add_array_item_string(wb, "LOCALHOST");
193 else if(s.ingest.type == RRDHOST_INGEST_TYPE_VIRTUAL)
194 buffer_json_add_array_item_string(wb, "VIRTUAL NODE");
195 else
196 buffer_json_add_array_item_string(wb, stream_handshake_error_to_string(s.ingest.reason));
197
198 buffer_json_add_array_item_int64(wb, s.ingest.hops); // InHops
199 if(s.ingest.hops > max_in_hops) max_in_hops = s.ingest.hops;
200
201 buffer_json_add_array_item_double(wb, s.ingest.replication.completion); // InReplCompletion
202 buffer_json_add_array_item_uint64(wb, s.ingest.replication.instances); // InReplInstances
203 buffer_json_add_array_item_string(wb, s.ingest.type == RRDHOST_INGEST_TYPE_LOCALHOST || s.ingest.type == RRDHOST_INGEST_TYPE_VIRTUAL ? "localhost" : s.ingest.peers.local.ip); // InLocalIP
204
205 buffer_json_add_array_item_uint64(wb, s.ingest.peers.local.port); // InLocalPort
206 if(s.ingest.peers.local.port > max_in_local_port) max_in_local_port = s.ingest.peers.local.port;
207
208 buffer_json_add_array_item_string(wb, s.ingest.peers.peer.ip); // InRemoteIP
209 buffer_json_add_array_item_uint64(wb, s.ingest.peers.peer.port); // InRemotePort
210 if(s.ingest.peers.peer.port > max_in_remote_port) max_in_remote_port = s.ingest.peers.peer.port;
211
212 buffer_json_add_array_item_string(wb, s.ingest.ssl ? "SSL" : "PLAIN"); // InSSL
213 stream_capabilities_to_json_array(wb, s.ingest.capabilities, NULL); // InCapabilities
214
215 buffer_json_add_array_item_uint64(wb, s.ingest.collected.metrics); // CollectedMetrics
216 buffer_json_add_array_item_uint64(wb, s.ingest.collected.instances); // CollectedInstances
217 buffer_json_add_array_item_uint64(wb, s.ingest.collected.contexts); // CollectedContexts
218
219 // streaming
220
221 // OutConnections
222 buffer_json_add_array_item_uint64(wb, s.host->stream.snd.status.connections);
223 if(s.host->stream.snd.status.connections > max_out_connections)
224 max_out_connections = s.host->stream.snd.status.connections;
225
226 if(s.stream.since) {
227 uint64_t out_since = s.stream.since * MSEC_PER_SEC;
228 buffer_json_add_array_item_uint64(wb, out_since); // OutSince
229 if(out_since > max_out_since) max_out_since = out_since;
230
231 time_t out_age = s.now - s.stream.since;
232 buffer_json_add_array_item_time_t(wb, out_age); // OutAge
233 if(out_age > max_out_age) max_out_age = out_age;
234 }
235 else {
236 buffer_json_add_array_item_string(wb, NULL); // OutSince
237 buffer_json_add_array_item_string(wb, NULL); // OutAge
238 }
239 buffer_json_add_array_item_string(wb, stream_handshake_error_to_string(s.stream.reason)); // OutReason
240
241 buffer_json_add_array_item_int64(wb, s.stream.hops); // OutHops
242 if(s.stream.hops > max_out_hops) max_out_hops = s.stream.hops;
243
244 buffer_json_add_array_item_double(wb, s.stream.replication.completion); // OutReplCompletion
245 buffer_json_add_array_item_uint64(wb, s.stream.replication.instances); // OutReplInstances
246 buffer_json_add_array_item_string(wb, s.stream.peers.local.ip); // OutLocalIP
247 buffer_json_add_array_item_uint64(wb, s.stream.peers.local.port); // OutLocalPort
248 if(s.stream.peers.local.port > max_out_local_port) max_out_local_port = s.stream.peers.local.port;
249
250 buffer_json_add_array_item_string(wb, s.stream.peers.peer.ip); // OutRemoteIP
251 buffer_json_add_array_item_uint64(wb, s.stream.peers.peer.port); // OutRemotePort
252 if(s.stream.peers.peer.port > max_out_remote_port) max_out_remote_port = s.stream.peers.peer.port;
253
254 buffer_json_add_array_item_string(wb, s.stream.ssl ? "SSL" : "PLAIN"); // OutSSL
255 buffer_json_add_array_item_string(wb, s.stream.compression ? "COMPRESSED" : "UNCOMPRESSED"); // OutCompression
256 stream_capabilities_to_json_array(wb, s.stream.capabilities, NULL); // OutCapabilities
257 buffer_json_add_array_item_uint64(wb, s.stream.sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_DATA]);
258 buffer_json_add_array_item_uint64(wb, s.stream.sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_METADATA]);
259 buffer_json_add_array_item_uint64(wb, s.stream.sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_REPLICATION]);
260 buffer_json_add_array_item_uint64(wb, s.stream.sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_FUNCTIONS]);
261
262 buffer_json_add_array_item_array(wb); // OutAttemptHandshake
263 usec_t last_attempt = stream_parent_handshake_error_to_json(wb, host);
264 buffer_json_array_close(wb); // // OutAttemptHandshake
265
266 if(!last_attempt) {
267 buffer_json_add_array_item_string(wb, NULL); // OutAttemptSince
268 buffer_json_add_array_item_string(wb, NULL); // OutAttemptAge
269 }
270 else {
271 uint64_t out_attempt_since = last_attempt / USEC_PER_MS;
272 buffer_json_add_array_item_uint64(wb, out_attempt_since); // OutAttemptSince
273 if(out_attempt_since > max_out_attempt_since) max_out_attempt_since = out_attempt_since;
274
275 time_t out_attempt_age = s.now - (time_t)(last_attempt / USEC_PER_SEC);
276 buffer_json_add_array_item_time_t(wb, out_attempt_age); // OutAttemptAge
277 if(out_attempt_age > max_out_attempt_age) max_out_attempt_age = out_attempt_age;
278 }
279
280 // ML
281 if(s.ml.status == RRDHOST_ML_STATUS_RUNNING) {
282 buffer_json_add_array_item_uint64(wb, s.ml.metrics.anomalous); // MlAnomalous
283 buffer_json_add_array_item_uint64(wb, s.ml.metrics.normal); // MlNormal
284 buffer_json_add_array_item_uint64(wb, s.ml.metrics.trained); // MlTrained
285 buffer_json_add_array_item_uint64(wb, s.ml.metrics.pending); // MlPending
286 buffer_json_add_array_item_uint64(wb, s.ml.metrics.silenced); // MlSilenced
287
288 if(s.ml.metrics.anomalous > max_ml_anomalous)
289 max_ml_anomalous = s.ml.metrics.anomalous;
290
291 if(s.ml.metrics.normal > max_ml_normal)
292 max_ml_normal = s.ml.metrics.normal;
293
294 if(s.ml.metrics.trained > max_ml_trained)
295 max_ml_trained = s.ml.metrics.trained;
296
297 if(s.ml.metrics.pending > max_ml_pending)
298 max_ml_pending = s.ml.metrics.pending;
299
300 if(s.ml.metrics.silenced > max_ml_silenced)
301 max_ml_silenced = s.ml.metrics.silenced;
302
303 }
304 else {
305 buffer_json_add_array_item_string(wb, NULL); // MlAnomalous
306 buffer_json_add_array_item_string(wb, NULL); // MlNormal
307 buffer_json_add_array_item_string(wb, NULL); // MlTrained
308 buffer_json_add_array_item_string(wb, NULL); // MlPending
309 buffer_json_add_array_item_string(wb, NULL); // MlSilenced
310 }
311
312 // close
313 buffer_json_array_close(wb);
314 }
315 dfe_done(host);
316 }
317 buffer_json_array_close(wb); // data
318 buffer_json_member_add_object(wb, "columns");
319 {
320 size_t field_id = 0;
321
322 // Node
323 buffer_rrdf_table_add_field(wb, field_id++, "Node", "Node's Hostname",
324 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
325 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
326 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
327 RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY | RRDF_FIELD_OPTS_STICKY,
328 NULL);
329
330 buffer_rrdf_table_add_field(wb, field_id++, "rowOptions", "rowOptions",
331 RRDF_FIELD_TYPE_NONE, RRDR_FIELD_VISUAL_ROW_OPTIONS, RRDF_FIELD_TRANSFORM_NONE,
332 0, NULL, NAN, RRDF_FIELD_SORT_FIXED, NULL,
333 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_NONE, RRDF_FIELD_OPTS_DUMMY,
334 NULL);
335
336 buffer_rrdf_table_add_field(wb, field_id++, "Ephemerality", "The type of ephemerality for the node",
337 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
338 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
339 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
340 RRDF_FIELD_OPTS_VISIBLE,
341 NULL);
342
343 buffer_rrdf_table_add_field(wb, field_id++, "AgentName", "The name of the Netdata agent",
344 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
345 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
346 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
347 RRDF_FIELD_OPTS_NONE,
348 NULL);
349
350 buffer_rrdf_table_add_field(wb, field_id++, "AgentVersion", "The version of the Netdata agent",
351 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
352 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
353 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
354 RRDF_FIELD_OPTS_NONE,
355 NULL);
356
357 buffer_rrdf_table_add_field(wb, field_id++, "OSName", "The name of the host's operating system",
358 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
359 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
360 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
361 RRDF_FIELD_OPTS_NONE,
362 NULL);
363
364 buffer_rrdf_table_add_field(wb, field_id++, "OSId", "The identifier of the host's operating system",
365 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
366 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
367 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
368 RRDF_FIELD_OPTS_NONE,
369 NULL);
370
371 buffer_rrdf_table_add_field(wb, field_id++, "OSIdLike", "The ID-like string for the host's OS",
372 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
373 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
374 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
375 RRDF_FIELD_OPTS_NONE,
376 NULL);
377
378 buffer_rrdf_table_add_field(wb, field_id++, "OSVersion", "The version of the host's operating system",
379 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
380 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
381 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
382 RRDF_FIELD_OPTS_NONE,
383 NULL);
384
385 buffer_rrdf_table_add_field(wb, field_id++, "OSVersionId", "The version identifier of the host's OS",
386 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
387 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
388 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
389 RRDF_FIELD_OPTS_NONE,
390 NULL);
391
392 buffer_rrdf_table_add_field(wb, field_id++, "OSDetection", "Details about host OS detection",
393 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
394 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
395 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
396 RRDF_FIELD_OPTS_NONE,
397 NULL);
398
399 buffer_rrdf_table_add_field(wb, field_id++, "CPUCores", "The number of CPU cores in the host",
400 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
401 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
402 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
403 RRDF_FIELD_OPTS_NONE,
404 NULL);
405
406 buffer_rrdf_table_add_field(wb, field_id++, "DiskSpace", "The total disk space available on the host",
407 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
408 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
409 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_NONE,
410 RRDF_FIELD_OPTS_NONE,
411 NULL);
412
413 buffer_rrdf_table_add_field(wb, field_id++, "CPUFreq", "The CPU frequency of the host",
414 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
415 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
416 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_NONE,
417 RRDF_FIELD_OPTS_NONE,
418 NULL);
419
420 buffer_rrdf_table_add_field(wb, field_id++, "RAMTotal", "The total RAM available on the host",
421 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
422 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
423 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_NONE,
424 RRDF_FIELD_OPTS_NONE,
425 NULL);
426
427 buffer_rrdf_table_add_field(wb, field_id++, "ContainerOSName", "The name of the container's operating system",
428 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
429 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
430 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
431 RRDF_FIELD_OPTS_NONE,
432 NULL);
433
434 buffer_rrdf_table_add_field(wb, field_id++, "ContainerOSId", "The identifier of the container's operating system",
435 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
436 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
437 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
438 RRDF_FIELD_OPTS_NONE,
439 NULL);
440
441 buffer_rrdf_table_add_field(wb, field_id++, "ContainerOSIdLike", "The ID-like string for the container's OS",
442 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
443 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
444 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
445 RRDF_FIELD_OPTS_NONE,
446 NULL);
447
448 buffer_rrdf_table_add_field(wb, field_id++, "ContainerOSVersion", "The version of the container's OS",
449 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
450 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
451 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
452 RRDF_FIELD_OPTS_NONE,
453 NULL);
454
455 buffer_rrdf_table_add_field(wb, field_id++, "ContainerOSVersionId", "The version identifier of the container's OS",
456 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
457 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
458 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
459 RRDF_FIELD_OPTS_NONE,
460 NULL);
461
462 buffer_rrdf_table_add_field(wb, field_id++, "ContainerOSDetection", "Details about container OS detection",
463 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
464 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
465 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
466 RRDF_FIELD_OPTS_NONE,
467 NULL);
468
469 buffer_rrdf_table_add_field(wb, field_id++, "IsK8sNode", "Whether this node is part of a Kubernetes cluster",
470 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
471 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
472 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
473 RRDF_FIELD_OPTS_NONE,
474 NULL);
475
476 buffer_rrdf_table_add_field(wb, field_id++, "KernelName", "The kernel name",
477 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
478 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
479 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
480 RRDF_FIELD_OPTS_NONE,
481 NULL);
482
483 buffer_rrdf_table_add_field(wb, field_id++, "KernelVersion", "The kernel version",
484 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
485 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
486 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
487 RRDF_FIELD_OPTS_NONE,
488 NULL);
489
490 buffer_rrdf_table_add_field(wb, field_id++, "Architecture", "The system architecture",
491 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
492 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
493 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
494 RRDF_FIELD_OPTS_NONE,
495 NULL);
496
497 buffer_rrdf_table_add_field(wb, field_id++, "Virtualization", "The virtualization technology in use",
498 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
499 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
500 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
501 RRDF_FIELD_OPTS_NONE,
502 NULL);
503
504 buffer_rrdf_table_add_field(wb, field_id++, "VirtDetection", "Details about virtualization detection",
505 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
506 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
507 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
508 RRDF_FIELD_OPTS_NONE,
509 NULL);
510
511 buffer_rrdf_table_add_field(wb, field_id++, "Container", "Container type information",
512 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
513 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
514 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
515 RRDF_FIELD_OPTS_NONE,
516 NULL);
517
518 buffer_rrdf_table_add_field(wb, field_id++, "ContainerDetection", "Details about container detection",
519 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
520 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
521 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
522 RRDF_FIELD_OPTS_NONE,
523 NULL);
524
525 buffer_rrdf_table_add_field(wb, field_id++, "CloudProviderType", "The type of cloud provider",
526 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
527 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
528 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
529 RRDF_FIELD_OPTS_NONE,
530 NULL);
531
532 buffer_rrdf_table_add_field(wb, field_id++, "CloudInstanceType", "The type of cloud instance",
533 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
534 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
535 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
536 RRDF_FIELD_OPTS_NONE,
537 NULL);
538
539 buffer_rrdf_table_add_field(wb, field_id++, "CloudInstanceRegion", "The region of the cloud instance",
540 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
541 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
542 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
543 RRDF_FIELD_OPTS_NONE,
544 NULL);
545
546 buffer_rrdf_table_add_field(wb, field_id++, "dbFrom", "DB Data Retention From",
547 RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
548 0, NULL, (double)max_db_from * MSEC_PER_SEC, RRDF_FIELD_SORT_ASCENDING, NULL,
549 RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_NONE,
550 RRDF_FIELD_OPTS_NONE, NULL);
551
552 buffer_rrdf_table_add_field(wb, field_id++, "dbTo", "DB Data Retention To",
553 RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
554 0, NULL, (double)max_db_to * MSEC_PER_SEC, RRDF_FIELD_SORT_ASCENDING, NULL,
555 RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_NONE,
556 RRDF_FIELD_OPTS_NONE, NULL);
557
558 buffer_rrdf_table_add_field(wb, field_id++, "dbDuration", "DB Data Retention Duration",
559 RRDF_FIELD_TYPE_DURATION, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DURATION_S,
560 0, NULL, (double)max_db_duration, RRDF_FIELD_SORT_ASCENDING, NULL,
561 RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_NONE,
562 RRDF_FIELD_OPTS_VISIBLE, NULL);
563
564 buffer_rrdf_table_add_field(wb, field_id++, "dbMetrics", "Time-series Metrics in the DB",
565 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
566 0, NULL, (double)max_db_metrics, RRDF_FIELD_SORT_DESCENDING, NULL,
567 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
568 RRDF_FIELD_OPTS_VISIBLE, NULL);
569
570 buffer_rrdf_table_add_field(wb, field_id++, "dbInstances", "Instances in the DB",
571 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
572 0, NULL, (double)max_db_instances, RRDF_FIELD_SORT_DESCENDING, NULL,
573 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
574 RRDF_FIELD_OPTS_VISIBLE, NULL);
575
576 buffer_rrdf_table_add_field(wb, field_id++, "dbContexts", "Contexts in the DB",
577 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
578 0, NULL, (double)max_db_contexts, RRDF_FIELD_SORT_DESCENDING, NULL,
579 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
580 RRDF_FIELD_OPTS_VISIBLE, NULL);
581
582 // --- statuses ---
583
584 buffer_rrdf_table_add_field(wb, field_id++, "InStatus", "Data Collection Online Status",
585 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
586 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
587 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
588 RRDF_FIELD_OPTS_VISIBLE, NULL);
589
590
591 buffer_rrdf_table_add_field(wb, field_id++, "OutStatus", "Streaming Online Status",
592 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
593 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
594 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
595 RRDF_FIELD_OPTS_VISIBLE, NULL);
596
597 buffer_rrdf_table_add_field(wb, field_id++, "MlStatus", "ML Status",
598 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
599 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
600 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
601 RRDF_FIELD_OPTS_VISIBLE, NULL);
602
603 // --- collection ---
604
605 buffer_rrdf_table_add_field(wb, field_id++, "InConnections", "Number of times this child connected",
606 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
607 0, NULL, (double)max_in_connections, RRDF_FIELD_SORT_DESCENDING, NULL,
608 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
609 RRDF_FIELD_OPTS_NONE, NULL);
610
611 buffer_rrdf_table_add_field(wb, field_id++, "InSince", "Last Data Collection Status Change",
612 RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
613 0, NULL, (double)max_in_since, RRDF_FIELD_SORT_DESCENDING, NULL,
614 RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_NONE,
615 RRDF_FIELD_OPTS_NONE, NULL);
616
617 buffer_rrdf_table_add_field(wb, field_id++, "InAge", "Last Data Collection Online Status Change Age",
618 RRDF_FIELD_TYPE_DURATION, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DURATION_S,
619 0, NULL, (double)max_in_age, RRDF_FIELD_SORT_ASCENDING, NULL,
620 RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_RANGE,
621 RRDF_FIELD_OPTS_VISIBLE, NULL);
622
623 buffer_rrdf_table_add_field(wb, field_id++, "InReason", "Data Collection Online Status Reason",
624 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
625 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
626 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
627 RRDF_FIELD_OPTS_VISIBLE, NULL);
628
629 buffer_rrdf_table_add_field(wb, field_id++, "InHops", "Data Collection Distance Hops from Origin Node",
630 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
631 0, NULL, (double)max_in_hops, RRDF_FIELD_SORT_ASCENDING, NULL,
632 RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
633 RRDF_FIELD_OPTS_VISIBLE, NULL);
634
635 buffer_rrdf_table_add_field(wb, field_id++, "InReplCompletion", "Inbound Replication Completion",
636 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
637 1, "%", 100.0, RRDF_FIELD_SORT_DESCENDING, NULL,
638 RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
639 RRDF_FIELD_OPTS_VISIBLE, NULL);
640
641 buffer_rrdf_table_add_field(wb, field_id++, "InReplInstances", "Inbound Replicating Instances",
642 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
643 0, "instances", (double)max_collection_replication_instances, RRDF_FIELD_SORT_DESCENDING,
644 NULL,
645 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
646 RRDF_FIELD_OPTS_NONE, NULL);
647
648 buffer_rrdf_table_add_field(wb, field_id++, "InLocalIP", "Inbound Local IP",
649 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
650 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
651 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
652 RRDF_FIELD_OPTS_NONE, NULL);
653
654 buffer_rrdf_table_add_field(wb, field_id++, "InLocalPort", "Inbound Local Port",
655 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
656 0, NULL, (double)max_in_local_port, RRDF_FIELD_SORT_ASCENDING, NULL,
657 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_RANGE,
658 RRDF_FIELD_OPTS_NONE, NULL);
659
660 buffer_rrdf_table_add_field(wb, field_id++, "InRemoteIP", "Inbound Remote IP",
661 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
662 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
663 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
664 RRDF_FIELD_OPTS_NONE, NULL);
665
666 buffer_rrdf_table_add_field(wb, field_id++, "InRemotePort", "Inbound Remote Port",
667 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
668 0, NULL, (double)max_in_remote_port, RRDF_FIELD_SORT_ASCENDING, NULL,
669 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_RANGE,
670 RRDF_FIELD_OPTS_NONE, NULL);
671
672 buffer_rrdf_table_add_field(wb, field_id++, "InSSL", "Inbound SSL Connection",
673 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
674 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
675 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
676 RRDF_FIELD_OPTS_NONE, NULL);
677
678 buffer_rrdf_table_add_field(wb, field_id++, "InCapabilities", "Inbound Connection Capabilities",
679 RRDF_FIELD_TYPE_ARRAY, RRDF_FIELD_VISUAL_PILL, RRDF_FIELD_TRANSFORM_NONE,
680 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
681 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
682 RRDF_FIELD_OPTS_NONE, NULL);
683
684 buffer_rrdf_table_add_field(wb, field_id++, "CollectedMetrics", "Time-series Metrics Currently Collected",
685 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
686 0, NULL, (double)max_db_metrics, RRDF_FIELD_SORT_DESCENDING, NULL,
687 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
688 RRDF_FIELD_OPTS_VISIBLE, NULL);
689
690 buffer_rrdf_table_add_field(wb, field_id++, "CollectedInstances", "Instances Currently Collected",
691 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
692 0, NULL, (double)max_db_instances, RRDF_FIELD_SORT_DESCENDING, NULL,
693 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
694 RRDF_FIELD_OPTS_VISIBLE, NULL);
695
696 buffer_rrdf_table_add_field(wb, field_id++, "CollectedContexts", "Contexts Currently Collected",
697 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
698 0, NULL, (double)max_db_contexts, RRDF_FIELD_SORT_DESCENDING, NULL,
699 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
700 RRDF_FIELD_OPTS_VISIBLE, NULL);
701
702 // --- streaming ---
703
704 buffer_rrdf_table_add_field(wb, field_id++, "OutConnections", "Number of times connected to a parent",
705 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
706 0, NULL, (double)max_out_connections, RRDF_FIELD_SORT_DESCENDING, NULL,
707 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
708 RRDF_FIELD_OPTS_NONE, NULL);
709
710 buffer_rrdf_table_add_field(wb, field_id++, "OutSince", "Last Streaming Status Change",
711 RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
712 0, NULL, (double)max_out_since, RRDF_FIELD_SORT_DESCENDING, NULL,
713 RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_NONE,
714 RRDF_FIELD_OPTS_NONE, NULL);
715
716 buffer_rrdf_table_add_field(wb, field_id++, "OutAge", "Last Streaming Status Change Age",
717 RRDF_FIELD_TYPE_DURATION, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DURATION_S,
718 0, NULL, (double)max_out_age, RRDF_FIELD_SORT_ASCENDING, NULL,
719 RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
720 RRDF_FIELD_OPTS_VISIBLE, NULL);
721
722 buffer_rrdf_table_add_field(wb, field_id++, "OutReason", "Streaming Status Reason",
723 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
724 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
725 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
726 RRDF_FIELD_OPTS_VISIBLE, NULL);
727
728 buffer_rrdf_table_add_field(wb, field_id++, "OutHops", "Streaming Distance Hops from Origin Node",
729 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
730 0, NULL, (double)max_out_hops, RRDF_FIELD_SORT_ASCENDING, NULL,
731 RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
732 RRDF_FIELD_OPTS_VISIBLE, NULL);
733
734 buffer_rrdf_table_add_field(wb, field_id++, "OutReplCompletion", "Outbound Replication Completion",
735 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
736 1, "%", 100.0, RRDF_FIELD_SORT_DESCENDING, NULL,
737 RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
738 RRDF_FIELD_OPTS_VISIBLE, NULL);
739
740 buffer_rrdf_table_add_field(wb, field_id++, "OutReplInstances", "Outbound Replicating Instances",
741 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
742 0, "instances", (double)max_streaming_replication_instances, RRDF_FIELD_SORT_DESCENDING,
743 NULL,
744 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
745 RRDF_FIELD_OPTS_NONE, NULL);
746
747 buffer_rrdf_table_add_field(wb, field_id++, "OutLocalIP", "Outbound Local IP",
748 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
749 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
750 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
751 RRDF_FIELD_OPTS_NONE, NULL);
752
753 buffer_rrdf_table_add_field(wb, field_id++, "OutLocalPort", "Outbound Local Port",
754 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
755 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
756 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_NONE,
757 RRDF_FIELD_OPTS_NONE, NULL);
758
759 buffer_rrdf_table_add_field(wb, field_id++, "OutRemoteIP", "Outbound Remote IP",
760 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
761 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
762 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
763 RRDF_FIELD_OPTS_NONE, NULL);
764
765 buffer_rrdf_table_add_field(wb, field_id++, "OutRemotePort", "Outbound Remote Port",
766 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
767 0, NULL, (double)max_out_remote_port, RRDF_FIELD_SORT_ASCENDING, NULL,
768 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_RANGE,
769 RRDF_FIELD_OPTS_NONE, NULL);
770
771 buffer_rrdf_table_add_field(wb, field_id++, "OutSSL", "Outbound SSL Connection",
772 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
773 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
774 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
775 RRDF_FIELD_OPTS_NONE, NULL);
776
777 buffer_rrdf_table_add_field(wb, field_id++, "OutCompression", "Outbound Compressed Connection",
778 RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
779 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
780 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
781 RRDF_FIELD_OPTS_NONE, NULL);
782
783 buffer_rrdf_table_add_field(wb, field_id++, "OutCapabilities", "Outbound Connection Capabilities",
784 RRDF_FIELD_TYPE_ARRAY, RRDF_FIELD_VISUAL_PILL, RRDF_FIELD_TRANSFORM_NONE,
785 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
786 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
787 RRDF_FIELD_OPTS_NONE, NULL);
788
789 buffer_rrdf_table_add_field(wb, field_id++, "OutTrafficData", "Outbound Metric Data Traffic",
790 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
791 0, "bytes", (double)max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_DATA],
792 RRDF_FIELD_SORT_DESCENDING, NULL,
793 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
794 RRDF_FIELD_OPTS_NONE, NULL);
795
796 buffer_rrdf_table_add_field(wb, field_id++, "OutTrafficMetadata", "Outbound Metric Metadata Traffic",
797 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
798 0, "bytes",
799 (double)max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_METADATA],
800 RRDF_FIELD_SORT_DESCENDING, NULL,
801 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
802 RRDF_FIELD_OPTS_NONE, NULL);
803
804 buffer_rrdf_table_add_field(wb, field_id++, "OutTrafficReplication", "Outbound Metric Replication Traffic",
805 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
806 0, "bytes",
807 (double)max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_REPLICATION],
808 RRDF_FIELD_SORT_DESCENDING, NULL,
809 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
810 RRDF_FIELD_OPTS_NONE, NULL);
811
812 buffer_rrdf_table_add_field(wb, field_id++, "OutTrafficFunctions", "Outbound Metric Functions Traffic",
813 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
814 0, "bytes",
815 (double)max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_FUNCTIONS],
816 RRDF_FIELD_SORT_DESCENDING, NULL,
817 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
818 RRDF_FIELD_OPTS_NONE, NULL);
819
820 buffer_rrdf_table_add_field(wb, field_id++, "OutAttemptHandshake",
821 "Outbound Connection Attempt Handshake Status",
822 RRDF_FIELD_TYPE_ARRAY, RRDF_FIELD_VISUAL_PILL, RRDF_FIELD_TRANSFORM_NONE,
823 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
824 RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
825 RRDF_FIELD_OPTS_NONE, NULL);
826
827 buffer_rrdf_table_add_field(wb, field_id++, "OutAttemptSince",
828 "Last Outbound Connection Attempt Status Change Time",
829 RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
830 0, NULL, (double)max_out_attempt_since, RRDF_FIELD_SORT_DESCENDING, NULL,
831 RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_NONE,
832 RRDF_FIELD_OPTS_NONE, NULL);
833
834 buffer_rrdf_table_add_field(wb, field_id++, "OutAttemptAge",
835 "Last Outbound Connection Attempt Status Change Age",
836 RRDF_FIELD_TYPE_DURATION, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DURATION_S,
837 0, NULL, (double)max_out_attempt_age, RRDF_FIELD_SORT_ASCENDING, NULL,
838 RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
839 RRDF_FIELD_OPTS_VISIBLE, NULL);
840
841 // --- ML ---
842
843 buffer_rrdf_table_add_field(wb, field_id++, "MlAnomalous", "Number of Anomalous Metrics",
844 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
845 0, "metrics",
846 (double)max_ml_anomalous,
847 RRDF_FIELD_SORT_DESCENDING, NULL,
848 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
849 RRDF_FIELD_OPTS_NONE, NULL);
850
851 buffer_rrdf_table_add_field(wb, field_id++, "MlNormal", "Number of Not Anomalous Metrics",
852 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
853 0, "metrics",
854 (double)max_ml_normal,
855 RRDF_FIELD_SORT_DESCENDING, NULL,
856 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
857 RRDF_FIELD_OPTS_NONE, NULL);
858
859 buffer_rrdf_table_add_field(wb, field_id++, "MlTrained", "Number of Trained Metrics",
860 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
861 0, "metrics",
862 (double)max_ml_trained,
863 RRDF_FIELD_SORT_DESCENDING, NULL,
864 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
865 RRDF_FIELD_OPTS_NONE, NULL);
866
867 buffer_rrdf_table_add_field(wb, field_id++, "MlPending", "Number of Pending Metrics",
868 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
869 0, "metrics",
870 (double)max_ml_pending,
871 RRDF_FIELD_SORT_DESCENDING, NULL,
872 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
873 RRDF_FIELD_OPTS_NONE, NULL);
874
875 buffer_rrdf_table_add_field(wb, field_id++, "MlSilenced", "Number of Silenced Metrics",
876 RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
877 0, "metrics",
878 (double)max_ml_silenced,
879 RRDF_FIELD_SORT_DESCENDING, NULL,
880 RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
881 RRDF_FIELD_OPTS_NONE, NULL);
882 }
883 buffer_json_object_close(wb); // columns
884 buffer_json_member_add_string(wb, "default_sort_column", "Node");
885 buffer_json_member_add_object(wb, "charts");
886 {
887 // Data Collection Age chart
888 buffer_json_member_add_object(wb, "InAge");
889 {
890 buffer_json_member_add_string(wb, "name", "Data Collection Age");
891 buffer_json_member_add_string(wb, "type", "stacked-bar");
892 buffer_json_member_add_array(wb, "columns");
893 {
894 buffer_json_add_array_item_string(wb, "InAge");
895 }
896 buffer_json_array_close(wb);
897 }
898 buffer_json_object_close(wb);
899
900 // Streaming Age chart
901 buffer_json_member_add_object(wb, "OutAge");
902 {
903 buffer_json_member_add_string(wb, "name", "Streaming Age");
904 buffer_json_member_add_string(wb, "type", "stacked-bar");
905 buffer_json_member_add_array(wb, "columns");
906 {
907 buffer_json_add_array_item_string(wb, "OutAge");
908 }
909 buffer_json_array_close(wb);
910 }
911 buffer_json_object_close(wb);
912
913 // DB Duration
914 buffer_json_member_add_object(wb, "dbDuration");
915 {
916 buffer_json_member_add_string(wb, "name", "Retention Duration");
917 buffer_json_member_add_string(wb, "type", "stacked-bar");
918 buffer_json_member_add_array(wb, "columns");
919 {
920 buffer_json_add_array_item_string(wb, "dbDuration");
921 }
922 buffer_json_array_close(wb);
923 }
924 buffer_json_object_close(wb);
925 }
926 buffer_json_object_close(wb); // charts
927
928 buffer_json_member_add_array(wb, "default_charts");
929 {
930 buffer_json_add_array_item_array(wb);
931 buffer_json_add_array_item_string(wb, "InAge");
932 buffer_json_add_array_item_string(wb, "Node");
933 buffer_json_array_close(wb);
934
935 buffer_json_add_array_item_array(wb);
936 buffer_json_add_array_item_string(wb, "OutAge");
937 buffer_json_add_array_item_string(wb, "Node");
938 buffer_json_array_close(wb);
939 }
940 buffer_json_array_close(wb);
941
942 buffer_json_member_add_object(wb, "group_by");
943 {
944 GROUP_BY_COLUMN("OSName", "O/S Name");
945 GROUP_BY_COLUMN("OSId", "O/S ID");
946 GROUP_BY_COLUMN("OSIdLike", "O/S ID Like");
947 GROUP_BY_COLUMN("OSVersion", "O/S Version");
948 GROUP_BY_COLUMN("OSVersionId", "O/S Version ID");
949 GROUP_BY_COLUMN("OSDetection", "O/S Detection");
950 GROUP_BY_COLUMN("CPUCores", "CPU Cores");
951 GROUP_BY_COLUMN("ContainerOSName", "Container O/S Name");
952 GROUP_BY_COLUMN("ContainerOSId", "Container O/S ID");
953 GROUP_BY_COLUMN("ContainerOSIdLike", "Container O/S ID Like");
954 GROUP_BY_COLUMN("ContainerOSVersion", "Container O/S Version");
955 GROUP_BY_COLUMN("ContainerOSVersionId", "Container O/S Version ID");
956 GROUP_BY_COLUMN("ContainerOSDetection", "Container O/S Detection");
957 GROUP_BY_COLUMN("IsK8sNode", "Kubernetes Nodes");
958 GROUP_BY_COLUMN("KernelName", "Kernel Name");
959 GROUP_BY_COLUMN("KernelVersion", "Kernel Version");
960 GROUP_BY_COLUMN("Architecture", "Architecture");
961 GROUP_BY_COLUMN("Virtualization", "Virtualization Technology");
962 GROUP_BY_COLUMN("VirtDetection", "Virtualization Detection");
963 GROUP_BY_COLUMN("Container", "Container");
964 GROUP_BY_COLUMN("ContainerDetection", "Container Detection");
965 GROUP_BY_COLUMN("CloudProviderType", "Cloud Provider Type");
966 GROUP_BY_COLUMN("CloudInstanceType", "Cloud Instance Type");
967 GROUP_BY_COLUMN("CloudInstanceRegion", "Cloud Instance Region");
968
969 GROUP_BY_COLUMN("InStatus", "Collection Status");
970 GROUP_BY_COLUMN("OutStatus", "Streaming Status");
971 GROUP_BY_COLUMN("MlStatus", "ML Status");
972 GROUP_BY_COLUMN("InRemoteIP", "Inbound IP");
973 GROUP_BY_COLUMN("OutRemoteIP", "Outbound IP");
974 }
975 buffer_json_object_close(wb); // group_by
976
977 buffer_json_member_add_time_t(wb, "expires", now_realtime_sec() + STREAMING_FUNCTION_UPDATE_EVERY);
978 buffer_json_finalize(wb);
979
980 return HTTP_RESP_OK;
981 }