从生成CRD到编写自定义控制器教程示例

下面是关于从生成CRD到编写自定义控制器的详细攻略：

1. 生成CRD

首先，我们需要通过Kubernetes API来自定义资源并创建CRD。CRD是Custom Resource Definition的缩写，表示自定义资源定义。在Kubernetes中，自定义资源是指我们可以定义和使用的API资源类型，比如我们可以定义一个名为MyResource的自定义资源。

生成CRD的步骤如下：

1. 创建CRD的YAML文件：

apiVersion: apiextensions.k8s.io/v1
kind: CustomResourceDefinition
metadata:
  name: myresources.example.com
spec:
  group: example.com
  names:
    kind: MyResource
    plural: myresources
    singular: myresource
  scope: Namespaced
  version: v1

1. 使用kubectl命令，将该CRD创建到Kubernetes集群中：

kubectl apply -f myresource-crd.yaml

这样，我们就成功创建了一个名为myresources.example.com的CRD，可以通过kubectl命令来管理它。

2. 编写自定义控制器

CRD生成之后，我们就可以开始编写自定义控制器来管理这些资源。自定义控制器是指一段运行在Kubernetes中的代码，它能够监听CRD的变化，并根据CRD中的定义来进行相应的操作。

编写自定义控制器的步骤如下：

1. 创建一个新的Go语言项目，并导入必要的模块：

import (
    "context"
    "fmt"

    "k8s.io/apimachinery/pkg/runtime"
    "k8s.io/apimachinery/pkg/types"
    "sigs.k8s.io/controller-runtime/pkg/client"
    "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
    "sigs.k8s.io/controller-runtime/pkg/handler"
    "sigs.k8s.io/controller-runtime/pkg/manager"
    "sigs.k8s.io/controller-runtime/pkg/reconcile"
    "sigs.k8s.io/controller-runtime/pkg/source"

    myres "myproject/api/v1"
)

1. 创建一个新的Controller结构体：

type MyResourceReconciler struct {
    client.Client
    Scheme *runtime.Scheme
}

1. 实现Reconcile函数，该函数会被Controller Runtime调用，用于处理与自定义资源的协调策略：

func (r *MyResourceReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error) {
    // 从请求中获取CRD的名称和命名空间
    myres := &myres.MyResource{}
    if err := r.Get(context.TODO(), request.NamespacedName, myres); err != nil {      
        // 如果获取CRD时发生错误，则忽略该请求
        return reconcile.Result{}, client.IgnoreNotFound(err)
    }

    // 在这里可以监听CRD的添加、删除和修改事件，根据CRD的属性来执行相应的操作

    return reconcile.Result{}, nil
}

1. 创建一个新的Add函数，用于将自定义控制器与CRD进行关联：

func Add(mgr manager.Manager) error {
    return ctrl.NewControllerManagedBy(mgr).
        For(&myres.MyResource{}).
        Complete(&MyResourceReconciler{
            Client: mgr.GetClient(),
            Scheme: mgr.GetScheme(),
        })
}

1. 在main函数中初始化自定义控制器并运行：

if err = controller.Add(mgr); err != nil {
    panic(err)
}

if err := mgr.Start(ctrl.SetupSignalHandler()); err != nil {
    panic(err)
}

这样，我们就成功编写了一个自定义控制器，并且将其与CRD关联起来，控制器能够监听CRD的变化并执行相应的操作。

示例说明

下面我们来介绍两个示例，分别介绍如何在自定义控制器中处理CRD的添加和删除事件。

示例1：处理CRD的添加事件

假设我们有一个自定义资源类型MyResource，其中包含一个namespace属性和一个message属性。当用户添加新的MyResource时，我们需要将其对应的message属性打印出来。

在MyResourceReconciler结构体中，实现Reconcile函数：

func (r *MyResourceReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error) {
    // 从请求中获取CRD的名称和命名空间
    myres := &myres.MyResource{}
    if err := r.Get(context.TODO(), request.NamespacedName, myres); err != nil {      
        // 如果获取CRD时发生错误，则忽略该请求
        return reconcile.Result{}, client.IgnoreNotFound(err)
    }

    // 如果CRD刚刚被创建，打印出其message属性
    if myres.CreationTimestamp.IsZero() {
        fmt.Printf("New MyResource added: %s\n", myres.Message)
    }

    return reconcile.Result{}, nil
}

这样，当我们向Kubernetes集群添加新的MyResource时，控制器就会自动打印出相应的消息。

示例2：处理CRD的删除事件

假设我们有一个自定义资源类型MyResource，其中包含一个namespace属性和一个message属性。当用户删除一个名为myresource1的MyResource时，我们需要将其对应的namespace属性打印出来。

在MyResourceReconciler结构体中，实现Reconcile函数：

func (r *MyResourceReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error) {
    // 从请求中获取CRD的名称和命名空间
    myres := &myres.MyResource{}
    if err := r.Get(context.TODO(), request.NamespacedName, myres); err != nil {      
        // 如果获取CRD时发生错误，则忽略该请求
        return reconcile.Result{}, client.IgnoreNotFound(err)
    }

    // 如果删除名为myresource1的CRD，则打印其命名空间属性
    if myres.Name == "myresource1" && !myres.DeletionTimestamp.IsZero() {
        fmt.Printf("MyResource %s deleted from namespace %s\n", myres.Name, myres.Namespace)
    }

    return reconcile.Result{}, nil
}

这样，当我们从Kubernetes集群删除名为myresource1的MyResource时，控制器就会自动打印出其对应的命名空间。