Mon Jan 12 22:04:59 CST 2026

Author: Zeusro

cmd/killer/kill.go

@@ -6,6 +6,7 @@ import (
 	"os"
 	"strings"
 
+	"github.com/p-program/kube-killer/config"
 	"github.com/p-program/kube-killer/core"
 	"github.com/rs/zerolog/log"
 	"github.com/spf13/cobra"
@@ -333,6 +334,15 @@ func SelectKiller(args []string) error {
 	case "me":
 		log.Warn().Msg("!!!WARNING!!!: PLEASE DO NOT USE. It's an unpredictable command.")
 		return nil
+	case "zeusro":
+		log.Warn().Msg("!!!WARNING!!!: ZEUSRO mode - 50% chance nothing happens, 50% chance deletes 50% of pods randomly!")
+		projectConfig := config.NewProjectConfig()
+		targetNamespace := namespace
+		if allNamespaces {
+			targetNamespace = ""
+		}
+		z := NewZeusro(projectConfig, targetNamespace, dryRun)
+		return z.Run()
 	case "n", "no", "node":
 		if len(args) < 2 {
 			log.Error().Msg("Node name is required")

cmd/killer/zeusro.go

@@ -6,52 +6,85 @@ import (
 	"time"
 
 	"github.com/p-program/kube-killer/config"
+	"github.com/rs/zerolog/log"
 )
 
-// Coin live or dead ?
+// Coin returns true with 50% probability
 func (z *Zeusro) Coin() bool {
-	//prevent same result
 	// Use rand.New() instead of deprecated rand.Seed() (Go 1.20+)
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	v := r.Intn(2)
 	return v == 1
 }
 
-// Zeusro Kuiper
+// Zeusro Kuiper - The unpredictable killer
 type Zeusro struct {
-	dryRun bool
-	config *config.ProjectConfig
+	dryRun    bool
+	namespace string
+	config    *config.ProjectConfig
 }
 
-func NewZeusro(config *config.ProjectConfig, dryRun bool) *Zeusro {
+func NewZeusro(config *config.ProjectConfig, namespace string, dryRun bool) *Zeusro {
 	z := Zeusro{
-		dryRun: dryRun,
-		config: config,
+		dryRun:    dryRun,
+		namespace: namespace,
+		config:    config,
 	}
 	return &z
 }
 
-func (z *Zeusro) Run() {
+// DryRun sets the dryRun flag
+func (z *Zeusro) DryRun() *Zeusro {
+	z.dryRun = true
+	return z
+}
+
+// Run executes the Zeusro command:
+// - 50% probability: Valar Dohaeris (nothing happens)
+// - 50% probability: Thanos mode (randomly delete 50% of pods)
+func (z *Zeusro) Run() error {
 	if z.dryRun {
-		fmt.Println("Leonard: I am sorry,I have to go.")
-		time.Sleep(time.Second)
-		fmt.Println("Leonard: I don't believe this.")
-		time.Sleep(time.Second * 2)
-		z.callSheldon()
-		return
+		log.Info().Msg("Zeusro: [DRY RUN] The coin will be flipped...")
+		coin := z.Coin()
+		if coin {
+			log.Info().Msg("Arya: Valar Dohaeris (Nothing happens)")
+		} else {
+			log.Warn().Msg("Thanos: I am inevitable. [DRY RUN] Would delete 50% of pods")
+		}
+		return nil
 	}
+
 	coin := z.Coin()
-	dead := !coin
-	if dead {
-		fmt.Println("Zeusro: Goodbye.")
-		z.callMyWife()
+	if coin {
+		// Valar Dohaeris - nothing happens
+		fmt.Println("Arya: Valar Dohaeris")
+		log.Info().Msg("Zeusro: All shall serve. Nothing happens.")
+		return nil
 	}
-	live := coin
-	if live {
-		z.callAryaStark()
+
+	// Thanos mode - delete 50% of pods
+	fmt.Println("Thanos: I am inevitable.")
+	time.Sleep(time.Second)
+	fmt.Println("Thanos: *snaps fingers*")
+	time.Sleep(time.Second)
+	fmt.Println("Thanos: The universe will be balanced.")
+	log.Warn().Msg("Zeusro: Thanos mode activated - deleting 50% of pods randomly")
+
+	// Create PodKiller and kill half of the pods
+	podKiller, err := NewPodKiller(z.namespace)
+	if err != nil {
+		return fmt.Errorf("failed to create PodKiller: %w", err)
 	}
+
+	// Set half mode to delete 50% of pods
+	podKiller.SetHalf()
+	// BlackHand is needed to trigger KillHalfPods
+	podKiller.BlackHand()
+
+	return podKiller.Kill()
 }
 
+// Legacy methods kept for backward compatibility
 func (z *Zeusro) callAryaStark() {
 	coin := z.Coin()
 	dead := !coin
@@ -67,25 +100,6 @@ func (z *Zeusro) callAryaStark() {
 	}
 }
 
-func (z *Zeusro) callSheldon() {
-	fmt.Print("Sheldon: A")
-	for i := 0; i < 2049; i++ {
-		time.Sleep(time.Millisecond * 2)
-		fmt.Print("a")
-	}
-	fmt.Println("!")
-	time.Sleep(time.Second * 3)
-	fmt.Println("Sheldon: BAZINGA PUNK!!! NOW WE'RE EVEN.")
-}
-
-func (z *Zeusro) callMyWife() {
-	fmt.Println("Penny: What? What happened?")
-	time.Sleep(time.Second)
-	fmt.Println("Penny: Oh my god, are you okay?")
-	time.Sleep(time.Second)
-	fmt.Println("Penny: I'm coming over right now!")
-}
-
 func (z *Zeusro) callThanos() {
 	fmt.Println("Thanos: I am inevitable.")
 	time.Sleep(time.Second * 2)

cmd/killer/zeusro_test.go

@@ -6,11 +6,12 @@ import (
 	"testing"
 
 	"github.com/p-program/kube-killer/config"
+	"github.com/stretchr/testify/assert"
 )
 
 func prepareZeusro() *Zeusro {
 	projectConfig := config.NewProjectConfig()
-	return NewZeusro(projectConfig, false)
+	return NewZeusro(projectConfig, "default", false)
 }
 
 func TestCoin(t *testing.T) {
@@ -44,11 +45,37 @@ func BenchmarkFmtCoin(b *testing.B) {
 }
 
 func TestFakeZeusro(t *testing.T) {
+	skipIfNoCluster(t)
 	z := prepareZeusro()
-	z.Run()
+	z.DryRun()
+	err := z.Run()
+	// Error may occur if no pods exist, which is fine
+	_ = err
 }
 
 func TestZeusro(t *testing.T) {
+	skipIfNoCluster(t)
 	z := prepareZeusro()
-	z.Run()
+	z.DryRun()
+	err := z.Run()
+	// Error may occur if no pods exist, which is fine
+	_ = err
+}
+
+func TestZeusroNewZeusro(t *testing.T) {
+	skipIfNoCluster(t)
+	projectConfig := config.NewProjectConfig()
+	z := NewZeusro(projectConfig, "default", true)
+	assert.NotNil(t, z)
+	assert.Equal(t, "default", z.namespace)
+	assert.True(t, z.dryRun)
+	assert.NotNil(t, z.config)
+}
+
+func TestZeusroDryRun(t *testing.T) {
+	skipIfNoCluster(t)
+	projectConfig := config.NewProjectConfig()
+	z := NewZeusro(projectConfig, "default", false)
+	z.DryRun()
+	assert.True(t, z.dryRun)
 }