Kubernetes Operator 新手开发一文入门

 1+-------------------+           +-----------------------+
 2|   API Server       |           |     Controller        |
 3|                   |           |                       |
 4|  (Add/Update/Delete)-----------> (Reconcile function)  |
 5|   (List/Watch)     |           |   Handles resource    |
 6+-------------------+           +-----------------------+
 7          ^                              ^
 8          |                              |
 9          |    +------------------+      |
10          +----+ SharedInformer    +------+
11               | (Cache + Event)   |
12               +------------------+

 1apiVersion: rbac.authorization.k8s.io/v1
 2kind: ClusterRole
 3metadata:
 4  name: operator-role
 5rules:
 6  - apiGroups: [""]
 7    resources: ["pods", "services"]
 8    verbs: ["get", "list", "watch", "create", "update", "patch", "delete"]
 9  - apiGroups: ["apps"]
10    resources: ["deployments"]
11    verbs: ["get", "list", "watch", "create", "update", "patch", "delete"]

 1apiVersion: rbac.authorization.k8s.io/v1
 2kind: ClusterRoleBinding
 3metadata:
 4  name: operator-role-binding
 5subjects:
 6  - kind: ServiceAccount
 7    name: operator-sa
 8    namespace: default
 9roleRef:
10  kind: ClusterRole
11  name: operator-role
12  apiGroup: rbac.authorization.k8s.io

1// +kubebuilder:rbac:groups=apps,resources=deployments,verbs=get;list;watch;create;update;patch;delete

1wget -c https://github.com/kubernetes-sigs/kubebuilder/releases/download/v4.2.0/kubebuilder_darwin_amd64
2mv kubebuilder_darwin_amd64 /usr/local/bin/kubebuilder
3chmod +x /usr/local/bin/kubebuilder
4
5kubebuilder version
6Version: main.version{KubeBuilderVersion:"4.2.0", KubernetesVendor:"1.31.0", GitCommit:"c7cde5172dc8271267dbf2899e65ef6f9d30f91e", BuildDate:"2024-08-17T09:41:45Z", GoOs:"darwin", GoArch:"amd64"}

 1kubebuilder init --domain siming.com --repo github.com/ZhangSIming-blyq/mysql-operator
 2INFO Writing kustomize manifests for you to edit...
 3INFO Writing scaffold for you to edit...
 4INFO Get controller runtime:
 5$ go get sigs.k8s.io/controller-runtime@v0.19.0
 6...
 7...
 8INFO Update dependencies:
 9$ go mod tidy
10...
11...
12Next: define a resource with:
13$ kubebuilder create api

1kubebuilder create api --group apps --version v1 --kind MySQL

 1├── Dockerfile                     # 用于构建 Operator 的容器镜像
 2├── Makefile                       # 定义了常用的构建、测试、部署命令，简化操作流程
 3├── PROJECT                        # Kubebuilder 项目元数据文件，记录项目配置和版本信息
 4├── README.md                      # 项目介绍文件，记录项目的目标、安装步骤、功能等信息
 5├── api
 6│   └── v1
 7│       ├── groupversion_info.go   # 定义了 API 版本信息和资源组信息
 8│       ├── mysql_types.go         # 自定义资源 (CRD) 的结构定义，包含 CRD 的字段和序列化逻辑
 9│       └── zz_generated.deepcopy.go  # 自动生成的代码，用于深度拷贝自定义资源对象
