add storageclass dropdown

Author: mms-gianni

client/src/components/apps/new.vue

@@ -368,16 +368,6 @@
 
       <v-divider class="ma-5"></v-divider>
       <!-- EXTRAVOLUMES -->
-
-      <!--
-#  - name: "test-volume"
-#    emptyDir: false
-#    storageClass: "standard"
-#    size: "1Gi"
-#    accessModes:
-#      - "ReadWriteMany"
-#    mountPath: "/test-volume"
-      -->
       <h4 class="text-uppercase">Volumes</h4>
       <div v-for="volume in extraVolumes" v-bind:key="volume.id">
         <v-row>
@@ -422,10 +412,11 @@
             cols="12"
             md="3"
           >
-            <v-text-field
+            <v-select
               v-model="volume.storageClass"
+              :items="storageclasses"
               label="Storage Class"
-            ></v-text-field>
+            ></v-select>
           </v-col>
           <v-col
             cols="12"
@@ -705,6 +696,12 @@ export default {
         },
         */
       ],
+      storageclasses : [
+/*
+        'standard',
+        'standard-fast',
+*/
+      ],
       extraVolumes: [
         /*
         {
@@ -762,6 +759,7 @@ export default {
       }
     },
     mounted() {
+      this.loadStorageClasses();
       this.loadPipeline();
       this.loadPodsizeList();
       this.loadApp(); // this may lead into a race condition with the buildpacks loaded in loadPipeline
@@ -805,6 +803,13 @@ export default {
 
         });
       },
+      loadStorageClasses() {
+        axios.get('/api/config/storageclasses').then(response => {
+          for (let i = 0; i < response.data.length; i++) {
+            this.storageclasses.push(response.data[i].name);
+          }
+        });
+      },
       loadBranches() {
 
         // encode string to base64 (for ssh url)

src/kubero.ts

@@ -704,4 +704,8 @@ export class Kubero {
     public getNodeMetrics() {
         return this.kubectl.getNodeMetrics();
     }
+
+    public getStorageglasses() {
+        return this.kubectl.getStorageglasses();
+    }
 }

src/modules/kubectl.ts

@@ -21,6 +21,7 @@ import {
     PodMetric,
     PodMetricsList,
     NodeMetric,
+    StorageV1Api
 } from '@kubernetes/client-node'
 import { IPipeline, IKubectlPipeline, IKubectlPipelineList, IKubectlAppList, IKuberoConfig} from '../types';
 import { App, KubectlApp } from './application';
@@ -34,6 +35,7 @@ export class Kubectl {
     private coreV1Api: CoreV1Api;
     private appsV1Api: AppsV1Api;
     private metricsApi: Metrics;
+    private storageV1Api: StorageV1Api;
     private customObjectsApi: CustomObjectsApi;
     private kubeVersion: VersionInfo | void;
     private patchUtils: PatchUtils;
@@ -66,6 +68,7 @@ export class Kubectl {
         this.versionApi = this.kc.makeApiClient(VersionApi);
         this.coreV1Api = this.kc.makeApiClient(CoreV1Api);
         this.appsV1Api = this.kc.makeApiClient(AppsV1Api);
+        this.storageV1Api = this.kc.makeApiClient(StorageV1Api);
         this.metricsApi = new Metrics(this.kc);
         this.patchUtils = new PatchUtils();
         this.customObjectsApi = this.kc.makeApiClient(CustomObjectsApi);
@@ -491,4 +494,22 @@ export class Kubectl {
         const metrics = await this.metricsApi.getNodeMetrics();
         return metrics.items;
     }
+
+    public async getStorageglasses(): Promise<Object[]> {
+        const storageClasses = await this.storageV1Api.listStorageClass();
+        let ret = [];
+        for (let i = 0; i < storageClasses.body.items.length; i++) {
+            const sc = storageClasses.body.items[i];
+            const storageClass = {
+                name: sc.metadata?.name,
+                provisioner: sc.provisioner,
+                reclaimPolicy: sc.reclaimPolicy,
+                volumeBindingMode: sc.volumeBindingMode,
+                //allowVolumeExpansion: sc.allowVolumeExpansion,
+                //parameters: sc.parameters
+            }
+            ret.push(storageClass);
+        }
+        return ret;
+    }
 }

src/routes/config.ts

@@ -99,3 +99,10 @@ Router.get('/config/repositories', authMiddleware, async function (req: Request,
     // #swagger.summary = 'Get the available repositories'
     res.send(await req.app.locals.kubero.getRepositories());
 });
+
+
+Router.get('/config/storageclasses', authMiddleware, async function (req: Request, res: Response) {
+    // #swagger.tags = ['UI']
+    // #swagger.summary = 'Get the available storageclasses'
+    res.send(await req.app.locals.kubero.getStorageglasses());
+});