mirror/QuickStack
1
0
Fork 0
mirror of https://github.com/biersoeckli/QuickStack.git synced 2025-12-31 16:30:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Monitoring Nodes ==> add disk usage of nodes

Browse Source
This commit is contained in:
stefan.meyer
2024-12-05 14:26:21 +00:00
parent ec76c557e4
commit 689714175e
4 changed files with 81 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/app/monitoring/monitoring-nodes.tsx
View File

@@ -29,22 +29,24 @@ export default async function ResourcesNodes({ resourcesNodes }: { resourcesNode
<TableHeader>
<TableRow>
<TableHead>Name</TableHead>
<TableHead>CPU %</TableHead>
<TableHead>CPU</TableHead>
<TableHead>RAM %</TableHead>
<TableHead>RAM</TableHead>
<TableHead>Disk GB</TableHead>
<TableHead>CPU Absolut</TableHead>
<TableHead>CPU Capacity</TableHead>
<TableHead>RAM Absolut</TableHead>
<TableHead>RAM Capacity</TableHead>
<TableHead>Disk Absolut</TableHead>
<TableHead>Disk Capacity</TableHead>
</TableRow>
</TableHeader>
<TableBody>
{resourcesNodes.map((node) => (
<TableRow>
<TableCell className="font-medium">{node.name}</TableCell>
<TableCell className="font-medium">{node.cpuUsagePercent}</TableCell>
<TableCell className="font-medium">{node.cpuUsageAbsolut}</TableCell>
<TableCell className="font-medium">{node.ramUsagePercent}</TableCell>
<TableCell className="font-medium">{node.cpuUsageCapacity}</TableCell>
<TableCell className="font-medium">{node.ramUsageAbsolut}</TableCell>
<TableCell className="font-medium">{node.diskUsagePercent}</TableCell>
<TableCell className="font-medium">{node.ramUsageCapacity}</TableCell>
<TableCell className="font-medium">{node.diskUsageAbsolut}</TableCell>
<TableCell className="font-medium">{node.diskUsageCapacity}</TableCell>
</TableRow>
))}
</TableBody>

53
src/server/adapter/longhorn-api.adapter.ts
View File

@@ -1,3 +1,5 @@
import { any, number } from "zod";
class LonghornApiAdapter {
async getLonghornVolume(pvcName: String) { //Soll PVC Name und Used Size zurückgeben
@@ -31,6 +33,57 @@ class LonghornApiAdapter {
return -1; // Rückgabe mit Fehlerfall
}
}
async getNodeStorageInfo(nodeName: String) { //Soll PVC Name und Used Size zurückgeben
let longhornApiUrl = process.env.NODE_ENV === 'production' ? 'http://longhorn-frontend.longhorn-system.svc.cluster.local/v1/nodes' : 'http://localhost:4000/v1/nodes';
// Request senden
const response = await fetch(`${longhornApiUrl}/${nodeName}`, {
cache: 'no-cache',
method: 'GET', // Standardmäßig GET
headers: {
'Accept': 'application/json', // Optional, falls JSON erwartet wird
'Content-Type': 'application/json' // Optional, falls JSON zurückgegeben wird
}
});
// Überprüfen, ob die Anfrage erfolgreich war
if (!response.ok) {
throw new Error(`HTTP-Error: ${response.status}`);
}
// Antwort als JSON parsen
const data = await response.json() as {
disks: {
[key: string]: {
storageMaximum: number,
storageAvailable: number
}
}
};
if (!data.disks || typeof data.disks !== "object") {
throw new Error("Invalid node data: 'disks' property is missing or not an object.");
}
// Initialize totals
let totalStorageMaximum = 0;
let totalStorageAvailable = 0;
// Iterate over each disk and sum up the values
Object.values(data.disks).forEach(disk => {
totalStorageMaximum += disk.storageMaximum;
totalStorageAvailable += disk.storageAvailable;
});
return {
totalStorageMaximum,
totalStorageAvailable
};
}
}
const longhornApiAdapter = new LonghornApiAdapter();
export default longhornApiAdapter;

20
src/server/services/node.service.ts
View File

@@ -5,6 +5,7 @@ import { NodeInfoModel } from "@/shared/model/node-info.model";
import { NodeResourceModel } from "@/shared/model/node-resource.model";
import { Tags } from "../utils/cache-tag-generator.utils";
import { revalidateTag, unstable_cache } from "next/cache";
import longhornApiAdapter from "../adapter/longhorn-api.adapter";
class ClusterService {
@@ -68,20 +69,23 @@ class ClusterService {
return parseFloat(((current / capacity) * 100).toFixed(2));
}
function bytesToMb(bytes: number): number {
return parseFloat((bytes / (1024 * 1024)).toFixed(2));
}
return topNodes.map((node) => {
return await Promise.all (topNodes.map(async (node) => {
const diskInfo = await longhornApiAdapter.getNodeStorageInfo(node.Node.metadata?.name!);
return {
name: node.Node.metadata?.name!,
cpuUsagePercent: `${calculatePercent(Number(node.CPU?.RequestTotal!), Number(node.CPU?.Capacity!))}%`,
cpuUsageAbsolut: `${Number(node.CPU?.RequestTotal!).toFixed(2)} cores`,
ramUsagePercent: `${calculatePercent(bytesToMb(Number(node.Memory?.RequestTotal!)), bytesToMb(Number(node.Memory?.Capacity!)))}%`,
ramUsageAbsolut: `${bytesToMb(Number(node.Memory?.RequestTotal!))} MB`,
diskUsagePercent: "94%",
diskUsageAbsolut: "117GB%",
}});
cpuUsageAbsolut: Number(node.CPU?.RequestTotal!),
cpuUsageCapacity: Number(node.CPU?.Capacity!),
ramUsageAbsolut: Number(node.Memory?.RequestTotal!),
ramUsageCapacity: Number(node.Memory?.Capacity!),
diskUsageAbsolut: diskInfo.totalStorageMaximum - diskInfo.totalStorageAvailable,
diskUsageCapacity: diskInfo.totalStorageMaximum,
}}));
}
}

11
src/shared/model/node-resource.model.ts
View File

@@ -4,11 +4,12 @@ import { z } from "zod";
export const nodeResourceZodModel = z.object({
name: z.string(),
cpuUsagePercent: z.string(),
cpuUsageAbsolut: z.string(),
ramUsagePercent: z.string(),
ramUsageAbsolut: z.string(),
diskUsagePercent: z.string(),
cpuUsageAbsolut: z.number(),
cpuUsageCapacity: z.number(),
ramUsageAbsolut: z.number(),
ramUsageCapacity: z.number(),
diskUsageAbsolut: z.number(),
diskUsageCapacity: z.number(),
})
export type NodeResourceModel = z.infer<typeof nodeResourceZodModel>;