async-aws · jderusse · Nov 14, 2024 · Nov 14, 2024
diff --git a/manifest.json b/manifest.json
@@ -1,6 +1,6 @@
 {
     "variables": {
-        "${LATEST}": "3.325.7"
+        "${LATEST}": "3.326.0"
     },
     "endpoints": "https://raw.githubusercontent.com/aws/aws-sdk-php/${LATEST}/src/data/endpoints.json",
     "services": {

diff --git a/src/Service/DynamoDb/CHANGELOG.md b/src/Service/DynamoDb/CHANGELOG.md
@@ -2,6 +2,10 @@
 
 ## NOT RELEASED
 
+### Added
+
+- AWS api-change: This release includes supports the new WarmThroughput feature for DynamoDB. You can now provide an optional WarmThroughput attribute for CreateTable or UpdateTable APIs to pre-warm your table or global secondary index. You can also use DescribeTable to see the latest WarmThroughput value.
+
 ### Changed
 
 - use strict comparison `null !==` instead of `!`

diff --git a/src/Service/DynamoDb/composer.json b/src/Service/DynamoDb/composer.json
@@ -32,7 +32,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-master": "3.2-dev"
+            "dev-master": "3.3-dev"
         }
     }
 }
diff --git a/src/Service/DynamoDb/src/DynamoDbClient.php b/src/Service/DynamoDb/src/DynamoDbClient.php
@@ -82,6 +82,7 @@
 use AsyncAws\DynamoDb\ValueObject\Tag;
 use AsyncAws\DynamoDb\ValueObject\TimeToLiveSpecification;
 use AsyncAws\DynamoDb\ValueObject\TransactWriteItem;
+use AsyncAws\DynamoDb\ValueObject\WarmThroughput;
 
 class DynamoDbClient extends AbstractApi
 {
@@ -284,6 +285,7 @@ public function batchWriteItem($input): BatchWriteItemOutput
      *   Tags?: null|array<Tag|array>,
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
+     *   WarmThroughput?: null|WarmThroughput|array,
      *   ResourcePolicy?: null|string,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
      *   '@region'?: string|null,
@@ -1000,6 +1002,7 @@ public function updateItem($input): UpdateItemOutput
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
+     *   WarmThroughput?: null|WarmThroughput|array,
      *   '@region'?: string|null,
      * }|UpdateTableInput $input
      *

diff --git a/src/Service/DynamoDb/src/Input/CreateTableInput.php b/src/Service/DynamoDb/src/Input/CreateTableInput.php
@@ -21,6 +21,7 @@
 use AsyncAws\DynamoDb\ValueObject\SSESpecification;
 use AsyncAws\DynamoDb\ValueObject\StreamSpecification;
 use AsyncAws\DynamoDb\ValueObject\Tag;
+use AsyncAws\DynamoDb\ValueObject\WarmThroughput;
 
 /**
  * Represents the input of a `CreateTable` operation.
@@ -219,6 +220,13 @@ final class CreateTableInput extends Input
      */
     private $deletionProtectionEnabled;
 
+    /**
+     * Represents the warm throughput (in read units per second and write units per second) for creating a table.
+     *
+     * @var WarmThroughput|null
+     */
+    private $warmThroughput;
+
     /**
      * An Amazon Web Services resource-based policy document in JSON format that will be attached to the table.
      *
@@ -259,6 +267,7 @@ final class CreateTableInput extends Input
      *   Tags?: null|array<Tag|array>,
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
+     *   WarmThroughput?: null|WarmThroughput|array,
      *   ResourcePolicy?: null|string,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
      *   '@region'?: string|null,
@@ -278,6 +287,7 @@ public function __construct(array $input = [])
         $this->tags = isset($input['Tags']) ? array_map([Tag::class, 'create'], $input['Tags']) : null;
         $this->tableClass = $input['TableClass'] ?? null;
         $this->deletionProtectionEnabled = $input['DeletionProtectionEnabled'] ?? null;
+        $this->warmThroughput = isset($input['WarmThroughput']) ? WarmThroughput::create($input['WarmThroughput']) : null;
         $this->resourcePolicy = $input['ResourcePolicy'] ?? null;
         $this->onDemandThroughput = isset($input['OnDemandThroughput']) ? OnDemandThroughput::create($input['OnDemandThroughput']) : null;
         parent::__construct($input);
@@ -297,6 +307,7 @@ public function __construct(array $input = [])
      *   Tags?: null|array<Tag|array>,
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
+     *   WarmThroughput?: null|WarmThroughput|array,
      *   ResourcePolicy?: null|string,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
      *   '@region'?: string|null,
@@ -398,6 +409,11 @@ public function getTags(): array
         return $this->tags ?? [];
     }
 
+    public function getWarmThroughput(): ?WarmThroughput
+    {
+        return $this->warmThroughput;
+    }
+
     /**
      * @internal
      */
