Reflect k8s volume id in test data. Extract aws volume id from k8s value.

pkg/cluster/volumes.go

@@ -265,8 +265,13 @@ func (c *Cluster) executeEBSMigration() error {
 	c.logger.Debugf("found %d volumes, size of known volumes %d", len(pvs), len(c.EBSVolumes))
 
 	volumeIds := []string{}
+	var volumeID string
 	for _, pv := range pvs {
-		volumeID := pv.Spec.AWSElasticBlockStore.VolumeID
+		volumeID, err = c.VolumeResizer.GetProviderVolumeID(pv)
+		if err != nil {
+			continue
+		}
+
 		volumeIds = append(volumeIds, volumeID)
 	}
 

pkg/cluster/volumes_test.go

@@ -234,11 +234,11 @@ func TestMigrateEBS(t *testing.T) {
 
 	ps := v1.PersistentVolumeSpec{}
 	ps.AWSElasticBlockStore = &v1.AWSElasticBlockStoreVolumeSource{}
-	ps.AWSElasticBlockStore.VolumeID = "ebs-volume-1"
+	ps.AWSElasticBlockStore.VolumeID = "aws://eu-central-1b/ebs-volume-1"
 
 	ps2 := v1.PersistentVolumeSpec{}
 	ps2.AWSElasticBlockStore = &v1.AWSElasticBlockStoreVolumeSource{}
-	ps2.AWSElasticBlockStore.VolumeID = "ebs-volume-2"
+	ps2.AWSElasticBlockStore.VolumeID = "aws://eu-central-1b/ebs-volume-2"
 
 	pvList := &v1.PersistentVolumeList{
 		Items: []v1.PersistentVolume{

pkg/util/volumes/ebs.go

@@ -47,7 +47,7 @@ func (r *EBSVolumeResizer) GetProviderVolumeID(pv *v1.PersistentVolume) (string,
 	}
 	idx := strings.LastIndex(volumeID, constants.EBSVolumeIDStart) + 1
 	if idx == 0 {
-		return "", fmt.Errorf("malfored EBS volume id %q", volumeID)
+		return "", fmt.Errorf("malformed EBS volume id %q", volumeID)
 	}
 	return volumeID[idx:], nil
 }