K8s 不仅仅是容器编排#

大多数人只用 K8s 的内置资源：Pod, Deployment, Service。但 K8s 真正的威力在于它是一个 可扩展的分布式操作系统。它的 API Server 是通用的。

Operator 模式 = CRD (自定义资源) + Controller (控制器)。

场景：自动管理 Redis 集群#

假设你想部署一个 Redis 集群。用 Deployment？不行，Redis 有状态，主从切换逻辑复杂。用 StatefulSet？可以，但故障恢复还是需要人工干预。

这时候，你需要写一个 RedisOperator。

1. 定义 CRD#

1
apiVersion: db.example.com/v1
2
kind: RedisCluster
3
metadata:
4
  name: my-cache
5
spec:
6
  replicas: 3
7
  version: "6.2"
8
  storage: "10Gi"

2. 编写 Controller (Reconcile Loop)#

Controller 的核心逻辑是一个死循环（调和循环）： “观察现状 (Current State) -> 对比期望 (Desired State) -> 执行动作 (Action)“

1
func (r *RedisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
2
    // 1. 获取 CR 对象
3
    var redis RedisCluster
4
    if err := r.Get(ctx, req.NamespacedName, &redis); err != nil {
5
        return ctrl.Result{}, client.IgnoreNotFound(err)
6
    }
7

8
    // 2. 检查 Pod 是否存在
9
    var pods corev1.PodList
10
    // ... 列出 Pods ...
11

12
    // 3. 比较数量
13
    if len(pods.Items) < redis.Spec.Replicas {
14
        // 4. 创建新 Pod
15
        r.Create(ctx, newPod(&redis))
16
    }
17

18
    return ctrl.Result{}, nil
19
}