直接使用Client

  1. package main
  3. import (
  4.     "context"
  5.     "fmt"
  6.     v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  7.     "k8s.io/client-go/kubernetes"
  8.     "k8s.io/client-go/tools/clientcmd"
  9.     "k8s.io/client-go/util/homedir"
  10.     "log"
  11.     "path/filepath"
  12. )
  14. func main() {
  15.     home := homedir.HomeDir()
  16.     kubeconfig := filepath.Join(home, ".kube", "config")
  17.     config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
  18.     if err != nil {
  19.         panic(err)
  20.     }
  21.     // 初始化 client
  22.     clientset, err := kubernetes.NewForConfig(config)
  23.     if err != nil {
  24.         log.Panic(err.Error())
  25.     }
  27.     stopCh := make(chan struct{})
  28.     defer close(stopCh)
  30.     list, err := clientset.AppsV1().Deployments("default").List(context.TODO(), v1.ListOptions{})
  31.     if err == nil {
  32.         for _, k := range list.Items {
  33.             fmt.Println("deploy:",k.Name)
  34.         }
  35.     }
  36. }

这样查询数据会给APIServer带来负担。大多数情况下我们应该使用Informer机制。

基本原理如下图：
image.png
大致思路是给APIServer套了层缓存，在一开始获取到全量数据，然后基于etcd的watch机制，自动通知client-go的更新，client-go也会搞个本地缓存，所有更新也会作用于此缓存。后续对于资源的list操作将会走缓存。

informer 可以配置回调


import (
    "k8s.io/client-go/informers"
)

func main(){
    factory := informers.NewSharedInformerFactory(clientset, 60 * time.Second)
    podInformer := factory.Core().V1().Pods()

    informer := podInformer.Informer()
    informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
        AddFunc:    onAdd,
        UpdateFunc: onUpdate,
        DeleteFunc: onDelete,
    })

}

func onAdd(obj interface{}) 
    klog.Infof("add a pod: %+v", pod.Name)
}

// onUpdate // 此处省略 workqueue 的使用
func onUpdate(oldObj interface{}, newObj interface{}) {
    klog.Infof("update a pod")
}

func onDelete(obj interface{}) {
    klog.Infof("delete a pod: %+v\n", pod.Name)
}

pod发生变更时我们将会收到回调。

在CRD开发中，这个机制是非常必要的，我们需要把pod的当前状态和目标状态做对比，并尝试将当前状态修正为目标状态。