push k8s logs to LOG SERVICE IP

pull/531/head
Frostebite 2023-07-17 20:37:57 +01:00
parent 8cafc65464
commit 7385dfecf2
3 changed files with 11 additions and 1 deletions

6
dist/index.js generated vendored
View File

@ -3636,8 +3636,12 @@ var __importStar = (this && this.__importStar) || function (mod) {
__setModuleDefault(result, mod);
return result;
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", ({ value: true }));
const k8s = __importStar(__nccwpck_require__(89679));
const cloud_runner_logger_1 = __importDefault(__nccwpck_require__(42864));
class KubernetesLogService {
static async cleanupLogDeployment(namespace, kubeClientApps, kubeClient) {
await kubeClient.deleteNamespacedService('http-fileserver', namespace);
@ -3725,6 +3729,8 @@ class KubernetesLogService {
await new Promise((resolve) => setTimeout(resolve, 10000));
// get ip address of service
const service = await kubeClientCore.readNamespacedService('http-fileserver', namespace);
// log service json
cloud_runner_logger_1.default.log(`Service: ${JSON.stringify(service.body)}`);
const ip = service.body.status?.loadBalancer?.ingress?.[0]?.ip;
if (ip && ip.length > 0) {
return ip;

2
dist/index.js.map generated vendored

File diff suppressed because one or more lines are too long

View File

@ -1,5 +1,6 @@
import { CoreV1Api } from '@kubernetes/client-node';
import * as k8s from '@kubernetes/client-node';
import CloudRunnerLogger from '../../services/core/cloud-runner-logger';
class KubernetesLogService {
static async cleanupLogDeployment(namespace: string, kubeClientApps: k8s.AppsV1Api, kubeClient: CoreV1Api) {
await kubeClient.deleteNamespacedService('http-fileserver', namespace);
@ -93,6 +94,9 @@ status: {}
// get ip address of service
const service = await kubeClientCore.readNamespacedService('http-fileserver', namespace);
// log service json
CloudRunnerLogger.log(`Service: ${JSON.stringify(service.body)}`);
const ip = service.body.status?.loadBalancer?.ingress?.[0]?.ip;
if (ip && ip.length > 0) {
return ip;