10├── bin
11│   ├── controller-gen             # Kubebuilder 用于生成控制器的工具，提供 CRD、RBAC 等生成功能的二进制文件
12│   └── controller-gen-v0.16.1     # 特定版本的 controller-gen 工具
13├── cmd
14│   └── main.go                    # Operator 入口点，初始化 Manager 并启动控制器
15├── config
16│   ├── crd
17│   │   ├── kustomization.yaml     # CRD 的 kustomize 配置，用于定制 CRD 的生成
18│   │   └── kustomizeconfig.yaml   # 自定义资源定义 (CRD) 的额外配置文件
19│   ├── default
20│   │   ├── kustomization.yaml     # 默认的 kustomize 配置文件，用于管理 Operator 的部署
21│   │   ├── manager_metrics_patch.yaml  # 配置 Manager 的指标导出补丁
22│   │   └── metrics_service.yaml   # 用于暴露 Operator 监控指标的服务配置
23│   ├── manager
24│   │   ├── kustomization.yaml     # 用于部署 Manager 的 kustomize 配置
25│   │   └── manager.yaml           # Manager 的 Kubernetes 部署清单
26│   ├── network-policy
27│   │   ├── allow-metrics-traffic.yaml  # 网络策略，允许访问指标服务
28│   │   └── kustomization.yaml     # 网络策略的 kustomize 配置
29│   ├── prometheus
30│   │   ├── kustomization.yaml     # Prometheus 监控的 kustomize 配置
31│   │   └── monitor.yaml           # Prometheus 对 Operator 进行监控的规则
32│   ├── rbac
33│   │   ├── kustomization.yaml     # 用于生成 RBAC 配置的 kustomize 配置
34│   │   ├── leader_election_role.yaml   # Leader 选举的角色权限配置
35│   │   ├── leader_election_role_binding.yaml  # Leader 选举的角色绑定
36│   │   ├── metrics_auth_role.yaml # 监控指标授权的 RBAC 配置
37│   │   ├── metrics_auth_role_binding.yaml # 监控指标授权的角色绑定
38│   │   ├── metrics_reader_role.yaml  # 用于读取指标的角色
39│   │   ├── mysql_editor_role.yaml    # MySQL 资源编辑者角色
40│   │   ├── mysql_viewer_role.yaml    # MySQL 资源查看者角色
41│   │   ├── role.yaml                 # 默认的 Operator 角色
42│   │   ├── role_binding.yaml         # 角色绑定，将角色分配给 ServiceAccount
43│   │   └── service_account.yaml      # 定义 Operator 的 ServiceAccount
44│   └── samples
45│       ├── apps_v1_mysql.yaml       # 示例自定义资源，定义 MySQL 资源的 YAML 文件
46│       └── kustomization.yaml       # 样例资源的 kustomize 配置
47├── go.mod                           # Go 模块文件，记录依赖关系
48├── go.sum                           # Go 依赖的版本锁定文件
49├── hack
50│   └── boilerplate.go.txt           # 代码文件的版权声明模板
51├── internal
52│   └── controller
53│       ├── mysql_controller.go      # MySQL 控制器的核心逻辑，处理 CR 的状态同步和管理
54│       ├── mysql_controller_test.go # 控制器的单元测试
55│       └── suite_test.go            # 控制器的测试套件配置
56└── test
57    ├── e2e
58    │   ├── e2e_suite_test.go        # 端到端测试的套件配置
59    │   └── e2e_test.go              # 端到端测试的逻辑
60    └── utils
61        └── utils.go                 # 测试过程中使用的工具函数

1kubebuilder create api --group apps --version v1 --kind MySQL --resource --controller

 1package v1
 2
 3import (
 4    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 5)
 6
 7// MySQLSpec 定义了 MySQL 资源的期望状态
 8type MySQLSpec struct {
 9    // MySQL 用户名
10    Username string `json:"username"`
11
12    // MySQL 用户密码
13    Password string `json:"password"`
14
15    // 数据库名称
16    Database string `json:"database"`
17
18    // MySQL 实例的副本数（用于扩展）
19    Size int32 `json:"size"`
20
21    // 定期备份的时间表（Cron 表达式）
22    BackupSchedule string `json:"backupSchedule"`
23
24    // 备份存储路径
25    BackupPath string `json:"backupPath"`
26}
27
28// MySQLStatus 定义了 MySQL 资源的当前状态
29type MySQLStatus struct {
30    // 当前可用的 MySQL 副本数
31    ReadyReplicas int32 `json:"readyReplicas"`
32
33    // 最近备份的时间
34    LastBackupTime *metav1.Time `json:"lastBackupTime,omitempty"`
35
36    // 资源状态条件（如是否可用、是否需要备份等）
37    Conditions []metav1.Condition `json:"conditions,omitempty"`
38}
39
40// +kubebuilder:object:root=true
41// +kubebuilder:subresource:status
42
43// MySQL 是 MySQL 资源的 Schema
44type MySQL struct {
45    metav1.TypeMeta   `json:",inline"`
46    metav1.ObjectMeta `json:"metadata,omitempty"`
47
48    Spec   MySQLSpec   `json:"spec,omitempty"`
49    Status MySQLStatus `json:"status,omitempty"`
50}
51
52// +kubebuilder:object:root=true
53
54// MySQLList 包含 MySQL 资源的列表
55type MySQLList struct {
56    metav1.TypeMeta `json:",inline"`
57    metav1.ListMeta `json:"metadata,omitempty"`
58    Items           []MySQL `json:"items"`
59}
60
61func init() {
62    SchemeBuilder.Register(&MySQL{}, &MySQLList{})
63}

