Mon Jan 12 06:53:29 CST 2026

Author: Zeusro

cmd/freeze.go

@@ -5,13 +5,8 @@ import (
 	"github.com/spf13/cobra"
 )
 
-func init() {
-
-}
-
 var (
 	namespace string
-	dryRun    bool
 )
 
 func NewFreezeCommand() *cobra.Command {
@@ -33,6 +28,5 @@ func NewFreezeCommand() *cobra.Command {
 			icebox.Freeze(args[0], args[1])
 		}}
 	c.PersistentFlags().StringVarP(&namespace, "namespace", "n", "default", "working namespace")
-	c.PersistentFlags().BoolVarP(&dryRun, "dryrun", "d", false, "dryRun")
 	return c
 }

cmd/killer/job_killer.go

@@ -87,20 +87,20 @@ func (k *JobKiller) KillHalfJobs() error {
 		log.Info().Msg("No jobs to kill")
 		return nil
 	}
-	
+
 	// Randomly shuffle the jobs list
 	jobList := jobs.Items
 	rand.Seed(time.Now().UnixNano())
 	rand.Shuffle(len(jobList), func(i, j int) {
 		jobList[i], jobList[j] = jobList[j], jobList[i]
 	})
-	
+
 	// Calculate how many jobs to kill (half, rounded down)
 	jobsToKill := len(jobList) / 2
 	if jobsToKill == 0 {
 		jobsToKill = 1 // At least kill one job if there's only one
 	}
-	
+
 	log.Info().Msgf("Killing %d out of %d jobs", jobsToKill, len(jobList))
 	for i := 0; i < jobsToKill; i++ {
 		job := jobList[i]
@@ -136,7 +136,7 @@ func (k *JobKiller) DeserveDead(resource interface{}) bool {
 		return true
 	}
 	job := resource.(batchv1.Job)
-	
+
 	// Check if job is completed based on conditions
 	for _, condition := range job.Status.Conditions {
 		if condition.Type == batchv1.JobComplete && condition.Status == "True" {
@@ -146,7 +146,7 @@ func (k *JobKiller) DeserveDead(resource interface{}) bool {
 			return true
 		}
 	}
-	
+
 	// If no conditions are set, check completion based on spec and status
 	// A job is considered complete if:
 	// 1. It has completions specified and succeeded count matches
@@ -161,12 +161,11 @@ func (k *JobKiller) DeserveDead(resource interface{}) bool {
 			return true
 		}
 	}
-	
+
 	// Check if job has failed (backoff limit exceeded)
 	if job.Spec.BackoffLimit != nil && job.Status.Failed > *job.Spec.BackoffLimit {
 		return true
 	}
-	
+
 	return false
 }
-

cmd/killer/pod_killer.go

@@ -143,14 +143,14 @@ func (k *PodKiller) KillHalfPods() error {
 		log.Info().Msg("No pods to kill")
 		return nil
 	}
-	
+
 	// Randomly shuffle the pods list
 	podList := pods.Items
 	rand.Seed(time.Now().UnixNano())
 	rand.Shuffle(len(podList), func(i, j int) {
 		podList[i], podList[j] = podList[j], podList[i]
 	})
-	
+
 	// Calculate how many pods to kill (half, rounded down)
 	podsToKill := len(podList) / 2
 	if podsToKill == 0 {

cmd/killer/pvc_killer.go

@@ -104,20 +104,20 @@ func (k *PVCKiller) KillHalfPVCs() error {
 		log.Info().Msg("No PVCs to kill")
 		return nil
 	}
-	
+
 	// Randomly shuffle the PVCs list
 	pvcList := list.Items
 	rand.Seed(time.Now().UnixNano())
 	rand.Shuffle(len(pvcList), func(i, j int) {
 		pvcList[i], pvcList[j] = pvcList[j], pvcList[i]
 	})
-	
+
 	// Calculate how many PVCs to kill (half, rounded down)
 	pvcsToKill := len(pvcList) / 2
 	if pvcsToKill == 0 {
 		pvcsToKill = 1 // At least kill one PVC if there's only one
 	}
-	
+
 	log.Info().Msgf("Killing %d out of %d PVCs", pvcsToKill, len(pvcList))
 	for i := 0; i < pvcsToKill; i++ {
 		pvc := pvcList[i]
@@ -136,7 +136,7 @@ func (k *PVCKiller) KillUnusedPVCs() error {
 	if err != nil {
 		return err
 	}
-	
+
 	// Get all Pods to check which PVCs are in use
 	podKiller, err := NewPodKiller(k.namespace)
 	if err != nil {
@@ -146,7 +146,7 @@ func (k *PVCKiller) KillUnusedPVCs() error {
 	if err != nil {
 		return err
 	}
-	
+
 	// Build map of used PVCs
 	usedPVCs := make(map[string]bool)
 	for _, pod := range pods {
@@ -156,7 +156,7 @@ func (k *PVCKiller) KillUnusedPVCs() error {
 			}
 		}
 	}
-	
+
 	// Delete unused PVCs
 	for _, pvc := range pvcList.Items {
 		// Skip bound PVCs that are in use

cmd/root.go

@@ -1,9 +1,6 @@
 package cmd
 
 import (
-	"fmt"
-	"os"
-
 	"github.com/p-program/kube-killer/cmd/killer"
 	"github.com/p-program/kube-killer/cmd/server"
 	"github.com/spf13/cobra"
@@ -12,8 +9,7 @@ import (
 
 var (
 	// Used for flags.
-	cfgFile     string
-	userLicense string
+	cfgFile string
 
 	rootCmd = &cobra.Command{
 		Use:   "kube-killer",
@@ -30,12 +26,6 @@ func Execute() error {
 func init() {
 	cobra.OnInitialize(initConfig)
 	rootCmd.PersistentFlags().StringVar(&cfgFile, "config", "", "config file (default is $HOME/.config.yaml)")
-	rootCmd.PersistentFlags().StringVarP(&userLicense, "license", "l", "", "name of license for the project")
-	rootCmd.PersistentFlags().Bool("viper", true, "use Viper for configuration")
-	viper.BindPFlag("author", rootCmd.PersistentFlags().Lookup("author"))
-	viper.BindPFlag("useViper", rootCmd.PersistentFlags().Lookup("viper"))
-	viper.SetDefault("author", "https://github.com/p-program")
-	viper.SetDefault("license", "Mulan PSL v2")
 	bindCommand()
 
 }
@@ -51,11 +41,6 @@ func bindCommand() {
 
 }
 
-func er(msg interface{}) {
-	fmt.Println("Error:", msg)
-	os.Exit(1)
-}
-
 func initConfig() {
 	if cfgFile != "" {
 		// Use config file from the flag.