client test

client.go

package main

import (
	"context"
	"fmt"
	"os"
	"time"

	"k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/tools/clientcmd"
	"sigs.k8s.io/controller-runtime/pkg/client"
)

func main() {
	// use the current context in kubeconfig
	config, err := clientcmd.BuildConfigFromFlags("", os.Getenv("KUBECONFIG"))
	if err != nil {
		panic(err.Error())
	}

	c, err := client.New(config, client.Options{})
	if err != nil {
		panic(err)
	}

	ctx := context.Background()
	pod := v1.Pod{
		ObjectMeta: metav1.ObjectMeta{
			Name:                       "my-pod",
			Namespace:                  "default",
		},
	}
	t := time.Now()
	fmt.Println("Deleting...", t.String())
	if err := c.Delete(ctx, &pod, client.PropagationPolicy(metav1.DeletePropagationForeground)); err != nil {
		panic(err)
	}
	fmt.Println("Done deleting", time.Now().Sub(t))
	key := client.ObjectKey{
		Name: "my-pod",
		Namespace: "default",
	}
	p := &v1.Pod{}
	if err := c.Get(ctx, key, p); err != nil {
		panic(err)
	}
	fmt.Println("did not wait!")
	fmt.Println(p)
}