From 5f70feab59e1ac3d660dc80a6e34e27e48bebc5d Mon Sep 17 00:00:00 2001 From: pb Date: Thu, 17 Apr 2025 16:53:36 +0200 Subject: [PATCH] restructured the different package, cleaned some non used code, added comments, still have to reorganize packages to optimize packages --- {models => logger}/local_argo_logs.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) rename {models => logger}/local_argo_logs.go (96%) diff --git a/models/local_argo_logs.go b/logger/local_argo_logs.go similarity index 96% rename from models/local_argo_logs.go rename to logger/local_argo_logs.go index 234becb..95dcdfb 100644 --- a/models/local_argo_logs.go +++ b/logger/local_argo_logs.go @@ -1,4 +1,4 @@ -package models +package logger import ( "bufio" @@ -6,6 +6,7 @@ import ( "fmt" "io" "oc-monitord/conf" + "strings" "sync" @@ -106,7 +107,7 @@ func LogLocalWorkflow(wfName string, pipe io.ReadCloser, wg *sync.WaitGroup) { } // Debug, no logs sent -func LogPods(wfName string, pipe io.ReadCloser, steps []string, wg *sync.WaitGroup) { +func LogLocalPod(wfName string, pipe io.ReadCloser, steps []string, wg *sync.WaitGroup) { scanner := bufio.NewScanner(pipe) for scanner.Scan() { var podLogger zerolog.Logger @@ -118,6 +119,7 @@ func LogPods(wfName string, pipe io.ReadCloser, steps []string, wg *sync.WaitGro podLogger = wfLogger.With().Str("step_name", getStepName(podName, steps)).Logger() log := strings.Split(line,podName+":")[1] podLog := NewArgoPodLog(wfName,podName,log) + jsonifiedLog, err := json.Marshal(podLog) if err != nil { podLogger.Fatal().Msg(err.Error())