update at 2024-08-09 17:36:43

Author: imroc

pkg/clb/listener.go

@@ -68,9 +68,9 @@ func CreateListener(ctx context.Context, region string, req *clb.CreateListenerR
 	req.ListenerNames = []*string{common.StringPtr(TkePodListenerName)}
 	client := GetClient(region)
 	lbId := *req.LoadBalancerId
-	mux := getLbLock(lbId)
-	mux.Lock()
-	defer mux.Unlock()
+	mu := getLbLock(lbId)
+	mu.Lock()
+	defer mu.Unlock()
 	resp, err := client.CreateListenerWithContext(ctx, req)
 	if err != nil {
 		return
@@ -109,9 +109,9 @@ func DeleteListener(ctx context.Context, region, lbId, listenerId string) error
 	req.LoadBalancerId = &lbId
 	req.ListenerId = &listenerId
 	client := GetClient(region)
-	mux := getLbLock(lbId)
-	mux.Lock()
-	defer mux.Unlock()
+	mu := getLbLock(lbId)
+	mu.Lock()
+	defer mu.Unlock()
 	resp, err := client.DeleteListenerWithContext(ctx, req)
 	if err != nil {
 		return err

pkg/clb/lock.go

@@ -10,10 +10,10 @@ var (
 func getLbLock(lbId string) *sync.Mutex {
 	lock.Lock()
 	defer lock.Unlock()
-	mux, ok := lbLockMap[lbId]
+	mu, ok := lbLockMap[lbId]
 	if !ok {
-		mux = &sync.Mutex{}
-		lbLockMap[lbId] = mux
+		mu = &sync.Mutex{}
+		lbLockMap[lbId] = mu
 	}
-	return mux
+	return mu
 }

pkg/clb/target.go

@@ -103,9 +103,9 @@ func (t Target) String() string {
 }
 
 func DeregisterAllTargets(ctx context.Context, region, lbId, listenerId string) error {
-	mux := getLbLock(lbId)
-	mux.Lock()
-	defer mux.Unlock()
+	mu := getLbLock(lbId)
+	mu.Lock()
+	defer mu.Unlock()
 	queryReq := clb.NewDescribeTargetsRequest()
 	queryReq.LoadBalancerId = &lbId
 	queryReq.ListenerIds = []*string{&listenerId}
@@ -132,9 +132,9 @@ func DeregisterAllTargets(ctx context.Context, region, lbId, listenerId string)
 }
 
 func DeregisterTargetsForListener(ctx context.Context, region, lbId, listenerId string, targets ...Target) error {
-	mux := getLbLock(lbId)
-	mux.Lock()
-	defer mux.Unlock()
+	mu := getLbLock(lbId)
+	mu.Lock()
+	defer mu.Unlock()
 	clbTargets := getClbTargets(targets)
 	req := clb.NewDeregisterTargetsRequest()
 	req.LoadBalancerId = &lbId
@@ -159,9 +159,9 @@ func getClbTargets(targets []Target) (clbTargets []*clb.Target) {
 }
 
 func RegisterTargets(ctx context.Context, region, lbId, listenerId string, targets ...Target) error {
-	mux := getLbLock(lbId)
-	mux.Lock()
-	defer mux.Unlock()
+	mu := getLbLock(lbId)
+	mu.Lock()
+	defer mu.Unlock()
 	clbTargets := getClbTargets(targets)
 	req := clb.NewRegisterTargetsRequest()
 	req.LoadBalancerId = &lbId