动手写一个Kubernetes Controller，让Kubernetes如你所愿！

后端

2023-08-01 17:51:05

潜入 Kubernetes 控制器的奇妙世界：监听资源变化，掌控集群

概述

准备好驾驭 Kubernetes 的波涛了吗？让我们一起探索控制器的神奇世界，揭开 Kubernetes 自动化和控制的秘密。

Kubernetes 控制器：资源变化的守护者

控制器是 Kubernetes 的核心，负责监听集群资源的变化并执行相应的操作。它们就像机器人的哨兵，不断监视系统，确保一切按计划进行。

创建一个简单的控制器：监听 Pod 事件

让我们创建一个简单的控制器，它在 Pod 创建、更新或删除时打印一条消息。

步骤：

配置客户端： 连接到 Kubernetes 集群。
创建 Informer： 建立一个控制器，监听 Pod 资源的变化。
处理事件： 定义当 Pod 被创建、更新或删除时采取的具体操作。
启动 Informer： 开始监听资源变化。

代码示例：

import (
    "context"
    "fmt"
    "time"

    v1 "k8s.io/api/core/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/util/runtime"
    "k8s.io/client-go/informers"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/cache"
    "k8s.io/client-go/tools/clientcmd"
)

// 创建控制器
func main() {
    config, err := clientcmd.BuildConfigFromFlags("", "~/.kube/config")
    if err != nil {
        runtime.HandleError(fmt.Errorf("error building kubeconfig: %s", err.Error()))
    }

    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        runtime.HandleError(fmt.Errorf("error building kubernetes clientset: %s", err.Error()))
    }

    informerFactory := informers.NewSharedInformerFactory(clientset, time.Minute*30)

    podInformer := informerFactory.Core().V1().Pods()

    podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
        AddFunc: func(obj interface{}) {
            pod := obj.(*v1.Pod)
            fmt.Printf("Pod %s created in namespace %s\n", pod.Name, pod.Namespace)
        },
        UpdateFunc: func(oldObj, newObj interface{}) {
            oldPod := oldObj.(*v1.Pod)
            newPod := newObj.(*v1.Pod)
            fmt.Printf("Pod %s updated in namespace %s\n", oldPod.Name, oldPod.Namespace)
        },
        DeleteFunc: func(obj interface{}) {
            pod := obj.(*v1.Pod)
            fmt.Printf("Pod %s deleted in namespace %s\n", pod.Name, pod.Namespace)
        },
    })

    informerFactory.Start(context.Background().Done())

    <-context.Background().Done()
}