1# `make generate` 的作用：
2# 生成深度拷贝函数 `zz_generated.deepcopy.go`，确保在 Kubernetes 控制器中可以安全地拷贝自定义资源对象。
3# 确保自定义资源的代码与 Kubernetes API 兼容。
4make generate

1# **`make manifests` 的作用**：
2# - 该命令会基于 `mysql_types.go` 中的定义生成相应的 Kubernetes CRD 定义文件。
3# - 文件会被生成到 `config/crd/bases/` 目录下。
4make manifests

  1package controller
  2
  3import (
  4	"context"
  5	appsv1 "k8s.io/api/apps/v1"
  6	corev1 "k8s.io/api/core/v1"
  7	"k8s.io/apimachinery/pkg/api/errors"
  8	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  9	"k8s.io/apimachinery/pkg/runtime"
 10	"k8s.io/apimachinery/pkg/types"
 11	ctrl "sigs.k8s.io/controller-runtime"
 12	"sigs.k8s.io/controller-runtime/pkg/client"
 13	"sigs.k8s.io/controller-runtime/pkg/log"
 14
 15	appsv1alpha1 "github.com/ZhangSIming-blyq/mysql-operator/api/v1"
 16)
 17
 18// MySQLReconciler 是 MySQL 控制器的结构体
 19type MySQLReconciler struct {
 20	client.Client
 21	Scheme *runtime.Scheme
 22}
 23
 24// Reconcile 是控制器的核心逻辑，用于处理 MySQL CR 的状态变化
 25func (r *MySQLReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
 26	/*
 27		是的，目前的 Reconcile 逻辑主要涵盖以下两点：
 28
 29		创建 MySQL 的 Deployment：如果 MySQL CR 对应的 Deployment 不存在，会根据 CR 中定义的 spec 创建一个新的 Deployment。
 30		控制副本数：如果 MySQL CR 的 spec.size 与现有 Deployment 的副本数不匹配，控制器会更新 Deployment，以确保实际副本数与期望的副本数一致。
 31		除此之外，Reconcile 函数还会更新 MySQL CR 的 status，将 Deployment 中实际的副本数同步到 MySQL CR 的 ReadyReplicas 字段。
 32	*/
 33	log := log.FromContext(ctx)
 34
 35	// 获取 MySQL 实例: 在 Kubernetes 的控制器中，r.Get 函数只会返回一个具体的对象，而不会返回多个对象。这是因为 req.NamespacedName 包含了特定的 namespace 和 name，代表了一个唯一的资源实例。因此，不会出现 Get 返回多个对象的情况。
 36	var mysql appsv1alpha1.MySQL
 37	if err := r.Get(ctx, req.NamespacedName, &mysql); err != nil {
 38		if errors.IsNotFound(err) {
 39			// 如果没有找到 MySQL 实例，可能已经被删除，不采取行动
 40			log.Info("MySQL resource not found. Ignoring since object must be deleted")
 41			return ctrl.Result{}, nil
 42		}
 43		log.Error(err, "Failed to get MySQL")
 44		return ctrl.Result{}, err
 45	}
 46
 47	// 检查 MySQL Secret 是否存在，如果不存在则创建
 48	var secret corev1.Secret
 49	secretName := mysql.Name // 使用 MySQL CR 的名称作为 Secret 名称
 50	err := r.Get(ctx, types.NamespacedName{Name: secretName, Namespace: mysql.Namespace}, &secret)
 51	if err != nil && errors.IsNotFound(err) {
 52		log.Info("Creating a new Secret for MySQL", "Secret.Namespace", mysql.Namespace, "Secret.Name", secretName)
 53
 54		// 从 MySQL CR 中获取 username 和 password
 55		username := mysql.Spec.Username
 56		password := mysql.Spec.Password
 57
 58		// 创建 Secret
 59		secret = corev1.Secret{
 60			ObjectMeta: metav1.ObjectMeta{
 61				Name:      secretName,
 62				Namespace: mysql.Namespace,
 63			},
 64			StringData: map[string]string{
 65				"MYSQL_ROOT_PASSWORD": password, // 使用 CR 中的 password
 66				"MYSQL_USER":          username, // 使用 CR 中的 username
 67			},
 68			Type: corev1.SecretTypeOpaque,
 69		}
 70
 71		if err := r.Create(ctx, &secret); err != nil {
 72			log.Error(err, "Failed to create new Secret", "Secret.Namespace", mysql.Namespace, "Secret.Name", secretName)
 73			return ctrl.Result{}, err
 74		}
 75		// 重新排队 Reconcile
 76		return ctrl.Result{Requeue: true}, nil
 77	} else if err != nil {
 78		log.Error(err, "Failed to get Secret")
 79		return ctrl.Result{}, err
 80	}
 81
 82	// 检查是否存在 MySQL Deployment，如果不存在则创建
 83	var deployment appsv1.Deployment
 84	err = r.Get(ctx, types.NamespacedName{Name: mysql.Name, Namespace: mysql.Namespace}, &deployment)
 85	if err != nil && errors.IsNotFound(err) {
 86		log.Info("Creating a new Deployment for MySQL", "Deployment.Namespace", mysql.Namespace, "Deployment.Name", mysql.Name)
 87		// 根据CRD的定义创建 Deployment
 88		dep := r.mysqlDeployment(&mysql)
 89		if err := r.Create(ctx, dep); err != nil {
 90			log.Error(err, "Failed to create new Deployment", "Deployment.Namespace", mysql.Namespace, "Deployment.Name", mysql.Name)
 91			return ctrl.Result{}, err
 92		}
 93		// 重新排队 Reconcile
 94		return ctrl.Result{Requeue: true}, nil
 95	} else if err != nil {
 96		log.Error(err, "Failed to get Deployment")
 97		return ctrl.Result{}, err
 98	}
 99
100	// 确保副本数与期望一致
101	size := mysql.Spec.Size
102	if *deployment.Spec.Replicas != size {
103		deployment.Spec.Replicas = &size
104		if err := r.Update(ctx, &deployment); err != nil {
105			log.Error(err, "Failed to update Deployment", "Deployment.Namespace", mysql.Namespace, "Deployment.Name", mysql.Name)
106			return ctrl.Result{}, err
107		}
108		// 创建完secret没有必要立刻重建
109		return ctrl.Result{}, nil
110	}
111
112	// 更新 MySQL 状态
113	mysql.Status.ReadyReplicas = deployment.Status.ReadyReplicas
114	if err := r.Status().Update(ctx, &mysql); err != nil {
115		log.Error(err, "Failed to update MySQL status")
116		return ctrl.Result{}, err
117	}
118
119	return ctrl.Result{}, nil
120}
121
122// mysqlDeployment 返回定义的 MySQL Deployment
123func (r *MySQLReconciler) mysqlDeployment(mysql *appsv1alpha1.MySQL) *appsv1.Deployment {
124	labels := map[string]string{"app": "mysql", "mysql_cr": mysql.Name}
125	replicas := mysql.Spec.Size
126
127	dep := &appsv1.Deployment{
128		ObjectMeta: metav1.ObjectMeta{
129			Name:      mysql.Name,
130			Namespace: mysql.Namespace,
131		},
132		Spec: appsv1.DeploymentSpec{
133			Replicas: &replicas,
134			Selector: &metav1.LabelSelector{
135				MatchLabels: labels,
136			},
137			Template: corev1.PodTemplateSpec{
138				ObjectMeta: metav1.ObjectMeta{
139					Labels: labels,
140				},
141				Spec: corev1.PodSpec{
142					Containers: []corev1.Container{{
143						Name:  "mysql",
144						Image: "mysql:5.7",
145						Ports: []corev1.ContainerPort{{
146							ContainerPort: 3306,
147							Name:          "mysql",
148						}},
149						Env: []corev1.EnvVar{
150							{
151								Name: "MYSQL_ROOT_PASSWORD",
152								ValueFrom: &corev1.EnvVarSource{
153									SecretKeyRef: &corev1.SecretKeySelector{
154										Key: "MYSQL_ROOT_PASSWORD",
155										LocalObjectReference: corev1.LocalObjectReference{
156											Name: mysql.Name,
157										},
158									},
159								},
160							},
161						},
162					}},
163				},
164			},
165		},
166	}
167	// Set the owner reference for garbage collection
168	ctrl.SetControllerReference(mysql, dep, r.Scheme)
169	return dep
170}
171
172// SetupWithManager 将控制器注册到 Manager 中
173func (r *MySQLReconciler) SetupWithManager(mgr ctrl.Manager) error {
174	return ctrl.NewControllerManagedBy(mgr).
175		For(&appsv1alpha1.MySQL{}).
176		Owns(&appsv1.Deployment{}).
177		Complete(r)
178}