@@ -543,6 +559,13 @@ public function setTags(array $value): self
         return $this;
     }
 
+    public function setWarmThroughput(?WarmThroughput $value): self
+    {
+        $this->warmThroughput = $value;
+
+        return $this;
+    }
+
     private function requestBody(): array
     {
         $payload = [];
@@ -620,6 +643,9 @@ private function requestBody(): array
         if (null !== $v = $this->deletionProtectionEnabled) {
             $payload['DeletionProtectionEnabled'] = (bool) $v;
         }
+        if (null !== $v = $this->warmThroughput) {
+            $payload['WarmThroughput'] = $v->requestBody();
+        }
         if (null !== $v = $this->resourcePolicy) {
             $payload['ResourcePolicy'] = $v;
         }

diff --git a/src/Service/DynamoDb/src/Input/UpdateTableInput.php b/src/Service/DynamoDb/src/Input/UpdateTableInput.php
@@ -15,6 +15,7 @@
 use AsyncAws\DynamoDb\ValueObject\ReplicationGroupUpdate;
 use AsyncAws\DynamoDb\ValueObject\SSESpecification;
 use AsyncAws\DynamoDb\ValueObject\StreamSpecification;
+use AsyncAws\DynamoDb\ValueObject\WarmThroughput;
 
 /**
  * Represents the input of an `UpdateTable` operation.
@@ -130,6 +131,13 @@ final class UpdateTableInput extends Input
      */
     private $onDemandThroughput;
 
+    /**
+     * Represents the warm throughput (in read units per second and write units per second) for updating a table.
+     *
+     * @var WarmThroughput|null
+     */
+    private $warmThroughput;
+
     /**
      * @param array{
      *   AttributeDefinitions?: null|array<AttributeDefinition|array>,
@@ -143,6 +151,7 @@ final class UpdateTableInput extends Input
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
+     *   WarmThroughput?: null|WarmThroughput|array,
      *   '@region'?: string|null,
      * } $input
      */
@@ -159,6 +168,7 @@ public function __construct(array $input = [])
         $this->tableClass = $input['TableClass'] ?? null;
         $this->deletionProtectionEnabled = $input['DeletionProtectionEnabled'] ?? null;
         $this->onDemandThroughput = isset($input['OnDemandThroughput']) ? OnDemandThroughput::create($input['OnDemandThroughput']) : null;
+        $this->warmThroughput = isset($input['WarmThroughput']) ? WarmThroughput::create($input['WarmThroughput']) : null;
         parent::__construct($input);
     }
 
@@ -175,6 +185,7 @@ public function __construct(array $input = [])
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
+     *   WarmThroughput?: null|WarmThroughput|array,
      *   '@region'?: string|null,
      * }|UpdateTableInput $input
      */
@@ -253,6 +264,11 @@ public function getTableName(): ?string
         return $this->tableName;
     }
 
+    public function getWarmThroughput(): ?WarmThroughput
+    {
+        return $this->warmThroughput;
+    }
+
     /**
      * @internal
      */
@@ -371,6 +387,13 @@ public function setTableName(?string $value): self
         return $this;
     }
 
+    public function setWarmThroughput(?WarmThroughput $value): self
+    {
+        $this->warmThroughput = $value;
+
+        return $this;
+    }
+
     private function requestBody(): array
     {
         $payload = [];
@@ -429,6 +452,9 @@ private function requestBody(): array
         if (null !== $v = $this->onDemandThroughput) {
             $payload['OnDemandThroughput'] = $v->requestBody();
         }
+        if (null !== $v = $this->warmThroughput) {
+            $payload['WarmThroughput'] = $v->requestBody();
+        }
 
         return $payload;
     }

