public_git
/
democratic-csi
mirror of https://github.com/democratic-csi/democratic-csi.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

use csi handle instead of name, use lodash for more robust behavior 

Signed-off-by: Travis Glenn Hansen <travisghansen@yahoo.com>
This commit is contained in:
Travis Glenn Hansen 2021-09-24 10:18:06 -06:00
parent fd85be9742
commit dd8e82b37c
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bin/k8s-csi-cleaner
View File

@ -18,6 +18,7 @@
* CSI_ENDPOINT="localhost:50051" * CSI_ENDPOINT="localhost:50051"
*/ */
const _ = require("lodash");
const k8s = require("@kubernetes/client-node"); const k8s = require("@kubernetes/client-node");
const prompt = require("prompt"); const prompt = require("prompt");
@ -43,7 +44,8 @@ var protoDescriptor = grpc.loadPackageDefinition(packageDefinition);
var csi = protoDescriptor.csi.v1; var csi = protoDescriptor.csi.v1;
//console.log(csi); //console.log(csi);
var connectionEndpoint = process.env.CSI_ENDPOINT || "unix:///csi-data/csi.sock"; var connectionEndpoint =
process.env.CSI_ENDPOINT || "unix:///csi-data/csi.sock";
var clientIdentity = new csi.Identity( var clientIdentity = new csi.Identity(
connectionEndpoint, connectionEndpoint,
@ -124,10 +126,10 @@ async function main() {
let volume_id = csiVolume.volume.volume_id; let volume_id = csiVolume.volume.volume_id;
//console.log(`processing csi volume ${volume_id}`); //console.log(`processing csi volume ${volume_id}`);
let k8sVolume = k8sVolumes.find((i_k8sVolume) => { let k8sVolume = k8sVolumes.find((i_k8sVolume) => {
return i_k8sVolume.metadata.name == volume_id; let volume_handle = _.get(i_k8sVolume, "spec.csi.volumeHandle", null);
return volume_handle == volume_id;
}); });
//let delete = false;
if (!k8sVolume) { if (!k8sVolume) {
console.log(`volume ${volume_id} is NOT in k8s`); console.log(`volume ${volume_id} is NOT in k8s`);
if (process.env.DRY_RUN == "1") { if (process.env.DRY_RUN == "1") {