summaryrefslogtreecommitdiffstats
path: root/src/web/api/functions
diff options
context:
space:
mode:
Diffstat (limited to 'src/web/api/functions')
-rw-r--r--src/web/api/functions/function-bearer_get_token.c81
-rw-r--r--src/web/api/functions/function-bearer_get_token.h14
-rw-r--r--src/web/api/functions/function-progress.c8
-rw-r--r--src/web/api/functions/function-progress.h10
-rw-r--r--src/web/api/functions/function-streaming.c627
-rw-r--r--src/web/api/functions/function-streaming.h12
-rw-r--r--src/web/api/functions/functions.c43
-rw-r--r--src/web/api/functions/functions.h14
8 files changed, 809 insertions, 0 deletions
diff --git a/src/web/api/functions/function-bearer_get_token.c b/src/web/api/functions/function-bearer_get_token.c
new file mode 100644
index 000000000..8f14e68ae
--- /dev/null
+++ b/src/web/api/functions/function-bearer_get_token.c
@@ -0,0 +1,81 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#include "function-bearer_get_token.h"
+#include "../v2/api_v2_calls.h"
+
+struct bearer_token_request {
+ nd_uuid_t claim_id;
+ nd_uuid_t machine_guid;
+ nd_uuid_t node_id;
+ HTTP_USER_ROLE user_role;
+ HTTP_ACCESS access;
+ nd_uuid_t cloud_account_id;
+ STRING *client_name;
+};
+
+static bool bearer_parse_json_payload(json_object *jobj, const char *path, void *data, BUFFER *error) {
+ struct bearer_token_request *rq = data;
+ JSONC_PARSE_TXT2UUID_OR_ERROR_AND_RETURN(jobj, path, "claim_id", rq->claim_id, error, true);
+ JSONC_PARSE_TXT2UUID_OR_ERROR_AND_RETURN(jobj, path, "machine_guid", rq->machine_guid, error, true);
+ JSONC_PARSE_TXT2UUID_OR_ERROR_AND_RETURN(jobj, path, "node_id", rq->node_id, error, true);
+ JSONC_PARSE_TXT2ENUM_OR_ERROR_AND_RETURN(jobj, path, "user_role", http_user_role2id, rq->user_role, error, true);
+ JSONC_PARSE_ARRAY_OF_TXT2BITMAP_OR_ERROR_AND_RETURN(jobj, path, "access", http_access2id_one, rq->access, error, true);
+ JSONC_PARSE_TXT2UUID_OR_ERROR_AND_RETURN(jobj, path, "cloud_account_id", rq->cloud_account_id, error, true);
+ JSONC_PARSE_TXT2STRING_OR_ERROR_AND_RETURN(jobj, path, "client_name", rq->client_name, error, true);
+ return true;
+}
+
+int function_bearer_get_token(BUFFER *wb, const char *function __maybe_unused, BUFFER *payload, const char *source) {
+ if(!request_source_is_cloud(source))
+ return rrd_call_function_error(
+ wb, "Bearer tokens can only be provided via NC.", HTTP_RESP_BAD_REQUEST);
+
+ int code;
+ struct bearer_token_request rq = { 0 };
+ CLEAN_JSON_OBJECT *jobj = json_parse_function_payload_or_error(wb, payload, &code, bearer_parse_json_payload, &rq);
+ if(!jobj || code != HTTP_RESP_OK) {
+ string_freez(rq.client_name);
+ return code;
+ }
+
+ char claim_id[UUID_STR_LEN];
+ uuid_unparse_lower(rq.claim_id, claim_id);
+
+ char machine_guid[UUID_STR_LEN];
+ uuid_unparse_lower(rq.machine_guid, machine_guid);
+
+ char node_id[UUID_STR_LEN];
+ uuid_unparse_lower(rq.node_id, node_id);
+
+ int rc = bearer_get_token_json_response(wb, localhost, claim_id, machine_guid, node_id,
+ rq.user_role, rq.access, rq.cloud_account_id,
+ string2str(rq.client_name));
+
+ string_freez(rq.client_name);
+ return rc;
+}
+
+int call_function_bearer_get_token(RRDHOST *host, struct web_client *w, const char *claim_id, const char *machine_guid, const char *node_id) {
+ CLEAN_BUFFER *payload = buffer_create(0, NULL);
+ buffer_json_initialize(payload, "\"", "\"", 0, true, BUFFER_JSON_OPTIONS_MINIFY);
+ buffer_json_member_add_string(payload, "claim_id", claim_id);
+ buffer_json_member_add_string(payload, "machine_guid", machine_guid);
+ buffer_json_member_add_string(payload, "node_id", node_id);
+ buffer_json_member_add_string(payload, "user_role", http_id2user_role(w->user_role));
+ http_access2buffer_json_array(payload, "access", w->access);
+ buffer_json_member_add_uuid(payload, "cloud_account_id", w->auth.cloud_account_id);
+ buffer_json_member_add_string(payload, "client_name", w->auth.client_name);
+ buffer_json_finalize(payload);
+
+ CLEAN_BUFFER *source = buffer_create(0, NULL);
+ web_client_api_request_vX_source_to_buffer(w, source);
+
+ char transaction_str[UUID_COMPACT_STR_LEN];
+ uuid_unparse_lower_compact(w->transaction, transaction_str);
+ return rrd_function_run(host, w->response.data, 10,
+ w->access, RRDFUNCTIONS_BEARER_GET_TOKEN, true,
+ transaction_str, NULL, NULL,
+ NULL, NULL,
+ NULL, NULL,
+ payload, buffer_tostring(source), true);
+}
diff --git a/src/web/api/functions/function-bearer_get_token.h b/src/web/api/functions/function-bearer_get_token.h
new file mode 100644
index 000000000..03481ebb8
--- /dev/null
+++ b/src/web/api/functions/function-bearer_get_token.h
@@ -0,0 +1,14 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_FUNCTION_BEARER_GET_TOKEN_H
+#define NETDATA_FUNCTION_BEARER_GET_TOKEN_H
+
+#include "daemon/common.h"
+
+int function_bearer_get_token(BUFFER *wb, const char *function, BUFFER *payload, const char *source);
+int call_function_bearer_get_token(RRDHOST *host, struct web_client *w, const char *claim_id, const char *machine_guid, const char *node_id);
+
+#define RRDFUNCTIONS_BEARER_GET_TOKEN "bearer_get_token"
+#define RRDFUNCTIONS_BEARER_GET_TOKEN_HELP "Get a bearer token for authenticated direct access to the agent"
+
+#endif //NETDATA_FUNCTION_BEARER_GET_TOKEN_H
diff --git a/src/web/api/functions/function-progress.c b/src/web/api/functions/function-progress.c
new file mode 100644
index 000000000..052a9020a
--- /dev/null
+++ b/src/web/api/functions/function-progress.c
@@ -0,0 +1,8 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#include "function-progress.h"
+
+int function_progress(BUFFER *wb, const char *function __maybe_unused, BUFFER *payload __maybe_unused, const char *source __maybe_unused) {
+ return progress_function_result(wb, rrdhost_hostname(localhost));
+}
+
diff --git a/src/web/api/functions/function-progress.h b/src/web/api/functions/function-progress.h
new file mode 100644
index 000000000..7d2d10b9d
--- /dev/null
+++ b/src/web/api/functions/function-progress.h
@@ -0,0 +1,10 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_FUNCTION_PROGRESS_H
+#define NETDATA_FUNCTION_PROGRESS_H
+
+#include "daemon/common.h"
+
+int function_progress(BUFFER *wb, const char *function, BUFFER *payload, const char *source);
+
+#endif //NETDATA_FUNCTION_PROGRESS_H
diff --git a/src/web/api/functions/function-streaming.c b/src/web/api/functions/function-streaming.c
new file mode 100644
index 000000000..11e970441
--- /dev/null
+++ b/src/web/api/functions/function-streaming.c
@@ -0,0 +1,627 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#include "function-streaming.h"
+
+int function_streaming(BUFFER *wb, const char *function __maybe_unused, BUFFER *payload __maybe_unused, const char *source __maybe_unused) {
+
+ time_t now = now_realtime_sec();
+
+ buffer_flush(wb);
+ wb->content_type = CT_APPLICATION_JSON;
+ buffer_json_initialize(wb, "\"", "\"", 0, true, BUFFER_JSON_OPTIONS_DEFAULT);
+
+ buffer_json_member_add_string(wb, "hostname", rrdhost_hostname(localhost));
+ buffer_json_member_add_uint64(wb, "status", HTTP_RESP_OK);
+ buffer_json_member_add_string(wb, "type", "table");
+ buffer_json_member_add_time_t(wb, "update_every", 1);
+ buffer_json_member_add_boolean(wb, "has_history", false);
+ buffer_json_member_add_string(wb, "help", RRDFUNCTIONS_STREAMING_HELP);
+ buffer_json_member_add_array(wb, "data");
+
+ size_t max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_MAX] = { 0 };
+ size_t max_db_metrics = 0, max_db_instances = 0, max_db_contexts = 0;
+ size_t max_collection_replication_instances = 0, max_streaming_replication_instances = 0;
+ size_t max_ml_anomalous = 0, max_ml_normal = 0, max_ml_trained = 0, max_ml_pending = 0, max_ml_silenced = 0;
+ {
+ RRDHOST *host;
+ dfe_start_read(rrdhost_root_index, host) {
+ RRDHOST_STATUS s;
+ rrdhost_status(host, now, &s);
+ buffer_json_add_array_item_array(wb);
+
+ if(s.db.metrics > max_db_metrics)
+ max_db_metrics = s.db.metrics;
+
+ if(s.db.instances > max_db_instances)
+ max_db_instances = s.db.instances;
+
+ if(s.db.contexts > max_db_contexts)
+ max_db_contexts = s.db.contexts;
+
+ if(s.ingest.replication.instances > max_collection_replication_instances)
+ max_collection_replication_instances = s.ingest.replication.instances;
+
+ if(s.stream.replication.instances > max_streaming_replication_instances)
+ max_streaming_replication_instances = s.stream.replication.instances;
+
+ for(int i = 0; i < STREAM_TRAFFIC_TYPE_MAX ;i++) {
+ if (s.stream.sent_bytes_on_this_connection_per_type[i] >
+ max_sent_bytes_on_this_connection_per_type[i])
+ max_sent_bytes_on_this_connection_per_type[i] =
+ s.stream.sent_bytes_on_this_connection_per_type[i];
+ }
+
+ // retention
+ buffer_json_add_array_item_string(wb, rrdhost_hostname(s.host)); // Node
+ buffer_json_add_array_item_uint64(wb, s.db.first_time_s * MSEC_PER_SEC); // dbFrom
+ buffer_json_add_array_item_uint64(wb, s.db.last_time_s * MSEC_PER_SEC); // dbTo
+
+ if(s.db.first_time_s && s.db.last_time_s && s.db.last_time_s > s.db.first_time_s)
+ buffer_json_add_array_item_uint64(wb, s.db.last_time_s - s.db.first_time_s); // dbDuration
+ else
+ buffer_json_add_array_item_string(wb, NULL); // dbDuration
+
+ buffer_json_add_array_item_uint64(wb, s.db.metrics); // dbMetrics
+ buffer_json_add_array_item_uint64(wb, s.db.instances); // dbInstances
+ buffer_json_add_array_item_uint64(wb, s.db.contexts); // dbContexts
+
+ // statuses
+ buffer_json_add_array_item_string(wb, rrdhost_ingest_status_to_string(s.ingest.status)); // InStatus
+ buffer_json_add_array_item_string(wb, rrdhost_streaming_status_to_string(s.stream.status)); // OutStatus
+ buffer_json_add_array_item_string(wb, rrdhost_ml_status_to_string(s.ml.status)); // MLStatus
+
+ // collection
+ if(s.ingest.since) {
+ buffer_json_add_array_item_uint64(wb, s.ingest.since * MSEC_PER_SEC); // InSince
+ buffer_json_add_array_item_time_t(wb, s.now - s.ingest.since); // InAge
+ }
+ else {
+ buffer_json_add_array_item_string(wb, NULL); // InSince
+ buffer_json_add_array_item_string(wb, NULL); // InAge
+ }
+ buffer_json_add_array_item_string(wb, stream_handshake_error_to_string(s.ingest.reason)); // InReason
+ buffer_json_add_array_item_uint64(wb, s.ingest.hops); // InHops
+ buffer_json_add_array_item_double(wb, s.ingest.replication.completion); // InReplCompletion
+ buffer_json_add_array_item_uint64(wb, s.ingest.replication.instances); // InReplInstances
+ buffer_json_add_array_item_string(wb, s.ingest.peers.local.ip); // InLocalIP
+ buffer_json_add_array_item_uint64(wb, s.ingest.peers.local.port); // InLocalPort
+ buffer_json_add_array_item_string(wb, s.ingest.peers.peer.ip); // InRemoteIP
+ buffer_json_add_array_item_uint64(wb, s.ingest.peers.peer.port); // InRemotePort
+ buffer_json_add_array_item_string(wb, s.ingest.ssl ? "SSL" : "PLAIN"); // InSSL
+ stream_capabilities_to_json_array(wb, s.ingest.capabilities, NULL); // InCapabilities
+
+ // streaming
+ if(s.stream.since) {
+ buffer_json_add_array_item_uint64(wb, s.stream.since * MSEC_PER_SEC); // OutSince
+ buffer_json_add_array_item_time_t(wb, s.now - s.stream.since); // OutAge
+ }
+ else {
+ buffer_json_add_array_item_string(wb, NULL); // OutSince
+ buffer_json_add_array_item_string(wb, NULL); // OutAge
+ }
+ buffer_json_add_array_item_string(wb, stream_handshake_error_to_string(s.stream.reason)); // OutReason
+ buffer_json_add_array_item_uint64(wb, s.stream.hops); // OutHops
+ buffer_json_add_array_item_double(wb, s.stream.replication.completion); // OutReplCompletion
+ buffer_json_add_array_item_uint64(wb, s.stream.replication.instances); // OutReplInstances
+ buffer_json_add_array_item_string(wb, s.stream.peers.local.ip); // OutLocalIP
+ buffer_json_add_array_item_uint64(wb, s.stream.peers.local.port); // OutLocalPort
+ buffer_json_add_array_item_string(wb, s.stream.peers.peer.ip); // OutRemoteIP
+ buffer_json_add_array_item_uint64(wb, s.stream.peers.peer.port); // OutRemotePort
+ buffer_json_add_array_item_string(wb, s.stream.ssl ? "SSL" : "PLAIN"); // OutSSL
+ buffer_json_add_array_item_string(wb, s.stream.compression ? "COMPRESSED" : "UNCOMPRESSED"); // OutCompression
+ stream_capabilities_to_json_array(wb, s.stream.capabilities, NULL); // OutCapabilities
+ buffer_json_add_array_item_uint64(wb, s.stream.sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_DATA]);
+ buffer_json_add_array_item_uint64(wb, s.stream.sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_METADATA]);
+ buffer_json_add_array_item_uint64(wb, s.stream.sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_REPLICATION]);
+ buffer_json_add_array_item_uint64(wb, s.stream.sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_FUNCTIONS]);
+
+ buffer_json_add_array_item_array(wb); // OutAttemptHandshake
+ time_t last_attempt = 0;
+ for(struct rrdpush_destinations *d = host->destinations; d ; d = d->next) {
+ if(d->since > last_attempt)
+ last_attempt = d->since;
+
+ buffer_json_add_array_item_string(wb, stream_handshake_error_to_string(d->reason));
+ }
+ buffer_json_array_close(wb); // // OutAttemptHandshake
+
+ if(!last_attempt) {
+ buffer_json_add_array_item_string(wb, NULL); // OutAttemptSince
+ buffer_json_add_array_item_string(wb, NULL); // OutAttemptAge
+ }
+ else {
+ buffer_json_add_array_item_uint64(wb, last_attempt * 1000); // OutAttemptSince
+ buffer_json_add_array_item_time_t(wb, s.now - last_attempt); // OutAttemptAge
+ }
+
+ // ML
+ if(s.ml.status == RRDHOST_ML_STATUS_RUNNING) {
+ buffer_json_add_array_item_uint64(wb, s.ml.metrics.anomalous); // MlAnomalous
+ buffer_json_add_array_item_uint64(wb, s.ml.metrics.normal); // MlNormal
+ buffer_json_add_array_item_uint64(wb, s.ml.metrics.trained); // MlTrained
+ buffer_json_add_array_item_uint64(wb, s.ml.metrics.pending); // MlPending
+ buffer_json_add_array_item_uint64(wb, s.ml.metrics.silenced); // MlSilenced
+
+ if(s.ml.metrics.anomalous > max_ml_anomalous)
+ max_ml_anomalous = s.ml.metrics.anomalous;
+
+ if(s.ml.metrics.normal > max_ml_normal)
+ max_ml_normal = s.ml.metrics.normal;
+
+ if(s.ml.metrics.trained > max_ml_trained)
+ max_ml_trained = s.ml.metrics.trained;
+
+ if(s.ml.metrics.pending > max_ml_pending)
+ max_ml_pending = s.ml.metrics.pending;
+
+ if(s.ml.metrics.silenced > max_ml_silenced)
+ max_ml_silenced = s.ml.metrics.silenced;
+
+ }
+ else {
+ buffer_json_add_array_item_string(wb, NULL); // MlAnomalous
+ buffer_json_add_array_item_string(wb, NULL); // MlNormal
+ buffer_json_add_array_item_string(wb, NULL); // MlTrained
+ buffer_json_add_array_item_string(wb, NULL); // MlPending
+ buffer_json_add_array_item_string(wb, NULL); // MlSilenced
+ }
+
+ // close
+ buffer_json_array_close(wb);
+ }
+ dfe_done(host);
+ }
+ buffer_json_array_close(wb); // data
+ buffer_json_member_add_object(wb, "columns");
+ {
+ size_t field_id = 0;
+
+ // Node
+ buffer_rrdf_table_add_field(wb, field_id++, "Node", "Node's Hostname",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_VISIBLE | RRDF_FIELD_OPTS_UNIQUE_KEY | RRDF_FIELD_OPTS_STICKY,
+ NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "dbFrom", "DB Data Retention From",
+ RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "dbTo", "DB Data Retention To",
+ RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "dbDuration", "DB Data Retention Duration",
+ RRDF_FIELD_TYPE_DURATION, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DURATION_S,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "dbMetrics", "Time-series Metrics in the DB",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, NULL, (double)max_db_metrics, RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "dbInstances", "Instances in the DB",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, NULL, (double)max_db_instances, RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "dbContexts", "Contexts in the DB",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, NULL, (double)max_db_contexts, RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ // --- statuses ---
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InStatus", "Data Collection Online Status",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutStatus", "Streaming Online Status",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "MlStatus", "ML Status",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ // --- collection ---
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InSince", "Last Data Collection Status Change",
+ RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
+ 0, NULL, NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InAge", "Last Data Collection Online Status Change Age",
+ RRDF_FIELD_TYPE_DURATION, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DURATION_S,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InReason", "Data Collection Online Status Reason",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InHops", "Data Collection Distance Hops from Origin Node",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InReplCompletion", "Inbound Replication Completion",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
+ 1, "%", 100.0, RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InReplInstances", "Inbound Replicating Instances",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "instances", (double)max_collection_replication_instances, RRDF_FIELD_SORT_DESCENDING,
+ NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InLocalIP", "Inbound Local IP",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InLocalPort", "Inbound Local Port",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InRemoteIP", "Inbound Remote IP",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InRemotePort", "Inbound Remote Port",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InSSL", "Inbound SSL Connection",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "InCapabilities", "Inbound Connection Capabilities",
+ RRDF_FIELD_TYPE_ARRAY, RRDF_FIELD_VISUAL_PILL, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ // --- streaming ---
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutSince", "Last Streaming Status Change",
+ RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
+ 0, NULL, NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutAge", "Last Streaming Status Change Age",
+ RRDF_FIELD_TYPE_DURATION, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DURATION_S,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutReason", "Streaming Status Reason",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutHops", "Streaming Distance Hops from Origin Node",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutReplCompletion", "Outbound Replication Completion",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_BAR, RRDF_FIELD_TRANSFORM_NUMBER,
+ 1, "%", 100.0, RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutReplInstances", "Outbound Replicating Instances",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "instances", (double)max_streaming_replication_instances, RRDF_FIELD_SORT_DESCENDING,
+ NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutLocalIP", "Outbound Local IP",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutLocalPort", "Outbound Local Port",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutRemoteIP", "Outbound Remote IP",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutRemotePort", "Outbound Remote Port",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutSSL", "Outbound SSL Connection",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutCompression", "Outbound Compressed Connection",
+ RRDF_FIELD_TYPE_STRING, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutCapabilities", "Outbound Connection Capabilities",
+ RRDF_FIELD_TYPE_ARRAY, RRDF_FIELD_VISUAL_PILL, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutTrafficData", "Outbound Metric Data Traffic",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "bytes", (double)max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_DATA],
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutTrafficMetadata", "Outbound Metric Metadata Traffic",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "bytes",
+ (double)max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_METADATA],
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutTrafficReplication", "Outbound Metric Replication Traffic",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "bytes",
+ (double)max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_REPLICATION],
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutTrafficFunctions", "Outbound Metric Functions Traffic",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "bytes",
+ (double)max_sent_bytes_on_this_connection_per_type[STREAM_TRAFFIC_TYPE_FUNCTIONS],
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutAttemptHandshake",
+ "Outbound Connection Attempt Handshake Status",
+ RRDF_FIELD_TYPE_ARRAY, RRDF_FIELD_VISUAL_PILL, RRDF_FIELD_TRANSFORM_NONE,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_COUNT, RRDF_FIELD_FILTER_MULTISELECT,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutAttemptSince",
+ "Last Outbound Connection Attempt Status Change Time",
+ RRDF_FIELD_TYPE_TIMESTAMP, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DATETIME_MS,
+ 0, NULL, NAN, RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MAX, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "OutAttemptAge",
+ "Last Outbound Connection Attempt Status Change Age",
+ RRDF_FIELD_TYPE_DURATION, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_DURATION_S,
+ 0, NULL, NAN, RRDF_FIELD_SORT_ASCENDING, NULL,
+ RRDF_FIELD_SUMMARY_MIN, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_VISIBLE, NULL);
+
+ // --- ML ---
+
+ buffer_rrdf_table_add_field(wb, field_id++, "MlAnomalous", "Number of Anomalous Metrics",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "metrics",
+ (double)max_ml_anomalous,
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "MlNormal", "Number of Not Anomalous Metrics",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "metrics",
+ (double)max_ml_normal,
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "MlTrained", "Number of Trained Metrics",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "metrics",
+ (double)max_ml_trained,
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "MlPending", "Number of Pending Metrics",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "metrics",
+ (double)max_ml_pending,
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+
+ buffer_rrdf_table_add_field(wb, field_id++, "MlSilenced", "Number of Silenced Metrics",
+ RRDF_FIELD_TYPE_INTEGER, RRDF_FIELD_VISUAL_VALUE, RRDF_FIELD_TRANSFORM_NUMBER,
+ 0, "metrics",
+ (double)max_ml_silenced,
+ RRDF_FIELD_SORT_DESCENDING, NULL,
+ RRDF_FIELD_SUMMARY_SUM, RRDF_FIELD_FILTER_RANGE,
+ RRDF_FIELD_OPTS_NONE, NULL);
+ }
+ buffer_json_object_close(wb); // columns
+ buffer_json_member_add_string(wb, "default_sort_column", "Node");
+ buffer_json_member_add_object(wb, "charts");
+ {
+ // Data Collection Age chart
+ buffer_json_member_add_object(wb, "InAge");
+ {
+ buffer_json_member_add_string(wb, "name", "Data Collection Age");
+ buffer_json_member_add_string(wb, "type", "stacked-bar");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "InAge");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+
+ // Streaming Age chart
+ buffer_json_member_add_object(wb, "OutAge");
+ {
+ buffer_json_member_add_string(wb, "name", "Streaming Age");
+ buffer_json_member_add_string(wb, "type", "stacked-bar");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "OutAge");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+
+ // DB Duration
+ buffer_json_member_add_object(wb, "dbDuration");
+ {
+ buffer_json_member_add_string(wb, "name", "Retention Duration");
+ buffer_json_member_add_string(wb, "type", "stacked-bar");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "dbDuration");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+ }
+ buffer_json_object_close(wb); // charts
+
+ buffer_json_member_add_array(wb, "default_charts");
+ {
+ buffer_json_add_array_item_array(wb);
+ buffer_json_add_array_item_string(wb, "InAge");
+ buffer_json_add_array_item_string(wb, "Node");
+ buffer_json_array_close(wb);
+
+ buffer_json_add_array_item_array(wb);
+ buffer_json_add_array_item_string(wb, "OutAge");
+ buffer_json_add_array_item_string(wb, "Node");
+ buffer_json_array_close(wb);
+ }
+ buffer_json_array_close(wb);
+
+ buffer_json_member_add_object(wb, "group_by");
+ {
+ buffer_json_member_add_object(wb, "Node");
+ {
+ buffer_json_member_add_string(wb, "name", "Node");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "Node");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+
+ buffer_json_member_add_object(wb, "InStatus");
+ {
+ buffer_json_member_add_string(wb, "name", "Nodes by Collection Status");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "InStatus");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+
+ buffer_json_member_add_object(wb, "OutStatus");
+ {
+ buffer_json_member_add_string(wb, "name", "Nodes by Streaming Status");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "OutStatus");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+
+ buffer_json_member_add_object(wb, "MlStatus");
+ {
+ buffer_json_member_add_string(wb, "name", "Nodes by ML Status");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "MlStatus");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+
+ buffer_json_member_add_object(wb, "InRemoteIP");
+ {
+ buffer_json_member_add_string(wb, "name", "Nodes by Inbound IP");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "InRemoteIP");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+
+ buffer_json_member_add_object(wb, "OutRemoteIP");
+ {
+ buffer_json_member_add_string(wb, "name", "Nodes by Outbound IP");
+ buffer_json_member_add_array(wb, "columns");
+ {
+ buffer_json_add_array_item_string(wb, "OutRemoteIP");
+ }
+ buffer_json_array_close(wb);
+ }
+ buffer_json_object_close(wb);
+ }
+ buffer_json_object_close(wb); // group_by
+
+ buffer_json_member_add_time_t(wb, "expires", now_realtime_sec() + 1);
+ buffer_json_finalize(wb);
+
+ return HTTP_RESP_OK;
+}
diff --git a/src/web/api/functions/function-streaming.h b/src/web/api/functions/function-streaming.h
new file mode 100644
index 000000000..06da6af9f
--- /dev/null
+++ b/src/web/api/functions/function-streaming.h
@@ -0,0 +1,12 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_FUNCTION_STREAMING_H
+#define NETDATA_FUNCTION_STREAMING_H
+
+#include "daemon/common.h"
+
+#define RRDFUNCTIONS_STREAMING_HELP "Streaming status for parents and children."
+
+int function_streaming(BUFFER *wb, const char *function, BUFFER *payload, const char *source);
+
+#endif //NETDATA_FUNCTION_STREAMING_H
diff --git a/src/web/api/functions/functions.c b/src/web/api/functions/functions.c
new file mode 100644
index 000000000..c00e04ca0
--- /dev/null
+++ b/src/web/api/functions/functions.c
@@ -0,0 +1,43 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#include "functions.h"
+
+void global_functions_add(void) {
+ // we register this only on localhost
+ // for the other nodes, the origin server should register it
+ rrd_function_add_inline(
+ localhost,
+ NULL,
+ "streaming",
+ 10,
+ RRDFUNCTIONS_PRIORITY_DEFAULT + 1,
+ RRDFUNCTIONS_VERSION_DEFAULT,
+ RRDFUNCTIONS_STREAMING_HELP,
+ "top",
+ HTTP_ACCESS_SIGNED_ID | HTTP_ACCESS_SAME_SPACE | HTTP_ACCESS_SENSITIVE_DATA,
+ function_streaming);
+
+ rrd_function_add_inline(
+ localhost,
+ NULL,
+ "netdata-api-calls",
+ 10,
+ RRDFUNCTIONS_PRIORITY_DEFAULT + 2,
+ RRDFUNCTIONS_VERSION_DEFAULT,
+ RRDFUNCTIONS_PROGRESS_HELP,
+ "top",
+ HTTP_ACCESS_SIGNED_ID | HTTP_ACCESS_SAME_SPACE | HTTP_ACCESS_SENSITIVE_DATA,
+ function_progress);
+
+ rrd_function_add_inline(
+ localhost,
+ NULL,
+ RRDFUNCTIONS_BEARER_GET_TOKEN,
+ 10,
+ RRDFUNCTIONS_PRIORITY_DEFAULT + 3,
+ RRDFUNCTIONS_VERSION_DEFAULT,
+ RRDFUNCTIONS_BEARER_GET_TOKEN_HELP,
+ RRDFUNCTIONS_TAG_HIDDEN,
+ HTTP_ACCESS_SIGNED_ID | HTTP_ACCESS_SAME_SPACE | HTTP_ACCESS_SENSITIVE_DATA,
+ function_bearer_get_token);
+}
diff --git a/src/web/api/functions/functions.h b/src/web/api/functions/functions.h
new file mode 100644
index 000000000..28c483541
--- /dev/null
+++ b/src/web/api/functions/functions.h
@@ -0,0 +1,14 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_FUNCTIONS_H
+#define NETDATA_FUNCTIONS_H
+
+#include "daemon/common.h"
+
+#include "function-streaming.h"
+#include "function-progress.h"
+#include "function-bearer_get_token.h"
+
+void global_functions_add(void);
+
+#endif //NETDATA_FUNCTIONS_H
generated by cgit v1.2.3 (git 2.39.1) at 2025-02-15 18:08:18 +0000