fix(region): cdn purge

This commit is contained in:
Qu Xuan
2021-11-02 19:25:14 +08:00
parent bfaf8729ed
commit 7e9306c283
2 changed files with 19 additions and 0 deletions
+1
View File
@@ -1482,6 +1482,7 @@ func (self *SCloudprovider) RealDelete(ctx context.Context, userCred mcclient.To
MongoDBManager,
ElasticSearchManager,
KafkaManager,
CDNDomainManager,
NetworkInterfaceManager,
KubeClusterManager,
CloudproviderRegionManager,
+18
View File
@@ -2047,6 +2047,24 @@ func (manager *SKafkaManager) purgeAll(ctx context.Context, userCred mcclient.To
return nil
}
func (manager *SCDNDomainManager) purgeAll(ctx context.Context, userCred mcclient.TokenCredential, providerId string) error {
domains := []SCDNDomain{}
err := fetchByManagerId(manager, providerId, &domains)
if err != nil {
return errors.Wrapf(err, "fetchByManagerId")
}
for i := range domains {
lockman.LockObject(ctx, &domains[i])
defer lockman.ReleaseObject(ctx, &domains[i])
err := domains[i].RealDelete(ctx, userCred)
if err != nil {
return errors.Wrapf(err, "cdn domain delete")
}
}
return nil
}
func (manager *SKubeClusterManager) purgeAll(ctx context.Context, userCred mcclient.TokenCredential, providerId string) error {
clusters := []SKubeCluster{}
err := fetchByManagerId(manager, providerId, &clusters)