Release v2.3.4

修复：避免当 clb 底层性能出问题时绑定 rs 失败（没有错误码）误以为绑定成功而将映射结果写入 pod 注解的问题。

Author: imroc

CHANGELOG.md

@@ -1,5 +1,9 @@
 # 版本说明
 
+## v2.3.4 (2025-08-07)
+
+- 修复：避免当 clb 底层性能出问题时绑定 rs 失败（没有错误码）误以为绑定成功而将映射结果写入 pod 注解的问题。
+
 ## v2.3.3 (2025-08-04)
 
 - 优化chart：vpc 接口调用走内部地址，不依赖公网。

Makefile

@@ -1,5 +1,5 @@
 # Image URL to use all building/pushing image targets
-IMG ?= imroc/tke-extend-network-controller:2.3.3
+IMG ?= imroc/tke-extend-network-controller:2.3.4
 # ENVTEST_K8S_VERSION refers to the version of kubebuilder assets to be downloaded by envtest binary.
 ENVTEST_K8S_VERSION = 1.30.0
 

charts/tke-extend-network-controller/Chart.yaml

@@ -18,11 +18,11 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 2.3.3
+version: 2.3.4
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
 # It is recommended to use it with quotes.
-appVersion: 2.3.3
+appVersion: 2.3.4
 kubeVersion: '>= 1.26.0-0'

pkg/clb/batch-target.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 
 	clb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/clb/v20180317"
+	"github.com/tkestack/tke-extend-network-controller/pkg/util"
 )
 
 type RegisterTargetTask struct {
@@ -48,9 +49,16 @@ func startRegisterTargetsProccessor(concurrent int) {
 			}
 			return
 		}
-		_, err = Wait(context.Background(), region, *res.Response.RequestId, apiName)
-		for _, task := range tasks {
-			task.Result <- err
+		if len(res.Response.FailListenerIdSet) > 0 {
+			err := fmt.Errorf("register targets failed for %s", util.ConvertPtrSlice(res.Response.FailListenerIdSet))
+			for _, task := range tasks {
+				task.Result <- err
+			}
+		} else {
+			_, err = Wait(context.Background(), region, *res.Response.RequestId, apiName)
+			for _, task := range tasks {
+				task.Result <- err
+			}
 		}
 	})
 }