diff --git a/src/Service/DynamoDb/src/Result/CreateTableOutput.php b/src/Service/DynamoDb/src/Result/CreateTableOutput.php
@@ -8,6 +8,7 @@
 use AsyncAws\DynamoDb\ValueObject\AttributeDefinition;
 use AsyncAws\DynamoDb\ValueObject\BillingModeSummary;
 use AsyncAws\DynamoDb\ValueObject\GlobalSecondaryIndexDescription;
+use AsyncAws\DynamoDb\ValueObject\GlobalSecondaryIndexWarmThroughputDescription;
 use AsyncAws\DynamoDb\ValueObject\KeySchemaElement;
 use AsyncAws\DynamoDb\ValueObject\LocalSecondaryIndexDescription;
 use AsyncAws\DynamoDb\ValueObject\OnDemandThroughput;
@@ -22,6 +23,7 @@
 use AsyncAws\DynamoDb\ValueObject\StreamSpecification;
 use AsyncAws\DynamoDb\ValueObject\TableClassSummary;
 use AsyncAws\DynamoDb\ValueObject\TableDescription;
+use AsyncAws\DynamoDb\ValueObject\TableWarmThroughputDescription;
 
 /**
  * Represents the output of a `CreateTable` operation.
@@ -100,6 +102,7 @@ private function populateResultGlobalSecondaryIndexDescription(array $json): Glo
             'ItemCount' => isset($json['ItemCount']) ? (int) $json['ItemCount'] : null,
             'IndexArn' => isset($json['IndexArn']) ? (string) $json['IndexArn'] : null,
             'OnDemandThroughput' => empty($json['OnDemandThroughput']) ? null : $this->populateResultOnDemandThroughput($json['OnDemandThroughput']),
+            'WarmThroughput' => empty($json['WarmThroughput']) ? null : $this->populateResultGlobalSecondaryIndexWarmThroughputDescription($json['WarmThroughput']),
         ]);
     }
 
@@ -116,6 +119,15 @@ private function populateResultGlobalSecondaryIndexDescriptionList(array $json):
         return $items;
     }
 
+    private function populateResultGlobalSecondaryIndexWarmThroughputDescription(array $json): GlobalSecondaryIndexWarmThroughputDescription
+    {
+        return new GlobalSecondaryIndexWarmThroughputDescription([
+            'ReadUnitsPerSecond' => isset($json['ReadUnitsPerSecond']) ? (int) $json['ReadUnitsPerSecond'] : null,
+            'WriteUnitsPerSecond' => isset($json['WriteUnitsPerSecond']) ? (int) $json['WriteUnitsPerSecond'] : null,
+            'Status' => isset($json['Status']) ? (string) $json['Status'] : null,
+        ]);
+    }
+
     /**
      * @return KeySchemaElement[]
      */
@@ -229,6 +241,7 @@ private function populateResultReplicaDescription(array $json): ReplicaDescripti
             'KMSMasterKeyId' => isset($json['KMSMasterKeyId']) ? (string) $json['KMSMasterKeyId'] : null,
             'ProvisionedThroughputOverride' => empty($json['ProvisionedThroughputOverride']) ? null : $this->populateResultProvisionedThroughputOverride($json['ProvisionedThroughputOverride']),
             'OnDemandThroughputOverride' => empty($json['OnDemandThroughputOverride']) ? null : $this->populateResultOnDemandThroughputOverride($json['OnDemandThroughputOverride']),
+            'WarmThroughput' => empty($json['WarmThroughput']) ? null : $this->populateResultTableWarmThroughputDescription($json['WarmThroughput']),
             'GlobalSecondaryIndexes' => !isset($json['GlobalSecondaryIndexes']) ? null : $this->populateResultReplicaGlobalSecondaryIndexDescriptionList($json['GlobalSecondaryIndexes']),
             'ReplicaInaccessibleDateTime' => (isset($json['ReplicaInaccessibleDateTime']) && ($d = \DateTimeImmutable::createFromFormat('U.u', \sprintf('%.6F', $json['ReplicaInaccessibleDateTime'])))) ? $d : null,
             'ReplicaTableClassSummary' => empty($json['ReplicaTableClassSummary']) ? null : $this->populateResultTableClassSummary($json['ReplicaTableClassSummary']),
