hashed logging k8s

pull/531/head
Frostebite 2023-09-20 21:11:36 +01:00
parent 368f63e404
commit 6bd6fddf40
3 changed files with 29 additions and 23 deletions

25
dist/index.js generated vendored
View File

@ -3957,17 +3957,20 @@ class KubernetesTaskRunner {
let logs; let logs;
const callback = (outputChunk) => { const callback = (outputChunk) => {
output += outputChunk; output += outputChunk;
// check if log start included in logs if so log a message // split output chunk and handle per line
if (outputChunk.includes(`Collected Logs`)) { for (const chunk of outputChunk.split(`\n`)) {
cloud_runner_logger_1.default.log(`Log Start found in logs`); // check if log start included in logs if so log a message
} if (chunk.includes(`Collected Logs`)) {
if (outputChunk.includes(`LOGHASH:`)) { cloud_runner_logger_1.default.log(`Log Start found in logs`);
remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(outputChunk); }
cloud_runner_logger_1.default.log(`Loghash found`); if (chunk.includes(`LOGHASH:`)) {
} remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(chunk);
if (outputChunk.includes(`LOGS:`)) { cloud_runner_logger_1.default.log(`Loghash found`);
const result = remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(outputChunk); }
cloud_runner_logger_1.default.log(`Logs found HandleLogChunkLineResult:${result}`); if (chunk.includes(`LOGS:`)) {
const result = remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(chunk);
cloud_runner_logger_1.default.log(`Logs found HandleLogChunkLineResult:${result}`);
}
} }
}; };
try { try {

2
dist/index.js.map generated vendored

File diff suppressed because one or more lines are too long

View File

@ -36,17 +36,20 @@ class KubernetesTaskRunner {
const callback = (outputChunk: string) => { const callback = (outputChunk: string) => {
output += outputChunk; output += outputChunk;
// check if log start included in logs if so log a message // split output chunk and handle per line
if (outputChunk.includes(`Collected Logs`)) { for (const chunk of outputChunk.split(`\n`)) {
CloudRunnerLogger.log(`Log Start found in logs`); // check if log start included in logs if so log a message
} if (chunk.includes(`Collected Logs`)) {
if (outputChunk.includes(`LOGHASH:`)) { CloudRunnerLogger.log(`Log Start found in logs`);
RemoteClientLogger.HandleLogChunkLine(outputChunk); }
CloudRunnerLogger.log(`Loghash found`); if (chunk.includes(`LOGHASH:`)) {
} RemoteClientLogger.HandleLogChunkLine(chunk);
if (outputChunk.includes(`LOGS:`)) { CloudRunnerLogger.log(`Loghash found`);
const result = RemoteClientLogger.HandleLogChunkLine(outputChunk); }
CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}`); if (chunk.includes(`LOGS:`)) {
const result = RemoteClientLogger.HandleLogChunkLine(chunk);
CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}`);
}
} }
}; };
try { try {