Fix: ephemeral pvcs (#403)

* added missing nindent arg in imagePullSecrets

* added missing nindent arg in imagePullSecrets

* bumped chart version

* fixed reporting ephemeral pvcs

* added tests

---------

Co-authored-by: Jan Nemcik <jan.nemcik@ataccama.com>

Author: nemcikjan

pkg/kor/create_test_resources.go

@@ -9,6 +9,7 @@ import (
 	policyv1 "k8s.io/api/policy/v1"
 	rbacv1 "k8s.io/api/rbac/v1"
 	storagev1 "k8s.io/api/storage/v1"
+	"k8s.io/apimachinery/pkg/api/resource"
 	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 )
@@ -96,6 +97,25 @@ func CreateTestVolume(name, pvcName string) *corev1.Volume {
 
 }
 
+func CreateEphemeralVolumeDefinition(name, size string) *corev1.Volume {
+	return &corev1.Volume{
+		Name: name,
+		VolumeSource: corev1.VolumeSource{
+			Ephemeral: &corev1.EphemeralVolumeSource{
+				VolumeClaimTemplate: &corev1.PersistentVolumeClaimTemplate{
+					Spec: corev1.PersistentVolumeClaimSpec{
+						Resources: corev1.VolumeResourceRequirements{
+							Requests: corev1.ResourceList{
+								corev1.ResourceStorage: resource.MustParse(size),
+							},
+						},
+					},
+				},
+			},
+		},
+	}
+}
+
 func CreateTestServiceAccount(namespace, name string, labels map[string]string) *corev1.ServiceAccount {
 	return &corev1.ServiceAccount{
 		ObjectMeta: v1.ObjectMeta{

pkg/kor/pvc.go

@@ -28,6 +28,11 @@ func retrieveUsedPvcs(clientset kubernetes.Interface, namespace string) ([]strin
 			if volume.PersistentVolumeClaim != nil {
 				usedPvcs = append(usedPvcs, volume.PersistentVolumeClaim.ClaimName)
 			}
+			// Include ephemeral PVC
+			if volume.Ephemeral != nil && volume.Ephemeral.VolumeClaimTemplate != nil {
+				// https://kubernetes.io/docs/concepts/storage/ephemeral-volumes/#persistentvolumeclaim-naming
+				usedPvcs = append(usedPvcs, pod.GetObjectMeta().GetName()+"-"+volume.Name)
+			}
 		}
 	}
 	return usedPvcs, err

pkg/kor/pvc_test.go

@@ -57,10 +57,17 @@ func createTestPvcs(t *testing.T) *fake.Clientset {
 	volumeList = append(volumeList, *testVolume)
 	testPod := CreateTestPod(testNamespace, "test-pod", "test-sa", volumeList, AppLabels)
 
+	ephVolume := CreateEphemeralVolumeDefinition("test-ephemeral-volume", "1Gi")
+	testPodWEphemeralStorage := CreateTestPod(testNamespace, "test-pod-ephemeral-storage", "test-sa", []corev1.Volume{*ephVolume}, AppLabels)
+
 	_, err = clientset.CoreV1().Pods(testNamespace).Create(context.TODO(), testPod, v1.CreateOptions{})
 	if err != nil {
 		t.Fatalf("Error creating fake %s: %v", "Pvc", err)
 	}
+	_, err = clientset.CoreV1().Pods(testNamespace).Create(context.TODO(), testPodWEphemeralStorage, v1.CreateOptions{})
+	if err != nil {
+		t.Fatalf("Error creating fake %s: %v", "Pvc", err)
+	}
 
 	return clientset
 }
@@ -72,13 +79,17 @@ func TestRetrieveUsedPvcs(t *testing.T) {
 		t.Errorf("Expected no error, got %v", err)
 	}
 
-	if len(usedPvcs) != 1 {
-		t.Errorf("Expected 1 used pvc, got %d", len(usedPvcs))
+	if len(usedPvcs) != 2 {
+		t.Errorf("Expected 2 used pvc, got %d", len(usedPvcs))
 	}
 
 	if usedPvcs[0] != "test-pvc1" {
 		t.Errorf("Expected 'test-pvc1', got %s", usedPvcs[0])
 	}
+
+	if usedPvcs[1] != "test-pod-ephemeral-storage-test-ephemeral-volume" {
+		t.Errorf("Expected 'test-pod-ephemeral-storage-test-ephemeral-volume', got %s", usedPvcs[1])
+	}
 }
 
 func TestProcessNamespacePvcs(t *testing.T) {