From f10f203d55fcae252e74dfd8ae8e29436e73e941 Mon Sep 17 00:00:00 2001
From: Qu Xuan <quxuan@yunionyun.com>
Date: Mon, 8 Nov 2021 19:01:11 +0800
Subject: [PATCH] fix(region): sync aliyun k8s by region

---
 pkg/multicloud/aliyun/kube_cluster.go | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/pkg/multicloud/aliyun/kube_cluster.go b/pkg/multicloud/aliyun/kube_cluster.go
index 5cb8575d61..287f3b52f6 100644
--- a/pkg/multicloud/aliyun/kube_cluster.go
+++ b/pkg/multicloud/aliyun/kube_cluster.go
@@ -210,8 +210,10 @@ func (self *SRegion) GetICloudKubeClusters() ([]cloudprovider.ICloudKubeCluster,
 	}
 	ret := []cloudprovider.ICloudKubeCluster{}
 	for i := range clusters {
-		clusters[i].region = self
-		ret = append(ret, &clusters[i])
+		if clusters[i].RegionId == self.RegionId {
+			clusters[i].region = self
+			ret = append(ret, &clusters[i])
+		}
 	}
 	return ret, nil
 }
@@ -221,6 +223,9 @@ func (self *SRegion) GetICloudKubeClusterById(id string) (cloudprovider.ICloudKu
 	if err != nil {
 		return nil, errors.Wrapf(err, "GetKubeCluster(%s)", id)
 	}
+	if cluster.RegionId != self.RegionId {
+		return nil, errors.Wrapf(cloudprovider.ErrNotFound, "%s at region %s", id, cluster.RegionId)
+	}
 	return cluster, nil
 }