diff --git a/pkg/controllers/resources/persistentvolumeclaims/translate.go b/pkg/controllers/resources/persistentvolumeclaims/translate.go index 01f2c6355b..9ffec15851 100644 --- a/pkg/controllers/resources/persistentvolumeclaims/translate.go +++ b/pkg/controllers/resources/persistentvolumeclaims/translate.go @@ -55,7 +55,7 @@ func (s *persistentVolumeClaimSyncer) translateSelector(ctx *synccontext.SyncCon // translate storage class if we manage those in vcluster if s.storageClassesEnabled && storageClassName != "" { - translated := translate.Default.HostNameCluster(storageClassName) + translated := mappings.VirtualToHostName(ctx, storageClassName, "", mappings.StorageClasses()) delete(vPvc.Annotations, deprecatedStorageClassAnnotation) vPvc.Spec.StorageClassName = &translated } @@ -67,7 +67,7 @@ func (s *persistentVolumeClaimSyncer) translateSelector(ctx *synccontext.SyncCon vPvc.Spec.Selector = translate.HostLabelSelector(vPvc.Spec.Selector) } if vPvc.Spec.VolumeName != "" { - vPvc.Spec.VolumeName = translate.Default.HostNameCluster(vPvc.Spec.VolumeName) + vPvc.Spec.VolumeName = mappings.VirtualToHostName(ctx, vPvc.Spec.VolumeName, "", mappings.PersistentVolumes()) } // check if the storage class exists in the physical cluster if !s.storageClassesEnabled && storageClassName != "" { @@ -75,12 +75,12 @@ func (s *persistentVolumeClaimSyncer) translateSelector(ctx *synccontext.SyncCon if vPvc.Spec.Selector == nil && vPvc.Spec.VolumeName == "" { err := ctx.HostClient.Get(ctx, types.NamespacedName{Name: storageClassName}, &storagev1.StorageClass{}) if err != nil && kerrors.IsNotFound(err) { - translated := translate.Default.HostNameCluster(storageClassName) + translated := mappings.VirtualToHostName(ctx, storageClassName, "", mappings.StorageClasses()) delete(vPvc.Annotations, deprecatedStorageClassAnnotation) vPvc.Spec.StorageClassName = &translated } } else { - translated := translate.Default.HostNameCluster(storageClassName) + translated := mappings.VirtualToHostName(ctx, storageClassName, "", mappings.StorageClasses()) delete(vPvc.Annotations, deprecatedStorageClassAnnotation) vPvc.Spec.StorageClassName = &translated } diff --git a/pkg/controllers/resources/persistentvolumes/syncer.go b/pkg/controllers/resources/persistentvolumes/syncer.go index f32027fe48..77a01decb9 100644 --- a/pkg/controllers/resources/persistentvolumes/syncer.go +++ b/pkg/controllers/resources/persistentvolumes/syncer.go @@ -248,7 +248,7 @@ func (s *persistentVolumeSyncer) Sync(ctx *synccontext.SyncContext, event *syncc // update host object if event.Virtual.Annotations[constants.HostClusterPersistentVolumeAnnotation] == "" { // TODO: translate the storage secrets - event.Host.Spec.StorageClassName = translate.Default.HostNameCluster(event.Virtual.Spec.StorageClassName) + event.Host.Spec.StorageClassName = mappings.VirtualToHostName(ctx, event.Virtual.Spec.StorageClassName, "", mappings.StorageClasses()) } // bi-directional sync of annotations and labels diff --git a/pkg/controllers/resources/persistentvolumes/translate.go b/pkg/controllers/resources/persistentvolumes/translate.go index 675f45bb70..4bbafd7bc9 100644 --- a/pkg/controllers/resources/persistentvolumes/translate.go +++ b/pkg/controllers/resources/persistentvolumes/translate.go @@ -17,7 +17,7 @@ func (s *persistentVolumeSyncer) translate(ctx *synccontext.SyncContext, vPv *co // TODO: translate the storage secrets if pPV.Spec.StorageClassName != "" { - pPV.Spec.StorageClassName = translate.Default.HostNameCluster(vPv.Spec.StorageClassName) + pPV.Spec.StorageClassName = mappings.VirtualToHostName(ctx, vPv.Spec.StorageClassName, "", mappings.StorageClasses()) } return pPV, nil }