fix: review label usage for pvc and volume association

internal/adapter/converter/persistentvolumeclaim.go

@@ -17,7 +17,7 @@ func (converter *DockerAPIConverter) UpdateConfigMapToPersistentVolumeClaim(pers
 
 	persistentVolumeClaim.ObjectMeta = metav1.ObjectMeta{
 		Name:      configMap.Labels[k2dtypes.PersistentVolumeClaimNameLabelKey],
-		Namespace: configMap.Labels[k2dtypes.NamespaceNameLabelKey],
+		Namespace: configMap.Labels[k2dtypes.PersistentVolumeClaimTargetNamespaceLabelKey],
 		CreationTimestamp: metav1.Time{
 			Time: configMap.CreationTimestamp.Time,
 		},

internal/adapter/deployment.go

@@ -24,7 +24,7 @@ func (adapter *KubeDockerAdapter) CreateContainerFromDeployment(ctx context.Cont
 		labels:        deployment.Spec.Template.Labels,
 	}
 
-	opts.labels[k2dtypes.WorkloadLabelKey] = k2dtypes.DeploymentWorkloadType
+	opts.labels[k2dtypes.WorkloadTypeLabelKey] = k2dtypes.DeploymentWorkloadType
 
 	if deployment.Labels["app.kubernetes.io/managed-by"] == "Helm" {
 		deploymentData, err := json.Marshal(deployment)

internal/adapter/filters/filters.go

@@ -22,7 +22,7 @@ import (
 //	// Now 'filter' can be used in Docker API calls to filter Deployment resources in the 'default' Kubernetes namespace.
 func AllDeployments(namespace string) filters.Args {
 	filter := ByNamespace(namespace)
-	filter.Add("label", fmt.Sprintf("%s=%s", types.WorkloadLabelKey, types.DeploymentWorkloadType))
+	filter.Add("label", fmt.Sprintf("%s=%s", types.WorkloadTypeLabelKey, types.DeploymentWorkloadType))
 	return filter
 }
 
@@ -141,19 +141,19 @@ func ByService(namespace, serviceName string) filters.Args {
 	return filter
 }
 
-// AllPersistentVolumes creates a Docker filter argument that targets resources labeled with a Kubernetes persistent volume name.
-// This function uses the types.PersistentVolumeNameLabelKey constant as the base label key to filter Docker resources.
+// AllPersistentVolumes creates a Docker filter argument that targets resources labeled with a specific type of storage, in this case, Kubernetes persistent volumes.
+// This function uses the types.StorageTypeLabelKey and types.PersistentVolumeStorageType constants to filter Docker resources.
 //
 // Parameters:
 //   - None
 //
 // Returns:
-// - filters.Args: A Docker filter object that can be used to filter Docker API calls based on the presence of the persistent volume name label.
+//   - filters.Args: A Docker filter object that can be used to filter Docker API calls based on the presence of a label indicating the storage type as a Kubernetes persistent volume.
 //
 // Usage Example:
 //
 //	filter := AllPersistentVolumes()
-//	// Now 'filter' can be used in Docker API calls to filter resources that are labeled with any Kubernetes persistent volume name.
+//	// Now 'filter' can be used in Docker API calls to filter resources that are labeled with a specific type of storage as a Kubernetes persistent volume.
 func AllPersistentVolumes() filters.Args {
-	return filters.NewArgs(filters.Arg("label", types.PersistentVolumeNameLabelKey))
+	return filters.NewArgs(filters.Arg("label", fmt.Sprintf("%s=%s", types.StorageTypeLabelKey, types.PersistentVolumeStorageType)))
 }

internal/adapter/persistentvolumeclaim.go

@@ -65,6 +65,7 @@ func (adapter *KubeDockerAdapter) CreatePersistentVolumeClaim(ctx context.Contex
 			Driver: "local",
 			Labels: map[string]string{
 				k2dtypes.PersistentVolumeNameLabelKey: volumeName,
+				k2dtypes.StorageTypeLabelKey:          k2dtypes.PersistentVolumeStorageType,
 			},
 		})
 
@@ -85,13 +86,14 @@ func (adapter *KubeDockerAdapter) CreatePersistentVolumeClaim(ctx context.Contex
 		ObjectMeta: metav1.ObjectMeta{
 			Name: naming.BuildPVCSystemConfigMapName(persistentVolumeClaim.Name, persistentVolumeClaim.Namespace),
 			Labels: map[string]string{
-				k2dtypes.NamespaceNameLabelKey:             persistentVolumeClaim.Namespace,
-				k2dtypes.PersistentVolumeNameLabelKey:      volumeName,
-				k2dtypes.PersistentVolumeClaimNameLabelKey: persistentVolumeClaim.Name,
-				k2dtypes.LastAppliedConfigLabelKey:         persistentVolumeClaim.ObjectMeta.Annotations["kubectl.kubernetes.io/last-applied-configuration"],
+				k2dtypes.PersistentVolumeNameLabelKey:                 volumeName,
+				k2dtypes.PersistentVolumeClaimNameLabelKey:            persistentVolumeClaim.Name,
+				k2dtypes.PersistentVolumeClaimTargetNamespaceLabelKey: persistentVolumeClaim.Namespace,
+				k2dtypes.LastAppliedConfigLabelKey:                    persistentVolumeClaim.ObjectMeta.Annotations["kubectl.kubernetes.io/last-applied-configuration"],
 			},
 		},
 	}
+
 	err := adapter.CreateSystemConfigMap(pvcConfigMap)
 	if err != nil {
 		return fmt.Errorf("unable to create system configmap for persistent volume claim: %w", err)
@@ -203,7 +205,7 @@ func (adapter *KubeDockerAdapter) listPersistentVolumeClaims(ctx context.Context
 	}
 
 	for _, configMap := range configMaps.Items {
-		namespace := configMap.Labels[k2dtypes.NamespaceNameLabelKey]
+		namespace := configMap.Labels[k2dtypes.PersistentVolumeClaimTargetNamespaceLabelKey]
 
 		if namespaceName == "" || namespace == namespaceName {
 			pvcLastAppliedConfig := configMap.Labels[k2dtypes.LastAppliedConfigLabelKey]

internal/adapter/store/filesystem/configmap.go

@@ -8,6 +8,7 @@ import (
 	"time"
 
 	"github.com/portainer/k2d/internal/adapter/errors"
+	"github.com/portainer/k2d/internal/adapter/types"
 	"github.com/portainer/k2d/pkg/filesystem"
 	"github.com/portainer/k2d/pkg/maputils"
 	corev1 "k8s.io/api/core/v1"
@@ -207,8 +208,8 @@ func (s *FileSystemStore) StoreConfigMap(configMap *corev1.ConfigMap) error {
 	defer s.mutex.Unlock()
 
 	labels := map[string]string{
-		NamespaceNameLabelKey:     configMap.Namespace,
-		CreationTimestampLabelKey: time.Now().UTC().Format(time.RFC3339),
+		types.NamespaceNameLabelKey: configMap.Namespace,
+		CreationTimestampLabelKey:   time.Now().UTC().Format(time.RFC3339),
 	}
 	maputils.MergeMapsInPlace(labels, configMap.Labels)
 
@@ -296,7 +297,7 @@ func (s *FileSystemStore) loadMetadataAndInitConfigMaps(metadataFiles []string,
 			return configMaps, fmt.Errorf("unable to load configmap metadata from disk: %w", err)
 		}
 
-		namespaceName := metadata[NamespaceNameLabelKey]
+		namespaceName := metadata[types.NamespaceNameLabelKey]
 		if namespace != "" && namespace != namespaceName {
 			continue
 		}

internal/adapter/store/filesystem/secret.go

@@ -8,6 +8,7 @@ import (
 	"time"
 
 	"github.com/portainer/k2d/internal/adapter/errors"
+	"github.com/portainer/k2d/internal/adapter/types"
 	"github.com/portainer/k2d/pkg/filesystem"
 	"github.com/portainer/k2d/pkg/maputils"
 	corev1 "k8s.io/api/core/v1"
@@ -213,8 +214,8 @@ func (s *FileSystemStore) StoreSecret(secret *corev1.Secret) error {
 	defer s.mutex.Unlock()
 
 	labels := map[string]string{
-		NamespaceNameLabelKey:     secret.Namespace,
-		CreationTimestampLabelKey: time.Now().UTC().Format(time.RFC3339),
+		types.NamespaceNameLabelKey: secret.Namespace,
+		CreationTimestampLabelKey:   time.Now().UTC().Format(time.RFC3339),
 	}
 	maputils.MergeMapsInPlace(labels, secret.Labels)
 
@@ -316,7 +317,7 @@ func (s *FileSystemStore) loadMetadataAndInitSecrets(metadataFiles []string, nam
 			continue
 		}
 
-		namespaceName := metadata[NamespaceNameLabelKey]
+		namespaceName := metadata[types.NamespaceNameLabelKey]
 		if namespace != "" && namespace != namespaceName {
 			continue
 		}

internal/adapter/store/filesystem/store.go

@@ -24,11 +24,6 @@ const (
 )
 
 const (
-	// NamespaceNameLabelKey is the key used to store the namespace of a Configmap or Secret resource
-	// in the associated metadata file
-	// It is used to identify the namespace associated with a ConfigMap or a Secret
-	NamespaceNameLabelKey = "store.k2d.io/filesystem/namespace-name"
-
 	// CreationTimestampLabelKey is the key used to store the creation timestamp of a Configmap or Secret resource
 	// in the associated metadata file
 	CreationTimestampLabelKey = "store.k2d.io/filesystem/creation-timestamp"

internal/adapter/types/labels.go

@@ -27,14 +27,28 @@ const (
 
 	// PersistentVolumeNameLabelKey is the key used to store the persistent volume name in the labels of a system configmap or a Docker volume
 	PersistentVolumeNameLabelKey = "storage.k2d.io/pv-name"
+
+	// PersistentVolumeClaimTargetNamespaceLabelKey is the key used to store the target namespace of a persistent volume claim in the labels of a system configmap
+	// This is used to identify the namespace where the persistent volume claim is used (e.g. the namespace of the workload)
+	PersistentVolumeClaimTargetNamespaceLabelKey = "storage.k2d.io/pvc-target-namespace"
+
+	// StorageTypeLabelKey is the key used to store the storage type in the labels of a system configmap or a Docker volume
+	// It is used to differentiate between persistent volumes and config maps when listing volumes
+	StorageTypeLabelKey = "storage.k2d.io/type"
+)
+
+const (
+	// PersistentVolumeStorageType is the label value used to identify a persistent volume storage
+	// It is stored inside metadata as a label and used to filter persistent volumes when listing persistent volumes
+	PersistentVolumeStorageType = "pv"
 )
 
 const (
 	// ServiceNameLabelKey is the key used to store the service name associated to the workload in the container labels
 	ServiceNameLabelKey = "workload.k2d.io/service-name"
 
-	// WorkloadLabelKey is the key used to store the workload type in the container labels
-	WorkloadLabelKey = "workload.k2d.io/type"
+	// WorkloadTypeLabelKey is the key used to store the workload type in the container labels
+	WorkloadTypeLabelKey = "workload.k2d.io/type"
 
 	// WorkloadNameLabelKey is the key used to store the workload name in the container labels
 	WorkloadNameLabelKey = "workload.k2d.io/name"