support storage manager

kube-HPC · Nov 18, 2018 · 84883f2 · 84883f2
1 parent 08e1054
commit 84883f2
Showing 1 changed file with 21 additions and 0 deletions.
diff --git a/lib/adapter.js b/lib/adapter.js
@@ -24,6 +24,27 @@ class RedisAdapter {
         return this._set({ path: pathLib.join('/', pathLib.join('/', options.Path)), data: options.Data });
     }
 
+
+    async list(options) {
+        return new Promise((resolve, reject) => {
+            let keys = [];
+            const stream = client.scanStream({ match: pathLib.join('/', options.Path, '*') });
+            stream.on('data', (data) => {
+                keys = keys.concat(data);
+            });
+            stream.on('end', () => {
+                return resolve(keys.map(k => ({ Path: k })));
+            });
+            stream.on('error', () => {
+                return reject();
+            });
+        });
+    }
+
+    async delete(options) {
+        return client.del(options.Path);
+    }
+
     _set(options) {
         return new Promise((resolve, reject) => {
             const { data, path } = options;