@@ -254,6 +267,7 @@ private function populateResultReplicaGlobalSecondaryIndexDescription(array $jso
             'IndexName' => isset($json['IndexName']) ? (string) $json['IndexName'] : null,
             'ProvisionedThroughputOverride' => empty($json['ProvisionedThroughputOverride']) ? null : $this->populateResultProvisionedThroughputOverride($json['ProvisionedThroughputOverride']),
             'OnDemandThroughputOverride' => empty($json['OnDemandThroughputOverride']) ? null : $this->populateResultOnDemandThroughputOverride($json['OnDemandThroughputOverride']),
+            'WarmThroughput' => empty($json['WarmThroughput']) ? null : $this->populateResultGlobalSecondaryIndexWarmThroughputDescription($json['WarmThroughput']),
         ]);
     }
 
@@ -333,6 +347,16 @@ private function populateResultTableDescription(array $json): TableDescription
             'TableClassSummary' => empty($json['TableClassSummary']) ? null : $this->populateResultTableClassSummary($json['TableClassSummary']),
             'DeletionProtectionEnabled' => isset($json['DeletionProtectionEnabled']) ? filter_var($json['DeletionProtectionEnabled'], \FILTER_VALIDATE_BOOLEAN) : null,
             'OnDemandThroughput' => empty($json['OnDemandThroughput']) ? null : $this->populateResultOnDemandThroughput($json['OnDemandThroughput']),
+            'WarmThroughput' => empty($json['WarmThroughput']) ? null : $this->populateResultTableWarmThroughputDescription($json['WarmThroughput']),
+        ]);
+    }
+
+    private function populateResultTableWarmThroughputDescription(array $json): TableWarmThroughputDescription
+    {
+        return new TableWarmThroughputDescription([
+            'ReadUnitsPerSecond' => isset($json['ReadUnitsPerSecond']) ? (int) $json['ReadUnitsPerSecond'] : null,
+            'WriteUnitsPerSecond' => isset($json['WriteUnitsPerSecond']) ? (int) $json['WriteUnitsPerSecond'] : null,
+            'Status' => isset($json['Status']) ? (string) $json['Status'] : null,
         ]);
     }
 }
diff --git a/src/Service/DynamoDb/src/Result/DeleteTableOutput.php b/src/Service/DynamoDb/src/Result/DeleteTableOutput.php
@@ -8,6 +8,7 @@
 use AsyncAws\DynamoDb\ValueObject\AttributeDefinition;
 use AsyncAws\DynamoDb\ValueObject\BillingModeSummary;
 use AsyncAws\DynamoDb\ValueObject\GlobalSecondaryIndexDescription;
+use AsyncAws\DynamoDb\ValueObject\GlobalSecondaryIndexWarmThroughputDescription;
 use AsyncAws\DynamoDb\ValueObject\KeySchemaElement;
 use AsyncAws\DynamoDb\ValueObject\LocalSecondaryIndexDescription;
 use AsyncAws\DynamoDb\ValueObject\OnDemandThroughput;
@@ -22,6 +23,7 @@
 use AsyncAws\DynamoDb\ValueObject\StreamSpecification;
 use AsyncAws\DynamoDb\ValueObject\TableClassSummary;
 use AsyncAws\DynamoDb\ValueObject\TableDescription;
+use AsyncAws\DynamoDb\ValueObject\TableWarmThroughputDescription;
 
 /**
  * Represents the output of a `DeleteTable` operation.
@@ -100,6 +102,7 @@ private function populateResultGlobalSecondaryIndexDescription(array $json): Glo
             'ItemCount' => isset($json['ItemCount']) ? (int) $json['ItemCount'] : null,
             'IndexArn' => isset($json['IndexArn']) ? (string) $json['IndexArn'] : null,
             'OnDemandThroughput' => empty($json['OnDemandThroughput']) ? null : $this->populateResultOnDemandThroughput($json['OnDemandThroughput']),
+            'WarmThroughput' => empty($json['WarmThroughput']) ? null : $this->populateResultGlobalSecondaryIndexWarmThroughputDescription($json['WarmThroughput']),
         ]);
     }
 
@@ -116,6 +119,15 @@ private function populateResultGlobalSecondaryIndexDescriptionList(array $json):
         return $items;
     }
 
+    private function populateResultGlobalSecondaryIndexWarmThroughputDescription(array $json): GlobalSecondaryIndexWarmThroughputDescription
+    {
+        return new GlobalSecondaryIndexWarmThroughputDescription([
+            'ReadUnitsPerSecond' => isset($json['ReadUnitsPerSecond']) ? (int) $json['ReadUnitsPerSecond'] : null,
+            'WriteUnitsPerSecond' => isset($json['WriteUnitsPerSecond']) ? (int) $json['WriteUnitsPerSecond'] : null,
+            'Status' => isset($json['Status']) ? (string) $json['Status'] : null,
+        ]);
+    }
+
     /**
      * @return KeySchemaElement[]
      */