1make generate

1make docker-build IMG=<your-operator-image>:<tag>

1make docker-build IMG=myregistry/mysql-operator:v1.0.0

1make docker-push IMG=myregistry/mysql-operator:v1.0.0

1spec:
2  containers:
3    - name: manager
4      image: myregistry/mysql-operator:v1.0.0
5      command:
6      - /manager

1make manifests

 1# 上传镜像到kubernetes所在机器
 2docker image save docker.io/myregistry/mysql-operator:v1.0.0 > dockerimage                                                                                      
 3
 4du -sh dockerimage 
 5 81M	dockerimage
 6
 7scp dockerimage siming-dev:~
 8dockerimage
 9
10# 部署各种yaml
11k apply -f crd/bases/apps.siming.com_mysqls.yaml
12k apply -f manager/manager.yaml
13k apply -f rbac/service_account.yaml
14k apply -f rbac/role_binding.yaml
15k apply -f rbac/role.yaml
16
17# 查看状态: 如果rbac权限不够，比如代码逻辑需要，记得手动更新
18k logs -f controller-manager-6c784ddb46-2b7lb                                                                                                         
192024-09-17T12:46:43Z	INFO	setup	starting manager
202024-09-17T12:46:43Z	INFO	starting server	{"name": "health probe", "addr": "[::]:8081"}
21I0917 12:46:43.256807       1 leaderelection.go:254] attempting to acquire leader lease system/b3982890.siming.com...
22I0917 12:47:00.943439       1 leaderelection.go:268] successfully acquired lease system/b3982890.siming.com
232024-09-17T12:47:00Z	DEBUG	events	controller-manager-6c784ddb46-2b7lb_8dccc7f2-caa7-4e2e-8268-8726aab5a9cf became leader	{"type": "Normal", "object": {"kind":"Lease","namespace":"system","name":"b3982890.siming.com","uid":"bd617fbe-a002-4545-8a23-ed4dd77d7f82","apiVersion":"coordination.k8s.io/v1","resourceVersion":"1470723"}, "reason": "LeaderElection"}
242024-09-17T12:47:00Z	INFO	Starting EventSource	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "source": "kind source: *v1.MySQL"}
252024-09-17T12:47:00Z	INFO	Starting EventSource	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "source": "kind source: *v1.Deployment"}
262024-09-17T12:47:00Z	INFO	Starting Controller	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL"}
272024-09-17T12:47:01Z	INFO	Starting workers	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "worker count": 1}

 1apiVersion: apps.example.com/v1
 2kind: MySQL
 3metadata:
 4  name: example-mysql
 5spec:
 6  username: root
 7  password: password123
 8  database: mydatabase
 9  size: 3
