rebase: update remaining kubernetes.io packages to v0.32.2

Signed-off-by: Niels de Vos <ndevos@ibm.com>
This commit is contained in:
Niels de Vos
2025-02-14 17:10:46 +01:00
committed by mergify[bot]
parent 229603a8ea
commit 75c70e158f
4 changed files with 194 additions and 128 deletions

View File

@ -18,6 +18,7 @@ package plugins
import (
"fmt"
"strings"
v1 "k8s.io/api/core/v1"
storagev1 "k8s.io/api/storage/v1"
@ -28,6 +29,29 @@ import (
const (
PortworxVolumePluginName = "kubernetes.io/portworx-volume"
PortworxDriverName = "pxd.portworx.com"
OpenStorageAuthSecretNameKey = "openstorage.io/auth-secret-name"
OpenStorageAuthSecretNamespaceKey = "openstorage.io/auth-secret-namespace"
csiParameterPrefix = "csi.storage.k8s.io/"
prefixedProvisionerSecretNameKey = csiParameterPrefix + "provisioner-secret-name"
prefixedProvisionerSecretNamespaceKey = csiParameterPrefix + "provisioner-secret-namespace"
prefixedControllerPublishSecretNameKey = csiParameterPrefix + "controller-publish-secret-name"
prefixedControllerPublishSecretNamespaceKey = csiParameterPrefix + "controller-publish-secret-namespace"
prefixedNodeStageSecretNameKey = csiParameterPrefix + "node-stage-secret-name"
prefixedNodeStageSecretNamespaceKey = csiParameterPrefix + "node-stage-secret-namespace"
prefixedNodePublishSecretNameKey = csiParameterPrefix + "node-publish-secret-name"
prefixedNodePublishSecretNamespaceKey = csiParameterPrefix + "node-publish-secret-namespace"
prefixedControllerExpandSecretNameKey = csiParameterPrefix + "controller-expand-secret-name"
prefixedControllerExpandSecretNamespaceKey = csiParameterPrefix + "controller-expand-secret-namespace"
prefixedNodeExpandSecretNameKey = csiParameterPrefix + "node-expand-secret-name"
prefixedNodeExpandSecretNamespaceKey = csiParameterPrefix + "node-expand-secret-namespace"
)
var _ InTreePlugin = &portworxCSITranslator{}
@ -44,7 +68,34 @@ func (p portworxCSITranslator) TranslateInTreeStorageClassToCSI(logger klog.Logg
if sc == nil {
return nil, fmt.Errorf("sc is nil")
}
var params = map[string]string{}
for k, v := range sc.Parameters {
switch strings.ToLower(k) {
case OpenStorageAuthSecretNameKey:
params[prefixedProvisionerSecretNameKey] = v
params[prefixedControllerPublishSecretNameKey] = v
params[prefixedNodePublishSecretNameKey] = v
params[prefixedNodeStageSecretNameKey] = v
params[prefixedControllerExpandSecretNameKey] = v
params[prefixedNodeExpandSecretNameKey] = v
case OpenStorageAuthSecretNamespaceKey:
params[prefixedProvisionerSecretNamespaceKey] = v
params[prefixedControllerPublishSecretNamespaceKey] = v
params[prefixedNodePublishSecretNamespaceKey] = v
params[prefixedNodeStageSecretNamespaceKey] = v
params[prefixedControllerExpandSecretNamespaceKey] = v
params[prefixedNodeExpandSecretNamespaceKey] = v
default:
// All other parameters can be copied as is
params[k] = v
}
}
if len(params) > 0 {
sc.Parameters = params
}
sc.Provisioner = PortworxDriverName
return sc, nil
}
@ -87,11 +138,26 @@ func (p portworxCSITranslator) TranslateInTreePVToCSI(logger klog.Logger, pv *v1
if pv == nil || pv.Spec.PortworxVolume == nil {
return nil, fmt.Errorf("pv is nil or PortworxVolume not defined on pv")
}
var secretRef *v1.SecretReference
if metav1.HasAnnotation(pv.ObjectMeta, OpenStorageAuthSecretNameKey) &&
metav1.HasAnnotation(pv.ObjectMeta, OpenStorageAuthSecretNamespaceKey) {
secretRef = &v1.SecretReference{
Name: pv.Annotations[OpenStorageAuthSecretNameKey],
Namespace: pv.Annotations[OpenStorageAuthSecretNamespaceKey],
}
}
csiSource := &v1.CSIPersistentVolumeSource{
Driver: PortworxDriverName,
VolumeHandle: pv.Spec.PortworxVolume.VolumeID,
FSType: pv.Spec.PortworxVolume.FSType,
VolumeAttributes: make(map[string]string), // copy access mode
Driver: PortworxDriverName,
VolumeHandle: pv.Spec.PortworxVolume.VolumeID,
FSType: pv.Spec.PortworxVolume.FSType,
VolumeAttributes: make(map[string]string), // copy access mode
ControllerPublishSecretRef: secretRef,
NodeStageSecretRef: secretRef,
NodePublishSecretRef: secretRef,
ControllerExpandSecretRef: secretRef,
NodeExpandSecretRef: secretRef,
}
pv.Spec.PortworxVolume = nil
pv.Spec.CSI = csiSource