4f19cf19d9
Co-authored-by: dunemask <dunemask@gmail.com> Co-authored-by: Dunemask <dunemask@gmail.com> Reviewed-on: https://gitea.dunemask.dev/elysium/minecluster/pulls/4
29 lines
1.1 KiB
JavaScript
29 lines
1.1 KiB
JavaScript
import { Router } from "express";
|
|
import k8s from "@kubernetes/client-node";
|
|
import { WARN } from "../util/logging.js";
|
|
const router = Router();
|
|
const kc = new k8s.KubeConfig();
|
|
kc.loadFromDefault();
|
|
const k8sApi = kc.makeApiClient(k8s.CoreV1Api);
|
|
// Get Routes
|
|
router.get("/available", (req, res) => {
|
|
return res.json({ cpu: 8000, memory: 16000 });
|
|
// TODO Workaround to detect available
|
|
k8sApi.listNode().then((nodeRes) => {
|
|
const nodeAllocatable = nodeRes.body.items.map((i) => i.status.allocatable);
|
|
const nodeResources = nodeAllocatable.map(({ cpu, memory }) => ({
|
|
cpu,
|
|
memory,
|
|
}));
|
|
const { cpu: clusterCpu, memory: clusterMemory } = nodeResources[0];
|
|
const isIdentical = ({ cpu, memory }) =>
|
|
clusterMemory === memory && clusterCpu === cpu;
|
|
if (!nodeResources.every(isIdentical))
|
|
WARN("ROUTES", "Warning, node resources were non-consistent");
|
|
const availableCpu = parseInt(clusterCpu) * 1000;
|
|
const availableMemory = parseInt(clusterMemory) / 1024;
|
|
res.json({ cpu: availableCpu, memory: availableMemory });
|
|
});
|
|
});
|
|
|
|
export default router;
|