github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 04:06:03 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #96821 from wongma7/translateebsinline

Browse Source 
Use volumeHandle as PV name when translating EBS inline volume
This commit is contained in:
Kubernetes Prow Robot 2021-01-11 20:52:25 -08:00 committed by GitHub
commit 9720013d92
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 94 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
staging/src/k8s.io/csi-translation-lib/plugins/aws_ebs.go
View File

@ -98,7 +98,7 @@ func (t *awsElasticBlockStoreCSITranslator) TranslateInTreeInlineVolumeToCSI(vol
ObjectMeta: metav1.ObjectMeta{
// Must be unique per disk as it is used as the unique part of the
// staging path
Name: fmt.Sprintf("%s-%s", AWSEBSDriverName, ebsSource.VolumeID),
Name: fmt.Sprintf("%s-%s", AWSEBSDriverName, volumeHandle),
},
Spec: v1.PersistentVolumeSpec{
PersistentVolumeSource: v1.PersistentVolumeSource{

100
staging/src/k8s.io/csi-translation-lib/plugins/aws_ebs_test.go
View File

@ -17,12 +17,20 @@ limitations under the License.
package plugins
import (
v1 "k8s.io/api/core/v1"
"reflect"
"testing"
storage "k8s.io/api/storage/v1"
)
const (
normalVolumeID = "vol-02399794d890f9375"
awsVolumeID = "aws:///vol-02399794d890f9375"
awsZoneVolumeID = "aws://us-west-2a/vol-02399794d890f9375"
invalidVolumeID = "aws://us-west-2a/02399794d890f9375"
)
func TestKubernetesVolumeIDToEBSVolumeID(t *testing.T) {
testCases := []struct {
name string
@ -32,22 +40,22 @@ func TestKubernetesVolumeIDToEBSVolumeID(t *testing.T) {
}{
{
name: "Normal ID format",
kubernetesID: "vol-02399794d890f9375",
ebsVolumeID: "vol-02399794d890f9375",
kubernetesID: normalVolumeID,
ebsVolumeID: normalVolumeID,
},
{
name: "aws:///{volumeId} format",
kubernetesID: "aws:///vol-02399794d890f9375",
ebsVolumeID: "vol-02399794d890f9375",
kubernetesID: awsVolumeID,
ebsVolumeID: normalVolumeID,
},
{
name: "aws://{zone}/{volumeId} format",
kubernetesID: "aws://us-west-2a/vol-02399794d890f9375",
ebsVolumeID: "vol-02399794d890f9375",
kubernetesID: awsZoneVolumeID,
ebsVolumeID: normalVolumeID,
},
{
name: "fails on invalid volume ID",
kubernetesID: "aws://us-west-2a/02399794d890f9375",
kubernetesID: invalidVolumeID,
expErr: true,
},
}
@ -112,3 +120,81 @@ func TestTranslateEBSInTreeStorageClassToCSI(t *testing.T) {
}
}
func TestTranslateInTreeInlineVolumeToCSI(t *testing.T) {
translator := NewAWSElasticBlockStoreCSITranslator()
cases := []struct {
name string
volumeSource v1.VolumeSource
expPVName string
expErr bool
}{
{
name: "Normal ID format",
volumeSource: v1.VolumeSource{
AWSElasticBlockStore: &v1.AWSElasticBlockStoreVolumeSource{
VolumeID: normalVolumeID,
},
},
expPVName: "ebs.csi.aws.com-" + normalVolumeID,
},
{
name: "aws:///{volumeId} format",
volumeSource: v1.VolumeSource{
AWSElasticBlockStore: &v1.AWSElasticBlockStoreVolumeSource{
VolumeID: awsVolumeID,
},
},
expPVName: "ebs.csi.aws.com-" + normalVolumeID,
},
{
name: "aws://{zone}/{volumeId} format",
volumeSource: v1.VolumeSource{
AWSElasticBlockStore: &v1.AWSElasticBlockStoreVolumeSource{
VolumeID: awsZoneVolumeID,
},
},
expPVName: "ebs.csi.aws.com-" + normalVolumeID,
},
{
name: "fails on invalid volume ID",
volumeSource: v1.VolumeSource{
AWSElasticBlockStore: &v1.AWSElasticBlockStoreVolumeSource{
VolumeID: invalidVolumeID,
},
},
expErr: true,
},
{
name: "fails on empty volume source",
volumeSource: v1.VolumeSource{},
expErr: true,
},
}
for _, tc := range cases {
t.Run(tc.name, func(t *testing.T) {
t.Logf("Testing %v", tc.name)
got, err := translator.TranslateInTreeInlineVolumeToCSI(&v1.Volume{Name: "volume", VolumeSource: tc.volumeSource})
if err != nil && !tc.expErr {
t.Fatalf("Did not expect error but got: %v", err)
}
if err == nil && tc.expErr {
t.Fatalf("Expected error, but did not get one.")
}
if err == nil {
if !reflect.DeepEqual(got.Name, tc.expPVName) {
t.Errorf("Got PV name: %v, expected :%v", got.Name, tc.expPVName)
}
if !reflect.DeepEqual(got.Spec.CSI.VolumeHandle, normalVolumeID) {
t.Errorf("Got PV volumeHandle: %v, expected :%v", got.Spec.CSI.VolumeHandle, normalVolumeID)
}
}
})
}
}