feat(cli): Add support for klog levels

experiments/swdt/cmd/kubernetes.go

@@ -17,10 +17,11 @@ limitations under the License.
 package cmd
 
 import (
-	"github.com/spf13/cobra"
 	"swdt/apis/config/v1alpha1"
 	"swdt/pkg/pwsh/executor"
 	"swdt/pkg/pwsh/kubernetes"
+
+	"github.com/spf13/cobra"
 )
 
 func init() {

experiments/swdt/cmd/root.go

@@ -17,14 +17,18 @@ limitations under the License.
 package cmd
 
 import (
+	"flag"
 	"os"
 	"swdt/apis/config/v1alpha1"
 	"swdt/pkg/config"
 
 	"github.com/spf13/cobra"
+	"k8s.io/klog"
 )
 
 func init() {
+	klog.InitFlags(nil)
+	rootCmd.PersistentFlags().AddGoFlagSet(flag.CommandLine)
 	rootCmd.PersistentFlags().StringP("config", "c", "samples/config.yaml", "Configuration file path.")
 }
 

experiments/swdt/pkg/config/node.go

@@ -25,6 +25,7 @@ import (
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/serializer"
 	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
+	"k8s.io/klog"
 )
 
 var (
@@ -38,6 +39,7 @@ func init() {
 
 // LoadConfigNodeFromFile LoadConfigFromFile returns the marshalled Node configuration object
 func LoadConfigNodeFromFile(file string) (*v1alpha1.Node, error) {
+	klog.V(1).Infof("Loading Node configuration from %s", file)
 	data, err := os.ReadFile(file)
 	if err != nil {
 		return nil, err

experiments/swdt/pkg/connections/ssh.go

@@ -21,15 +21,17 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	scp "github.com/bramvdbogaerde/go-scp"
-	"golang.org/x/crypto/ssh"
 	"io"
 	"os"
 	"path"
 	"regexp"
 	"swdt/apis/config/v1alpha1"
 	"sync"
 	"time"
+
+	scp "github.com/bramvdbogaerde/go-scp"
+	"golang.org/x/crypto/ssh"
+	"k8s.io/klog/v2"
 )
 
 const (
@@ -70,15 +72,19 @@ func (c *SSHConnection) fetchAuthMethod() (authMethod []ssh.AuthMethod, err erro
 	if password != "" {
 		authMethod = append(authMethod, ssh.Password(password))
 	}
+
 	return
 }
 
 // Connect creates the client connection object
 func (c *SSHConnection) Connect() error {
+	klog.V(1).Infof("SSH connecting to %s as %s", c.credentials.Hostname, c.credentials.Username)
+
 	authMethod, err := c.fetchAuthMethod()
 	if err != nil {
 		return err
 	}
+
 	client, err := ssh.Dial(TCP_TYPE, c.credentials.Hostname, &ssh.ClientConfig{
 		User:            c.credentials.Username,
 		Auth:            authMethod,
@@ -111,7 +117,10 @@ func (c *SSHConnection) Run(args string) (string, error) {
 	// Multiline PowerShell commands over SSH trip over newlines - only first one is executed
 	args = regexp.MustCompile(`\r?\n`).ReplaceAllLiteralString(args, ";")
 	cmd := fmt.Sprintf("powershell -nologo -noprofile -c { %s }", args)
-	// TODO(mloskot): Log executed commands in --verbose mode
+
+	// TODO(mloskot): Why this is not printed?
+	klog.V(1).Infof("SSH executing command: %s", cmd)
+
 	if err := session.Run(cmd); err != nil {
 		return "", err
 	}