OpenSource/homepage
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(kubernetes): add a boolean to disable traefik

Browse Source
This commit is contained in:
dotdiego 2023-06-22 10:41:36 +00:00
parent 1d78881a5f
commit 7658dd9419
1 changed files with 35 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
src/utils/config/service-helpers.js
View File

@ -1,4 +1,4 @@
import { promises as fs } from "fs"; import { promises as fs, readFileSync } from "fs";
import path from "path"; import path from "path";
import yaml from "js-yaml"; import yaml from "js-yaml";
@ -143,22 +143,8 @@ export async function servicesFromKubernetes() {
checkAndCopyConfig("kubernetes.yaml"); checkAndCopyConfig("kubernetes.yaml");
try { async function servicesFromTraefik(crd) {
const kc = getKubeConfig(); const traefikIngressList = crd.listClusterCustomObject("traefik.io", "v1alpha1", "ingressroutes")
if (!kc) {
return [];
}
const networking = kc.makeApiClient(NetworkingV1Api);
const crd = kc.makeApiClient(CustomObjectsApi);
const ingressList = await networking.listIngressForAllNamespaces(null, null, null, null)
.then((response) => response.body)
.catch((error) => {
logger.error("Error getting ingresses: %d %s %s", error.statusCode, error.body, error.response);
return null;
});
const traefikIngressList = await crd.listClusterCustomObject("traefik.io", "v1alpha1", "ingressroutes")
.then((response) => response.body) .then((response) => response.body)
.catch(async (error) => { .catch(async (error) => {
logger.error("Error getting traefik ingresses from traefik.io: %d %s %s", error.statusCode, error.body, error.response); logger.error("Error getting traefik ingresses from traefik.io: %d %s %s", error.statusCode, error.body, error.response);
@ -173,10 +159,37 @@ export async function servicesFromKubernetes() {
return fallbackIngressList; return fallbackIngressList;
}); });
if (traefikIngressList && traefikIngressList.items.length > 0) { if (traefikIngressList && traefikIngressList.items.length > 0) {
const traefikServices = traefikIngressList.items const traefikServices = traefikIngressList.items
.filter((ingress) => ingress.metadata.annotations && ingress.metadata.annotations[`${ANNOTATION_BASE}/href`]) .filter((ingress) => ingress.metadata.annotations && ingress.metadata.annotations[`${ANNOTATION_BASE}/href`])
return traefikServices;
}
return [];
}
try {
const configFile = path.join(process.cwd(), "config", "kubernetes.yaml");
const rawConfigData = readFileSync(configFile, "utf8");
const configData = substituteEnvironmentVars(rawConfigData);
const config = yaml.load(configData);
const kc = getKubeConfig();
if (!kc) {
return [];
}
const networking = kc.makeApiClient(NetworkingV1Api);
const crd = kc.makeApiClient(CustomObjectsApi);
const ingressList = await networking.listIngressForAllNamespaces(null, null, null, null)
.then((response) => response.body)
.catch((error) => {
logger.error("Error getting ingresses: %d %s %s", error.statusCode, error.body, error.response);
return null;
});
if (config.traefik) {
const traefikServices = await servicesFromTraefik(crd);
ingressList.items.push(...traefikServices); ingressList.items.push(...traefikServices);
} }
@ -249,6 +262,8 @@ export async function servicesFromKubernetes() {
logger.error(e); logger.error(e);
throw e; throw e;
} }
} }
export function cleanServiceGroups(groups) { export function cleanServiceGroups(groups) {