Created a spinner for let users wait that the test is running

pkg/common/args.go

@@ -18,18 +18,21 @@ package common
 
 import (
 	"fmt"
-	"os"
-	"strings"
-
 	"github.com/spf13/viper"
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/rest"
-
+	"os"
 	"sigs.k8s.io/hydrophone/pkg/log"
+	"strings"
+	"time"
 )
 
 // PrintInfo prints the information about the cluster
 func PrintInfo(clientSet *kubernetes.Clientset, config *rest.Config) {
+	spinner := NewSpinner(os.Stdout)
+	spinner.Start()
+
+	time.Sleep(2 * time.Second)
 	serverVersion, err := clientSet.ServerVersion()
 	if err != nil {
 		log.Fatal("Error fetching server version: ", err)
@@ -41,7 +44,7 @@ func PrintInfo(clientSet *kubernetes.Clientset, config *rest.Config) {
 		viper.Set("busybox-image", busyboxImage)
 	}
 
-	log.Printf("API endpoint : %s", config.Host)
+	log.PrintfAPI("API endpoint : %s", config.Host)
 	log.Printf("Server version : %#v", *serverVersion)
 }
 

pkg/common/spinner.go

@@ -0,0 +1,84 @@
+package common
+
+import (
+	"fmt"
+	"io"
+	"runtime"
+	"sync"
+	"time"
+)
+
+var spinnerFrames = []string{
+	"⠈⠁", "⠈⠑", "⠈⠱", "⠈⡱", "⢀⡱", "⢄⡱", "⢄⡱", "⢆⡱", "⢎⡱", "⢎⡰",
+	"⢎⡠", "⢎⡀", "⢎⠁", "⠎⠁", "⠊⠁",
+}
+
+type Spinner struct {
+	stop        chan struct{}
+	stopped     chan struct{}
+	mu          *sync.Mutex
+	running     bool
+	writer      io.Writer
+	ticker      *time.Ticker
+	prefix      string
+	suffix      string
+	frameFormat string
+}
+
+func NewSpinner(w io.Writer) *Spinner {
+	frameFormat := "\x1b[?7l\r%s%s%s\x1b[?7h"
+	if runtime.GOOS == "windows" {
+		frameFormat = "\r%s%s%s"
+	}
+	return &Spinner{
+		stop:        make(chan struct{}, 1),
+		stopped:     make(chan struct{}),
+		mu:          &sync.Mutex{},
+		writer:      w,
+		frameFormat: frameFormat,
+	}
+}
+
+func (s *Spinner) Start() {
+	s.mu.Lock()
+	defer s.mu.Unlock()
+	if s.running {
+		return
+	}
+	s.running = true
+	s.ticker = time.NewTicker(time.Millisecond * 100)
+	go func() {
+		for {
+			for _, frame := range spinnerFrames {
+				select {
+				case <-s.stop:
+					func() {
+						s.mu.Lock()
+						defer s.mu.Unlock()
+						s.ticker.Stop()
+						s.running = false
+						s.stopped <- struct{}{}
+					}()
+					return
+				case <-s.ticker.C:
+					func() {
+						s.mu.Lock()
+						defer s.mu.Unlock()
+						fmt.Fprintf(s.writer, s.frameFormat, s.prefix, frame, s.suffix)
+					}()
+				}
+			}
+		}
+	}()
+}
+
+func (s *Spinner) Stop() {
+	s.mu.Lock()
+	if !s.running {
+		s.mu.Unlock()
+		return
+	}
+	s.stop <- struct{}{}
+	s.mu.Unlock()
+	<-s.stopped
+}

pkg/log/logs.go

@@ -55,6 +55,12 @@ func Printf(format string, v ...any) {
 	slog.Info(fmt.Sprintf(format, v...))
 }
 
+// Print logs for API
+func PrintfAPI(format string, v ...interface{}) {
+	fmt.Print("\n")
+	slog.Info(fmt.Sprintf(format, v...))
+}
+
 // Println logs an info message from the given arguments.
 func Println(v ...any) {
 	slog.Info(fmt.Sprint(v...))