add

practise/k8s-practise/annotation.go

@@ -3,7 +3,6 @@ package main
 import (
 	"context"
 	"fmt"
-	"strings"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes"
@@ -21,28 +20,12 @@ func main() {
 		panic(err)
 	}
 
-	name := "nginx"
-	namespace := "default"
-	deployment, err := clientSet.AppsV1().Deployments(namespace).Get(context.TODO(), name, metav1.GetOptions{})
+	obj, err := clientSet.CoreV1().Nodes().Get(context.TODO(), "kirin", metav1.GetOptions{})
 	if err != nil {
 		panic(err)
 	}
 
-	fieldSelector := []string{
-		"involvedObject.uid=" + string(deployment.UID),
-		"involvedObject.name=" + deployment.Name,
-		"involvedObject.namespace=" + deployment.Namespace,
-		"involvedObject.kind=Deployment",
-	}
-
-	events, err := clientSet.CoreV1().Events(namespace).List(context.TODO(), metav1.ListOptions{
-		FieldSelector: strings.Join(fieldSelector, ","),
-		Limit:         500,
-	})
-	if err != nil {
-		panic(err)
-	}
-
-	fmt.Println("events.Items", events.Items)
-	fmt.Println("events.Items", len(events.Items))
+	obj.Annotations["testkey"] = "testvalue"
+	_, _ = clientSet.CoreV1().Nodes().Update(context.TODO(), obj, metav1.UpdateOptions{})
+	fmt.Println(obj.Annotations)
 }