fix(region): sync aliyun k8s by region

This commit is contained in:
Qu Xuan
2021-11-08 19:01:11 +08:00
parent dc2cf168b1
commit f10f203d55
+7 -2
View File
@@ -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
}