Skip to content

Commit 0eb89a9

Browse files
ShyamsundarRBenamarMk
authored andcommitted
Delete ManagedClusterView for DRClusterConfig on DRCluster deletion
Signed-off-by: Shyamsundar Ranganathan <[email protected]>
1 parent 9746aed commit 0eb89a9

File tree

4 files changed

+25
-7
lines changed

4 files changed

+25
-7
lines changed

internal/controller/drclusters.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -249,6 +249,10 @@ func drClusterUndeploy(
249249
return err
250250
}
251251

252+
if err := mcv.DeleteDRClusterConfigManagedClusterView(drcluster.GetName()); err != nil {
253+
return err
254+
}
255+
252256
if err := mwu.DeleteManifestWork(mwu.BuildManifestWorkName(util.MWTypeDRCConfig), drcluster.GetName()); err != nil {
253257
return err
254258
}

internal/controller/drpolicy_peerclass.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -541,7 +541,7 @@ func getClusterClasses(
541541
annotations := make(map[string]string)
542542
annotations[AllDRPolicyAnnotation] = cluster
543543

544-
drcConfig, err := m.GetDRClusterConfigFromManagedCluster(cluster, cluster, annotations)
544+
drcConfig, err := m.GetDRClusterConfigFromManagedCluster(cluster, annotations)
545545
if err != nil {
546546
return classLists{}, err
547547
}

internal/controller/fake_mcv_test.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,12 +33,16 @@ type FakeMCVGetter struct {
3333
}
3434

3535
func (f FakeMCVGetter) GetDRClusterConfigFromManagedCluster(
36-
resourceName, managedCluster string,
36+
resourceName string,
3737
annotations map[string]string,
3838
) (*rmn.DRClusterConfig, error) {
3939
return nil, nil
4040
}
4141

42+
func (f FakeMCVGetter) DeleteDRClusterConfigManagedClusterView(clusterName string) error {
43+
return nil
44+
}
45+
4246
func (f FakeMCVGetter) GetSClassFromManagedCluster(resourceName, managedCluster string, annotations map[string]string,
4347
) (*storagev1.StorageClass, error) {
4448
return nil, nil

internal/controller/util/mcv_util.go

Lines changed: 15 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,11 @@ type ManagedClusterViewGetter interface {
4343
ListMModesMCVs(managedCluster string) (*viewv1beta1.ManagedClusterViewList, error)
4444

4545
GetDRClusterConfigFromManagedCluster(
46-
resourceName, managedCluster string,
46+
resourceName string,
4747
annotations map[string]string) (*rmn.DRClusterConfig, error)
4848

49+
DeleteDRClusterConfigManagedClusterView(clusterName string) error
50+
4951
GetSClassFromManagedCluster(
5052
resourceName, managedCluster string,
5153
annotations map[string]string) (*storagev1.StorageClass, error)
@@ -198,18 +200,19 @@ func (m ManagedClusterViewGetterImpl) ListMModesMCVs(cluster string) (*viewv1bet
198200
return m.listMCVsWithLabel(cluster, map[string]string{MModesLabel: ""})
199201
}
200202

201-
func (m ManagedClusterViewGetterImpl) GetDRClusterConfigFromManagedCluster(resourceName, managedCluster string,
203+
func (m ManagedClusterViewGetterImpl) GetDRClusterConfigFromManagedCluster(
204+
clusterName string,
202205
annotations map[string]string,
203206
) (*rmn.DRClusterConfig, error) {
204207
drcConfig := &rmn.DRClusterConfig{}
205208

206209
err := m.getResourceFromManagedCluster(
207-
resourceName,
210+
clusterName,
208211
"",
209-
managedCluster,
212+
clusterName,
210213
annotations,
211214
nil,
212-
BuildManagedClusterViewName(resourceName, "", MWTypeDRCConfig),
215+
BuildManagedClusterViewName(clusterName, "", MWTypeDRCConfig),
213216
"DRClusterConfig",
214217
rmn.GroupVersion.Group,
215218
rmn.GroupVersion.Version,
@@ -477,6 +480,13 @@ func (m ManagedClusterViewGetterImpl) DeleteNFManagedClusterView(
477480
return m.DeleteManagedClusterView(clusterName, mcvNameNF, logger)
478481
}
479482

483+
func (m ManagedClusterViewGetterImpl) DeleteDRClusterConfigManagedClusterView(clusterName string) error {
484+
logger := ctrl.Log.WithName("MCV").WithValues("resouceName", clusterName)
485+
mcvNameDRCConfig := BuildManagedClusterViewName(clusterName, "", MWTypeDRCConfig)
486+
487+
return m.DeleteManagedClusterView(clusterName, mcvNameDRCConfig, logger)
488+
}
489+
480490
func (m ManagedClusterViewGetterImpl) DeleteManagedClusterView(clusterName, mcvName string, logger logr.Logger) error {
481491
logger.Info("Delete ManagedClusterView from", "namespace", clusterName, "name", mcvName)
482492

0 commit comments

Comments
 (0)