10  backupSchedule: "*/5 * * * *"
11  backupPath: /backups

 1k logs -f controller-manager-578b69d9d4-t228b                                                                                                              ok | base py | with ubuntu@VM-24-14-ubuntu | at 22:45:08
 22024-09-17T14:41:49Z	INFO	setup	starting manager
 32024-09-17T14:41:49Z	INFO	starting server	{"name": "health probe", "addr": "[::]:8081"}
 4I0917 14:41:49.676064       1 leaderelection.go:254] attempting to acquire leader lease system/b3982890.siming.com...
 5I0917 14:42:17.231093       1 leaderelection.go:268] successfully acquired lease system/b3982890.siming.com
 62024-09-17T14:42:17Z	DEBUG	events	controller-manager-578b69d9d4-t228b_521b43d8-0f30-44b1-a596-83d2946336b4 became leader	{"type": "Normal", "object": {"kind":"Lease","namespace":"system","name":"b3982890.siming.com","uid":"bd617fbe-a002-4545-8a23-ed4dd77d7f82","apiVersion":"coordination.k8s.io/v1","resourceVersion":"1484357"}, "reason": "LeaderElection"}
 72024-09-17T14:42:17Z	INFO	Starting EventSource	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "source": "kind source: *v1.MySQL"}
 82024-09-17T14:42:17Z	INFO	Starting EventSource	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "source": "kind source: *v1.Deployment"}
 92024-09-17T14:42:17Z	INFO	Starting Controller	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL"}
