main.go

package main

import (
	"fmt"
	"io"
	"log"
	"math/rand"
	"net/http"
	"os"
)

const (
	killOptions = 3
	attempts    = 10
)

func handleKill(w http.ResponseWriter, r *http.Request) {
	_, err := io.Copy(os.Stdout, r.Body)
	if err != nil {
		log.Println("Failed to parse the request")
		log.Println(err)
		return
	}

	c, err := inClusterLogin()
	if err != nil {
		log.Println("Failed to login in cluster")
		log.Println(err)
		return
	}

	log.Println("going to kill something")
	for i := 0; i < attempts; i++ {
		message := ""
		switch rand.Intn(killOptions) {
		case 0:
			message, err = killRandomPod(c)
		case 1:
			message, err = killRandomDeployment(c)
		case 2:
			message, err = killRandomStatefulSet(c)
		default:
			message, err = killRandomPod(c)
		}
		log.Println(fmt.Sprintf("err: %v, message: %s", err, message))
		if err == nil {
			fmt.Fprintf(w, "{\"message\": \"%s\"}", message)
			break
		}
		log.Println(fmt.Sprintf("Trying again, attempt #%d", i+2))
	}

}

func main() {
	log.Println("server started")
	http.HandleFunc("/kill", handleKill)
	log.Fatal(http.ListenAndServe(":8080", nil))
}