一些优化

Author: imroc

api/v1alpha1/dedicatedclbservice_types.go

@@ -86,7 +86,7 @@ type AllocatableCLBInfo struct {
 	LbId string `json:"lbId"`
 	// CLB 当前已被分配的端口。
 	// +optional
-	CurrentPort int64 `json:"maxPort"`
+	CurrentPort int64 `json:"currentPort"`
 	// 是否是自动创建的 CLB。如果是，删除 DedicatedCLBService 时，CLB 也会被清理。
 	AutoCreate bool `json:"autoCreate"`
 }

charts/tke-extend-network-controller/templates/networking.cloud.tencent.com_dedicatedclbservices.yaml

@@ -112,13 +112,13 @@ spec:
                     autoCreate:
                       description: 是否是自动创建的 CLB。如果是，删除 DedicatedCLBService 时，CLB 也会被清理。
                       type: boolean
-                    lbId:
-                      description: CLB 实例的 ID。
-                      type: string
-                    maxPort:
+                    currentPort:
                       description: CLB 当前已被分配的端口。
                       format: int64
                       type: integer
+                    lbId:
+                      description: CLB 实例的 ID。
+                      type: string
                   required:
                   - autoCreate
                   - lbId

config/crd/bases/networking.cloud.tencent.com_dedicatedclbservices.yaml

@@ -113,13 +113,13 @@ spec:
                     autoCreate:
                       description: 是否是自动创建的 CLB。如果是，删除 DedicatedCLBService 时，CLB 也会被清理。
                       type: boolean
-                    lbId:
-                      description: CLB 实例的 ID。
-                      type: string
-                    maxPort:
+                    currentPort:
                       description: CLB 当前已被分配的端口。
                       format: int64
                       type: integer
+                    lbId:
+                      description: CLB 实例的 ID。
+                      type: string
                   required:
                   - autoCreate
                   - lbId

internal/controller/dedicatedclbservice_controller.go

@@ -67,7 +67,7 @@ type DedicatedCLBServiceReconciler struct {
 // - https://pkg.go.dev/sigs.k8s.io/[email protected]/pkg/reconcile
 func (r *DedicatedCLBServiceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
 	ds := &networkingv1alpha1.DedicatedCLBService{}
-	if err := r.Get(ctx, req.NamespacedName, ds); err != nil {
+	if err := r.APIReader.Get(ctx, req.NamespacedName, ds); err != nil { // 避免从缓存中读取（status可能更新不及时导致状态不一致，造成clb多创等问题）
 		return ctrl.Result{}, client.IgnoreNotFound(err)
 	}
 	return util.RequeueIfConflict(r.reconcile(ctx, ds))
@@ -234,7 +234,7 @@ func (r *DedicatedCLBServiceReconciler) allocateNewCLB(ctx context.Context, ds *
 	if err != nil {
 		return err
 	}
-	log.FromContext(ctx).Info("successfully created clb instance", "lbIds", ids)
+	r.Recorder.Event(ds, corev1.EventTypeNormal, "CreateCLB", fmt.Sprintf("clb successfully created: %v", ids))
 	return kube.UpdateStatus(ctx, ds, func() {
 		for _, lbId := range ids {
 			ds.Status.AllocatableLb = append(ds.Status.AllocatableLb, networkingv1alpha1.AllocatableCLBInfo{