recert namespace changes

Author: naveenpaul1

src/agent/block_store_services/block_store_s3.js

@@ -77,7 +77,7 @@ class BlockStoreS3 extends BlockStoreBase {
     async init() {
         try {
             if (this.cloud_info.aws_sts_arn) {
-                this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+                this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
             }
             const res = await this.s3cloud.getObject({
                 Bucket: this.cloud_info.target_bucket,
@@ -104,7 +104,7 @@ class BlockStoreS3 extends BlockStoreBase {
 
     async _read_block_md(block_md) {
         if (this.cloud_info.aws_sts_arn) {
-            this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+            this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
         }
         const res = await this.s3cloud.headObject({
             Bucket: this.cloud_info.target_bucket,
@@ -162,7 +162,7 @@ class BlockStoreS3 extends BlockStoreBase {
     async _read_block(block_md) {
         try {
             if (this.cloud_info.aws_sts_arn) {
-                this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+                this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
             }
             const res = await this.s3cloud.getObject({
                 Bucket: this.cloud_info.target_bucket,
@@ -189,7 +189,7 @@ class BlockStoreS3 extends BlockStoreBase {
             const encoded_md = this.disable_metadata ? '' : this._encode_block_md(block_md);
             dbg.log3('writing block id to cloud:', block_key);
             if (this.cloud_info.aws_sts_arn) {
-                this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+                this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
             }
             await this.s3cloud.putObject({
                 Bucket: this.cloud_info.target_bucket,
@@ -236,7 +236,7 @@ class BlockStoreS3 extends BlockStoreBase {
     async _write_usage_internal() {
         const usage_data = this._encode_block_md(this._usage);
         if (this.cloud_info.aws_sts_arn) {
-            this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+            this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
         }
         const res = await this.s3cloud.putObject({
             Bucket: this.cloud_info.target_bucket,
@@ -259,7 +259,7 @@ class BlockStoreS3 extends BlockStoreBase {
             const endpoint = this.cloud_info.endpoint;
             if (cloud_utils.is_aws_endpoint(endpoint)) {
                 if (this.cloud_info.aws_sts_arn) {
-                    this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+                    this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
                 }
                 // in s3 there is no error for non-existing object
                 await this.s3cloud.deleteObjectTagging({
@@ -303,7 +303,7 @@ class BlockStoreS3 extends BlockStoreBase {
         let key_marker;
         let version_marker;
         if (this.cloud_info.aws_sts_arn) {
-            this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+            this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
         }
         while (is_truncated) {
             const res = await this.s3cloud.listObjectVersions({
@@ -339,7 +339,7 @@ class BlockStoreS3 extends BlockStoreBase {
             let version_marker;
             dbg.log0(`cleaning up all objects with prefix ${this.base_path}`);
             if (this.cloud_info.aws_sts_arn) {
-                this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+                this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
             }
             while (!done) {
                 const list_res = await this.s3cloud.listObjectVersions({
@@ -381,7 +381,7 @@ class BlockStoreS3 extends BlockStoreBase {
         // Todo: Assuming that all requested blocks were deleted, which a bit naive
         try {
             if (this.cloud_info.aws_sts_arn) {
-                this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+                this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
             }
             const usage = await this._get_blocks_usage(block_ids);
             deleted_storage.size -= usage.size;
@@ -419,7 +419,7 @@ class BlockStoreS3 extends BlockStoreBase {
         await P.map_with_concurrency(10, block_ids, async block_id => {
             try {
                 if (this.cloud_info.aws_sts_arn) {
-                    this.s3cloud = await cloud_utils.createSTSS3Client(this.cloud_info, this.additionalS3Params);
+                    this.s3cloud = await cloud_utils.createSTSS3SDKv3Client(this.cloud_info, this.additionalS3Params);
                 }
                 const res = await this.s3cloud.headObject({
                     Bucket: this.cloud_info.target_bucket,