126 lines
4.6 KiB
Go
126 lines
4.6 KiB
Go
/*
|
|
Copyright 2020 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package driver
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"strings"
|
|
|
|
"github.com/kubernetes-csi/csi-driver-nfs/pkg/nfs"
|
|
"github.com/kubernetes-csi/external-snapshotter/v2/pkg/apis/volumesnapshot/v1beta1"
|
|
v1 "k8s.io/api/core/v1"
|
|
storagev1 "k8s.io/api/storage/v1"
|
|
"k8s.io/apimachinery/pkg/api/resource"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/klog"
|
|
)
|
|
|
|
// NFSDriverNameVar is the environment variable use to switch the driver to be used.
|
|
const NFSDriverNameVar = "NFS_CSI_DRIVER"
|
|
|
|
// NFSDriver implements DynamicPVTestDriver interface
|
|
type NFSDriver struct {
|
|
driverName string
|
|
}
|
|
|
|
// InitNFSDriver returns NFSDriver that implements DynamicPVTestDriver interface
|
|
func InitNFSDriver() PVTestDriver {
|
|
driverName := os.Getenv(NFSDriverNameVar)
|
|
if driverName == "" {
|
|
driverName = nfs.DriverName
|
|
}
|
|
|
|
klog.Infof("Using nfs driver: %s", driverName)
|
|
return &NFSDriver{
|
|
driverName: driverName,
|
|
}
|
|
}
|
|
|
|
// normalizeProvisioner extracts any '/' character in the provisioner name to '-'.
|
|
// StorageClass name cannot container '/' character.
|
|
func normalizeProvisioner(provisioner string) string {
|
|
return strings.ReplaceAll(provisioner, "/", "-")
|
|
}
|
|
|
|
func (d *NFSDriver) GetDynamicProvisionStorageClass(parameters map[string]string, mountOptions []string, reclaimPolicy *v1.PersistentVolumeReclaimPolicy, bindingMode *storagev1.VolumeBindingMode, allowedTopologyValues []string, namespace string) *storagev1.StorageClass {
|
|
provisioner := d.driverName
|
|
generateName := fmt.Sprintf("%s-%s-dynamic-sc-", namespace, normalizeProvisioner(provisioner))
|
|
return getStorageClass(generateName, provisioner, parameters, mountOptions, reclaimPolicy, bindingMode, nil)
|
|
}
|
|
|
|
func (d *NFSDriver) GetPreProvisionStorageClass(parameters map[string]string, mountOptions []string, reclaimPolicy *v1.PersistentVolumeReclaimPolicy, bindingMode *storagev1.VolumeBindingMode, allowedTopologyValues []string, namespace string) *storagev1.StorageClass {
|
|
provisioner := d.driverName
|
|
generateName := fmt.Sprintf("%s-%s-pre-provisioned-sc-", namespace, provisioner)
|
|
return getStorageClass(generateName, provisioner, parameters, mountOptions, reclaimPolicy, bindingMode, nil)
|
|
}
|
|
|
|
func (d *NFSDriver) GetVolumeSnapshotClass(namespace string) *v1beta1.VolumeSnapshotClass {
|
|
provisioner := d.driverName
|
|
generateName := fmt.Sprintf("%s-%s-dynamic-sc-", namespace, normalizeProvisioner(provisioner))
|
|
return getVolumeSnapshotClass(generateName, provisioner)
|
|
}
|
|
|
|
func (d *NFSDriver) GetPersistentVolume(volumeID string, fsType string, size string, reclaimPolicy *v1.PersistentVolumeReclaimPolicy, namespace string, attrib map[string]string, nodeStageSecretRef string) *v1.PersistentVolume {
|
|
provisioner := d.driverName
|
|
generateName := fmt.Sprintf("%s-%s-preprovsioned-pv-", namespace, normalizeProvisioner(provisioner))
|
|
// Default to Retain ReclaimPolicy for pre-provisioned volumes
|
|
pvReclaimPolicy := v1.PersistentVolumeReclaimRetain
|
|
if reclaimPolicy != nil {
|
|
pvReclaimPolicy = *reclaimPolicy
|
|
}
|
|
stageSecretRef := &v1.SecretReference{}
|
|
if nodeStageSecretRef != "" {
|
|
stageSecretRef.Name = nodeStageSecretRef
|
|
stageSecretRef.Namespace = namespace
|
|
} else {
|
|
stageSecretRef = nil
|
|
}
|
|
return &v1.PersistentVolume{
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
GenerateName: generateName,
|
|
Namespace: namespace,
|
|
// TODO remove if https://github.com/kubernetes-csi/external-provisioner/issues/202 is fixed
|
|
Annotations: map[string]string{
|
|
"pv.kubernetes.io/provisioned-by": provisioner,
|
|
},
|
|
},
|
|
Spec: v1.PersistentVolumeSpec{
|
|
AccessModes: []v1.PersistentVolumeAccessMode{v1.ReadWriteOnce},
|
|
Capacity: v1.ResourceList{
|
|
v1.ResourceName(v1.ResourceStorage): resource.MustParse(size),
|
|
},
|
|
PersistentVolumeReclaimPolicy: pvReclaimPolicy,
|
|
PersistentVolumeSource: v1.PersistentVolumeSource{
|
|
CSI: &v1.CSIPersistentVolumeSource{
|
|
Driver: provisioner,
|
|
VolumeHandle: volumeID,
|
|
FSType: fsType,
|
|
VolumeAttributes: attrib,
|
|
NodeStageSecretRef: stageSecretRef,
|
|
},
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
func GetParameters() map[string]string {
|
|
return map[string]string{
|
|
"skuName": "Standard_LRS",
|
|
}
|
|
}
|