102024-09-17T14:42:17Z	INFO	Starting workers	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "worker count": 1}
112024-09-17T14:43:01Z	INFO	Creating a new Deployment for MySQL	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "MySQL": {"name":"mysql-sample","namespace":"system"}, "namespace": "system", "name": "mysql-sample", "reconcileID": "90483a7a-4ba9-4381-a402-04a18635a0b9", "Deployment.Namespace": "system", "Deployment.Name": "mysql-sample"}
122024-09-17T14:45:00Z	INFO	MySQL resource not found. Ignoring since object must be deleted	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "MySQL": {"name":"mysql-sample","namespace":"system"}, "namespace": "system", "name": "mysql-sample", "reconcileID": "a93dd691-e78f-46fa-9672-fde7cf421d6d"}
132024-09-17T14:45:00Z	INFO	MySQL resource not found. Ignoring since object must be deleted	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "MySQL": {"name":"mysql-sample","namespace":"system"}, "namespace": "system", "name": "mysql-sample", "reconcileID": "10467c4f-e29d-4aca-b60d-878a3ceac98a"}
142024-09-17T14:45:07Z	INFO	Creating a new Secret for MySQL	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "MySQL": {"name":"mysql-sample","namespace":"system"}, "namespace": "system", "name": "mysql-sample", "reconcileID": "f4e005b4-b4db-49fd-a838-e9031958e9e8", "Secret.Namespace": "system", "Secret.Name": "mysql-sample"}
152024-09-17T14:45:07Z	INFO	Creating a new Deployment for MySQL	{"controller": "mysql", "controllerGroup": "apps.siming.com", "controllerKind": "MySQL", "MySQL": {"name":"mysql-sample","namespace":"system"}, "namespace": "system", "name": "mysql-sample", "reconcileID": "748ccf1b-e0ca-4544-8f11-8cd40b526458", "Deployment.Namespace": "system", "Deployment.Name": "mysql-sample"}
16...
17
18kp   
19controller-manager-578b69d9d4-t228b   1/1     Running   0          3m39s
20mysql-sample-64b88f58f7-9lkr9         1/1     Running   0          20s
21
22k get mysql mysql-sample -o yaml                                                                                                      
23apiVersion: apps.siming.com/v1
24kind: MySQL
25metadata:
26  annotations:
27    kubectl.kubernetes.io/last-applied-configuration: |
28      {"apiVersion":"apps.siming.com/v1","kind":"MySQL","metadata":{"annotations":{},"labels":{"app.kubernetes.io/managed-by":"kustomize","app.kubernetes.io/name":"mysql-operator"},"name":"mysql-sample","namespace":"system"},"spec":{"backupPath":"/backups","backupSchedule":"*/5 * * * *","database":"mydatabase","password":"password123","size":1,"username":"root"}}
29  creationTimestamp: "2024-09-17T14:45:07Z"
30  generation: 1
31  labels:
32    app.kubernetes.io/managed-by: kustomize
33    app.kubernetes.io/name: mysql-operator
34  name: mysql-sample
35  namespace: system
36  resourceVersion: "1484746"
37  uid: 3e799684-8646-4c20-a1dd-6724ab78e56b
38spec:
39  backupPath: /backups
40  backupSchedule: '*/5 * * * *'
41  database: mydatabase
42  password: password123
43  size: 1
44  username: root
45status:
46  readyReplicas: 1
47
48# 把副本改成2之后会通过operator自动创建
49k apply -f samples/apps_v1_mysql.yaml
50mysql.apps.siming.com/mysql-sample configured
51
52kp -w 
53NAME                                  READY   STATUS              RESTARTS   AGE
54controller-manager-578b69d9d4-t228b   1/1     Running             0          5m27s
55mysql-sample-64b88f58f7-9lkr9         1/1     Running             0          2m8s
56mysql-sample-64b88f58f7-trwrc         0/1     ContainerCreating   0          1s
57mysql-sample-64b88f58f7-trwrc         1/1     Running             0          2s

1kubebuilder init --domain mydomain.com --repo github.com/myorg/my-operator

1kubebuilder create api --group apps --version v1 --kind MySQL

1make generate
2make manifests

 1func (r *MySQLReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
 2    // 获取 MySQL 实例
 3    var mysql appsv1alpha1.MySQL
 4    if err := r.Get(ctx, req.NamespacedName, &mysql); err != nil {
 5        return ctrl.Result{}, client.IgnoreNotFound(err)
 6    }
 7
 8    // 检查是否需要创建或更新 Deployment
 9    // 处理业务逻辑
10}

1var mysql appsv1alpha1.MySQL
2if err := r.Get(ctx, req.NamespacedName, &mysql); err != nil {
3    return ctrl.Result{}, client.IgnoreNotFound(err)
4}