Added storage provisioner

chart/templates/deployment.yaml

@@ -33,14 +33,6 @@ spec:
           imagePullPolicy: {{ .Values.image.pullPolicy }}
           resources:
             {{- toYaml .Values.resources | nindent 12 }}
-          volumeMounts:
-            - name: data-volumes
-              mountPath: {{ .Values.storage.path }}
-      volumes:
-        - name: data-volumes
-          hostPath:
-            path: {{ .Values.storage.path }}
-            type: DirectoryOrCreate
       {{- with .Values.nodeSelector }}
       nodeSelector:
         {{- toYaml . | nindent 8 }}

chart/values.yaml

@@ -9,11 +9,8 @@ image:
   tag: main
 
 imagePullSecrets: []
-nameOverride: ''
-fullnameOverride: ''
-
-storage:
-  path: /data/volumes
+nameOverride: ""
+fullnameOverride: ""
 
 serviceAccount:
   # Specifies whether a service account should be created
@@ -22,7 +19,7 @@ serviceAccount:
   annotations: {}
   # The name of the service account to use.
   # If not set and create is true, a name is generated using the fullname template
-  name: ''
+  name: ""
 
 podAnnotations: {}
 
@@ -53,4 +50,4 @@ nodeSelector: {}
 
 tolerations: []
 
-affinity: {}
+affinity: {}

scripts/list-manifests.ts

@@ -1,15 +0,0 @@
-#!/usr/bin/env node
-
-import { K8sService } from '../src/services/k8s/k8s.ts';
-import { Services } from '../src/utils/service.ts';
-
-const services = new Services();
-const k8s = services.get(K8sService);
-
-const manifests = await k8s.extensionsApi.listCustomResourceDefinition();
-
-for (const manifest of manifests.items) {
-  for (const version of manifest.spec.versions) {
-    console.log(`group: ${manifest.spec.group}, plural: ${manifest.spec.names.plural}, version: ${version.name}`);
-  }
-}

src/storage-provider/storage-provider.ts

@@ -7,6 +7,7 @@ import type { Services } from '../utils/service.ts';
 import { ResourceService, type Resource } from '../services/resources/resources.ts';
 
 const PROVISIONER = 'reuse-local-path-provisioner';
+const LABEL_SELECTOR = `provisioner=${PROVISIONER}`;
 
 class StorageProvider {
   #watcher: Watcher<V1PersistentVolumeClaim>;
@@ -16,36 +17,26 @@ class StorageProvider {
     this.#services = services;
     const watchService = this.#services.get(WatcherService);
     this.#watcher = watchService.create({
-      path: '/api/v1/persistentvolumeclaims',
-      transform: (manifest) => ({
-        apiVersion: 'v1',
-        kind: 'PersistentVolumeClaim',
-        ...manifest,
-      }),
-      list: async (k8s) => {
-        const current = await k8s.api.listPersistentVolumeClaimForAllNamespaces();
-        return current;
-      },
+      path: '/api/v1/persistantvolumeclaims',
+      list: (k8s) =>
+        k8s.api.listPersistentVolumeClaimForAllNamespaces({
+          labelSelector: LABEL_SELECTOR,
+        }),
       verbs: ['add', 'update', 'delete'],
+      selector: LABEL_SELECTOR,
     });
     this.#watcher.on('changed', this.#handleChange);
   }
 
   #handleChange = async (pvc: Resource<V1PersistentVolumeClaim>) => {
-    if (pvc.metadata?.annotations?.['volume.kubernetes.io/storage-provisioner'] !== PROVISIONER) {
-      return;
-    }
     const target = `/data/volumes/${pvc.namespace}/${pvc.name}`;
-    try {
-      await mkdir(target, { recursive: true });
-    } catch (err) {
-      console.error(err);
-    }
+    await mkdir(target, { recursive: true });
     const resourceService = this.#services.get(ResourceService);
     const pv = resourceService.get<V1PersistentVolume>({
       apiVersion: 'v1',
-      kind: 'PersistentVolume',
-      name: `${pvc.namespace}-${pvc.name}`,
+      kind: 'PersistantVolume',
+      name: pvc.name,
+      namespace: pvc.namespace,
     });
     await pv.load();
     await pv.patch({
@@ -59,7 +50,7 @@ class StorageProvider {
           path: target,
         },
         capacity: {
-          storage: pvc.spec?.resources?.requests?.storage ?? '1Gi',
+          storage: pvc.spec?.resources?.requests?.storage ?? '1GB',
         },
         persistentVolumeReclaimPolicy: 'Retain',
         accessModes: pvc.spec?.accessModes,