graphs: fix memory graphs

This commit is contained in:
Girish Ramakrishnan
2025-05-23 16:11:48 +02:00
parent a88d523559
commit 1289a6e14f
2 changed files with 69 additions and 25 deletions
+51 -15
View File
@@ -37,6 +37,12 @@ let metricStream = null;
const LIVE_REFRESH_INTERVAL_MSECS = 500;
const LIVE_REFRESH_HISTORY_MSECS = 5*60*1000; // last 5 mins
function pruneGraphData(dataset, options) {
while (dataset.data.length && (dataset.data[0].x < options.scales.x.min)) { // remove elements beyond our tme window
dataset.data.shift();
}
}
async function liveRefresh() {
metricStream = await systemModel.getMetricStream(LIVE_REFRESH_INTERVAL_MSECS);
@@ -44,22 +50,27 @@ async function liveRefresh() {
metricStream.onmessage = (message) => {
const data = JSON.parse(message.data);
if (data.cpu[0]) { // value can be null if no previous value
if (data.cpu[0]) { // since cpu% is relative, value can be null if no previous value
cpuGraph.data.datasets[0].data.push({
x: data.cpu[1] * 1000, // cpuGraph.options.scales.x.max can be used for window edge, if we don't trust server timestamps . but using server timestamps handles network lags better
y: data.cpu[0]
});
while (cpuGraph.data.datasets[0].data.length && (cpuGraph.data.datasets[0].data[0].x < cpuGraph.options.scales.x.min)) { // remove elements beyond our tme window
cpuGraph.data.datasets[0].data.shift();
}
pruneGraphData(cpuGraph.data.datasets[0], cpuGraph.options);
cpuGraph.update('none');
}
memoryGraph.data.labels.push(moment(data.memory[1]*1000).format('hh:mm'));
memoryGraph.data.datasets[0].data.push((data.memory[0] / 1024 / 1024 / 1024).toFixed(2));
memoryGraph.data.datasets[1].data.push((data.swap[0] / 1024 / 1024 / 1024).toFixed(2) + 2);
memoryGraph.data.datasets[0].data.push({
x: data.memory[1] * 1000,
y: (data.memory[0] / 1024 / 1024 / 1024).toFixed(2)
});
pruneGraphData(memoryGraph.data.datasets[0], memoryGraph.options);
memoryGraph.data.datasets[1].data.push({
x: data.swap[1] * 1000,
y: (data.swap[0] / 1024 / 1024 / 1024).toFixed(2)
});
pruneGraphData(memoryGraph.data.datasets[1], memoryGraph.options);
memoryGraph.update('none');
};
@@ -68,6 +79,10 @@ async function liveRefresh() {
cpuGraph.options.scales.x.min += LIVE_REFRESH_INTERVAL_MSECS;
cpuGraph.options.scales.x.max += LIVE_REFRESH_INTERVAL_MSECS;
cpuGraph.update('none');
memoryGraph.options.scales.x.min += LIVE_REFRESH_INTERVAL_MSECS;
memoryGraph.options.scales.x.max += LIVE_REFRESH_INTERVAL_MSECS;
memoryGraph.update('none');
}, LIVE_REFRESH_INTERVAL_MSECS);
}
@@ -86,7 +101,7 @@ async function getMetrics(hours) {
y: (v[0] / 1024 / 1024 / 1024).toFixed(2)
};
});
// assume that there is 1:1 timeline for swap and memory data
const swapData = result.swap.map(v => {
return {
x: v[1]*1000,
@@ -210,19 +225,30 @@ async function refresh() {
const memoryGraphOptions = {
maintainAspectRatio: false,
plugins: {
legend: false,
legend: {
display: false
},
tooltip: {
callbacks: {
title: (tooltipItem) => moment(tooltipItem[0].raw.x).format(periods.find((p) => p.id === period.value).tooltipFormat)
}
}
},
scales: {
x: {
// we used to use 'time' type but it relies on the data to generate ticks. we may not have data for our time periods
type: 'linear',
bounds: 'ticks', // otherwise data bound. https://www.chartjs.org/docs/latest/axes/cartesian/time.html#changing-the-scale-type-from-time-scale-to-logarithmic-linear-scale
min: now - period.value*60*60*1000,
min: now - (period.value === 0 ? LIVE_REFRESH_HISTORY_MSECS : period.value*60*60*1000),
max: now,
ticks: {
autoSkip: true, // skip tick labels as needed
autoSkipPadding: 20, // padding between ticks
maxRotation: 0, // don't rotate the labels
maxTicksLimit: 15, // max tick labels to show
count: 7, // tick labels to show. anything more than 7 will not work for "7 days"
callback: function (value) {
if (period.value === 0) return `${5-(value-this.min)/60000}min`;
return moment(value).format(periods.find((p) => p.id === period.value).format);
}
},
grid: {
drawOnChartArea: false,
@@ -250,8 +276,18 @@ async function refresh() {
}
};
if (memoryGraph) memoryGraph.destroy();
memoryGraph = new Chart(memoryGraphNode.value, { type: 'line', data: memoryGraphData, options: memoryGraphOptions });
if (period.value === 0) {
// for realtime graph, generate steps of 1min and appropriate tick text
memoryGraphOptions.scales.x.ticks.stepSize = 60*1000; // 1min
}
if (!memoryGraph) {
memoryGraph = new Chart(memoryGraphNode.value, { type: 'line', data: memoryGraphData, options: memoryGraphOptions });
} else {
memoryGraph.data = memoryGraphData;
memoryGraph.options = memoryGraphOptions;
memoryGraph.update('none');
}
if (metricStream) {
clearInterval(metricStream.intervalId);