@@ -229,6 +241,7 @@ private function populateResultReplicaDescription(array $json): ReplicaDescripti
             'KMSMasterKeyId' => isset($json['KMSMasterKeyId']) ? (string) $json['KMSMasterKeyId'] : null,
             'ProvisionedThroughputOverride' => empty($json['ProvisionedThroughputOverride']) ? null : $this->populateResultProvisionedThroughputOverride($json['ProvisionedThroughputOverride']),
             'OnDemandThroughputOverride' => empty($json['OnDemandThroughputOverride']) ? null : $this->populateResultOnDemandThroughputOverride($json['OnDemandThroughputOverride']),
+            'WarmThroughput' => empty($json['WarmThroughput']) ? null : $this->populateResultTableWarmThroughputDescription($json['WarmThroughput']),
             'GlobalSecondaryIndexes' => !isset($json['GlobalSecondaryIndexes']) ? null : $this->populateResultReplicaGlobalSecondaryIndexDescriptionList($json['GlobalSecondaryIndexes']),
             'ReplicaInaccessibleDateTime' => (isset($json['ReplicaInaccessibleDateTime']) && ($d = \DateTimeImmutable::createFromFormat('U.u', \sprintf('%.6F', $json['ReplicaInaccessibleDateTime'])))) ? $d : null,
             'ReplicaTableClassSummary' => empty($json['ReplicaTableClassSummary']) ? null : $this->populateResultTableClassSummary($json['ReplicaTableClassSummary']),
@@ -254,6 +267,7 @@ private function populateResultReplicaGlobalSecondaryIndexDescription(array $jso
             'IndexName' => isset($json['IndexName']) ? (string) $json['IndexName'] : null,
             'ProvisionedThroughputOverride' => empty($json['ProvisionedThroughputOverride']) ? null : $this->populateResultProvisionedThroughputOverride($json['ProvisionedThroughputOverride']),
             'OnDemandThroughputOverride' => empty($json['OnDemandThroughputOverride']) ? null : $this->populateResultOnDemandThroughputOverride($json['OnDemandThroughputOverride']),
+            'WarmThroughput' => empty($json['WarmThroughput']) ? null : $this->populateResultGlobalSecondaryIndexWarmThroughputDescription($json['WarmThroughput']),
         ]);
     }
 
@@ -333,6 +347,16 @@ private function populateResultTableDescription(array $json): TableDescription
             'TableClassSummary' => empty($json['TableClassSummary']) ? null : $this->populateResultTableClassSummary($json['TableClassSummary']),
             'DeletionProtectionEnabled' => isset($json['DeletionProtectionEnabled']) ? filter_var($json['DeletionProtectionEnabled'], \FILTER_VALIDATE_BOOLEAN) : null,
             'OnDemandThroughput' => empty($json['OnDemandThroughput']) ? null : $this->populateResultOnDemandThroughput($json['OnDemandThroughput']),
+            'WarmThroughput' => empty($json['WarmThroughput']) ? null : $this->populateResultTableWarmThroughputDescription($json['WarmThroughput']),
+        ]);
+    }
+
+    private function populateResultTableWarmThroughputDescription(array $json): TableWarmThroughputDescription
+    {
+        return new TableWarmThroughputDescription([
+            'ReadUnitsPerSecond' => isset($json['ReadUnitsPerSecond']) ? (int) $json['ReadUnitsPerSecond'] : null,
+            'WriteUnitsPerSecond' => isset($json['WriteUnitsPerSecond']) ? (int) $json['WriteUnitsPerSecond'] : null,
+            'Status' => isset($json['Status']) ? (string) $json['Status'] : null,
         ]);
     }
 }