Reorganize files

Author: MathieuCesbron

pkg/controller/container.go

@@ -6,37 +6,15 @@ import (
 	"math"
 	"net/http"
 	"os/exec"
-	"slices"
 	"strconv"
 	"strings"
-	"sync"
 	"time"
 
 	"github.com/rs/zerolog/log"
 	"github.com/unagex/kondense/pkg/utils"
 	corev1 "k8s.io/api/core/v1"
 )
 
-func (r *Reconciler) ReconcileContainer(pod *corev1.Pod, container corev1.Container, wg *sync.WaitGroup) {
-	defer wg.Done()
-
-	exclude := utils.ContainersToExclude()
-	if slices.Contains(exclude, container.Name) {
-		return
-	}
-
-	err := r.UpdateStats(pod, container)
-	if err != nil {
-		log.Error().Err(err)
-		return
-	}
-
-	err = r.KondenseContainer(container)
-	if err != nil {
-		log.Error().Err(err)
-	}
-}
-
 func (r *Reconciler) UpdateStats(pod *corev1.Pod, container corev1.Container) error {
 	var err error
 	var output []byte

pkg/controller/controller.go renamed to pkg/controller/reconcile.go

@@ -3,10 +3,12 @@ package controller
 import (
 	"context"
 	"net/http"
+	"slices"
 	"sync"
 	"time"
 
 	"github.com/rs/zerolog/log"
+	"github.com/unagex/kondense/pkg/utils"
 	corev1 "k8s.io/api/core/v1"
 	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes"
@@ -59,3 +61,23 @@ func (r *Reconciler) Reconcile() {
 		loopTime = time.Since(start)
 	}
 }
+
+func (r *Reconciler) ReconcileContainer(pod *corev1.Pod, container corev1.Container, wg *sync.WaitGroup) {
+	defer wg.Done()
+
+	exclude := utils.ContainersToExclude()
+	if slices.Contains(exclude, container.Name) {
+		return
+	}
+
+	err := r.UpdateStats(pod, container)
+	if err != nil {
+		log.Error().Err(err)
+		return
+	}
+
+	err = r.KondenseContainer(container)
+	if err != nil {
+		log.Error().Err(err)
+	}
+}