K8s Informer 机制：掌控资源变化，运筹帷幄

2024-01-29 15:49:30

K8s Informer：掌控资源流转，洞察集群变幻

Kubernetes（简称 K8s）是一个用于自动化容器化应用程序部署、管理和扩展的开源容器编排系统。在 K8s 的复杂生态系统中，资源的动态变化是家常便饭，难以捉摸。为了应对这一挑战，Informer 机制应运而生，它如同茫茫海洋中的一盏明灯，指引我们掌控资源变幻，运筹帷幄。

Informer 机制：洞悉资源变幻

Informer 是一个 Go 语言客户端，能够持续监听 K8s 集群中资源的变动。它基于 watch 机制，当资源发生变化时，K8s API 服务器会将变更事件推送到客户端。Informer 负责接收这些事件，并将其转化为 Go 语言对象，供我们使用。

Informer 的工作流程：步步为营

Informer 的工作流程环环相扣，步步为营：

创建 watch 对象，用于监听特定类型的资源。
接收来自 API 服务器的变更事件。
处理事件，包括将数据转化为 Go 语言对象、更新内部缓存以及调用用户注册的回调函数。

通过这种机制，Informer 实现对资源变化的实时监控。

Informer 的优势：独树一帜

Informer 作为 K8s 资源监控的利器，拥有以下独树一帜的优势：

实时性： 基于 watch 机制，能够实时接收资源变化信息。
可靠性： 采用事件驱动的机制，确保资源变化信息不丢失。
易用性： 提供简洁易用的 API，方便开发者使用。
可扩展性： 可以监听任意类型的资源，满足不同的使用需求。

Informer 的使用场景：举重若轻

Informer 的使用场景广泛，可以应用于：

资源监控： 实时监控资源的变化，及时发现异常情况。
事件处理： 根据资源变化触发事件处理，实现自动化运维。
数据同步： 将 K8s 集群中的数据同步到其他系统，实现数据一致性。
控制器开发： 为控制器提供资源变化信息，实现自动化的资源管理。

代码示例：使用 Informer 监控 Pod

import (
	"context"
	"fmt"
	"time"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/informers"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/cache"
)

func main() {
	// 创建一个 Kubernetes 客户端集
	clientset, err := kubernetes.NewForConfig(restConfig)
	if err != nil {
		panic(err)
	}

	// 创建一个 InformerFactory，用于创建各种 informers
	informerFactory := informers.NewSharedInformerFactory(clientset, time.Second*30)

	// 创建一个 Pod informer
	podInformer := informerFactory.Core().V1().Pods()

	// 添加一个回调函数，当 Pod 发生变化时触发
	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
		AddFunc: func(obj interface{}) {
			fmt.Println("Pod added: ", obj)
		},
		UpdateFunc: func(oldObj, newObj interface{}) {
			fmt.Println("Pod updated: ", oldObj, newObj)
		},
		DeleteFunc: func(obj interface{}) {
			fmt.Println("Pod deleted: ", obj)
		},
	})

	// 启动 informer
	informerFactory.Start(context.Background())
	informerFactory.WaitForCacheSync(context.Background())

	// 持续监听资源变化
	select {}
}