master
c 106 lines 4.11 KB
Raw
1 // SPDX-License-Identifier: GPL-3.0-or-later
2
3 #include "rrdset2json.h"
4
5 static int process_label_callback(const char *name, const char *value, RRDLABEL_SRC ls __maybe_unused, void *data) {
6 BUFFER *wb = data;
7 buffer_json_member_add_string_or_empty(wb, name, value);
8 return 1;
9 }
10
11 void chart_labels2json(RRDSET *st, BUFFER *wb)
12 {
13 if(unlikely(!st->rrdlabels))
14 return;
15
16 rrdlabels_walkthrough_read(st->rrdlabels, process_label_callback, wb);
17 }
18
19 // generate JSON for the /api/v1/chart API call
20 void rrdset2json(RRDSET *st, BUFFER *wb, size_t *dimensions_count, size_t *memory_used)
21 {
22 time_t first_entry_t = rrdset_first_entry_s(st);
23 time_t last_entry_t = rrdset_last_entry_s(st);
24 char buf[RRD_ID_LENGTH_MAX + 16];
25
26 buffer_json_member_add_string(wb, "id", rrdset_id(st));
27 buffer_json_member_add_string(wb, "name", rrdset_name(st));
28 buffer_json_member_add_string(wb, "type", rrdset_parts_type(st));
29 buffer_json_member_add_string(wb, "family", rrdset_family(st));
30 buffer_json_member_add_string(wb, "context", rrdset_context(st));
31 snprintfz(buf, RRD_ID_LENGTH_MAX + 15, "%s (%s)", rrdset_title(st), rrdset_name(st));
32 buffer_json_member_add_string(wb, "title", buf);
33 buffer_json_member_add_int64(wb, "priority", st->priority);
34 buffer_json_member_add_string(wb, "plugin", rrdset_plugin_name(st));
35 buffer_json_member_add_string(wb, "module", rrdset_module_name(st));
36 buffer_json_member_add_string(wb, "units", rrdset_units(st));
37
38 snprintfz(buf, RRD_ID_LENGTH_MAX + 15, "/api/v1/data?chart=%s", rrdset_name(st));
39 buffer_json_member_add_string(wb, "data_url", buf);
40
41 buffer_json_member_add_string(wb, "chart_type", rrdset_type_name(st->chart_type));
42 buffer_json_member_add_int64(wb, "duration", (int64_t)(last_entry_t - first_entry_t + st->update_every));
43 buffer_json_member_add_int64(wb, "first_entry", (int64_t)first_entry_t);
44 buffer_json_member_add_int64(wb, "last_entry", (int64_t)last_entry_t);
45 buffer_json_member_add_int64(wb, "update_every", (int64_t)st->update_every);
46
47 unsigned long memory = sizeof(RRDSET);
48
49 size_t dimensions = 0;
50 buffer_json_member_add_object(wb, "dimensions");
51 {
52 RRDDIM *rd;
53 rrddim_foreach_read(rd, st)
54 {
55 if (rrddim_option_check(rd, RRDDIM_OPTION_HIDDEN) || rrddim_flag_check(rd, RRDDIM_FLAG_OBSOLETE))
56 continue;
57
58 memory += rrddim_size() + rd->db.memsize;
59
60 buffer_json_member_add_object(wb, rrddim_id(rd));
61 buffer_json_member_add_string(wb, "name", rrddim_name(rd));
62 buffer_json_object_close(wb);
63
64 dimensions++;
65 }
66 rrddim_foreach_done(rd);
67 }
68 buffer_json_object_close(wb);
69
70 if(dimensions_count) *dimensions_count += dimensions;
71 if(memory_used) *memory_used += memory;
72
73 buffer_json_member_add_object(wb, "chart_variables");
74 health_api_v1_chart_custom_variables2json(st, wb);
75 buffer_json_object_close(wb);
76
77 buffer_json_member_add_double(wb, "green", st->green);
78 buffer_json_member_add_double(wb, "red", st->red);
79
80 {
81 buffer_json_member_add_object(wb, "alarms");
82 RRDCALC *rc;
83 rw_spinlock_read_lock(&st->alerts.spinlock);
84 DOUBLE_LINKED_LIST_FOREACH_FORWARD(st->alerts.base, rc, prev, next)
85 {
86 {
87 buffer_json_member_add_object(wb, rrdcalc_name(rc));
88 buffer_json_member_add_string_or_empty(wb, "id", rrdcalc_name(rc));
89 buffer_json_member_add_string_or_empty(wb, "status", rrdcalc_status2string(rc->status));
90 buffer_json_member_add_string_or_empty(wb, "units", rrdcalc_units(rc));
91 buffer_json_member_add_int64(wb, "duration", (int64_t)rc->config.update_every);
92 buffer_json_object_close(wb);
93 }
94 }
95 rw_spinlock_read_unlock(&st->alerts.spinlock);
96 buffer_json_object_close(wb);
97 }
98
99 buffer_json_member_add_object(wb, "chart_labels");
100 chart_labels2json(st, wb);
101 buffer_json_object_close(wb);
102
103 buffer_json_member_add_object(wb, "functions");
104 chart_functions2json(st, wb);
105 buffer_json_object_close(wb);
106 }