diff --git a/src/storage/gcs.js b/src/storage/gcs.js index ecd934024..5bca431c2 100644 --- a/src/storage/gcs.js +++ b/src/storage/gcs.js @@ -1,21 +1,21 @@ 'use strict'; exports = module.exports = { - getBackupPath: getBackupPath, - checkPreconditions: checkPreconditions, + getBackupPath, + checkPreconditions, - upload: upload, - download: download, - copy: copy, + upload, + download, + copy, - listDir: listDir, + listDir, - remove: remove, - removeDir: removeDir, + remove, + removeDir, - testConfig: testConfig, - removePrivateFields: removePrivateFields, - injectPrivateFields: injectPrivateFields, + testConfig, + removePrivateFields, + injectPrivateFields, // Used to mock GCS _mockInject: mockInject, @@ -212,7 +212,7 @@ function removeDir(apiConfig, pathPrefix) { var events = new EventEmitter(); - const batchSize = 1000, concurrency = 10; // https://googleapis.dev/nodejs/storage/latest/Bucket.html#deleteFiles + const batchSize = 1000, concurrency = apiConfig.deleteConcurrency || 10; // https://googleapis.dev/nodejs/storage/latest/Bucket.html#deleteFiles var total = 0; listDir(apiConfig, pathPrefix, batchSize, function (entries, done) { diff --git a/src/storage/s3.js b/src/storage/s3.js index e2bd777aa..c143e2d18 100644 --- a/src/storage/s3.js +++ b/src/storage/s3.js @@ -1,21 +1,21 @@ 'use strict'; exports = module.exports = { - getBackupPath: getBackupPath, - checkPreconditions: checkPreconditions, + getBackupPath, + checkPreconditions, - upload: upload, - download: download, - copy: copy, + upload, + download, + copy, - listDir: listDir, + listDir, - remove: remove, - removeDir: removeDir, + remove, + removeDir, - testConfig: testConfig, - removePrivateFields: removePrivateFields, - injectPrivateFields: injectPrivateFields, + testConfig, + removePrivateFields, + injectPrivateFields, // Used to mock AWS _mockInject: mockInject,