Update generated code (#1813)

update generated code
async-aws · Dec 4, 2024 · 4f4fe94 · 4f4fe94
1 parent f909f85
commit 4f4fe94
Show file tree

Hide file tree

Showing 11 changed files with 129 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,10 @@
 
 ## NOT RELEASED
 
+### Added
+
+- AWS api-change: This change adds support for global tables with multi-Region strong consistency (in preview). The UpdateTable API now supports a new attribute MultiRegionConsistency to set consistency when creating global tables. The DescribeTable output now optionally includes the MultiRegionConsistency attribute.
+
 ## 3.3.1
 
 ### Changed

diff --git a/composer.json b/composer.json
@@ -32,7 +32,7 @@
     },
     "extra": {
         "branch-alias": {
-            "dev-master": "3.3-dev"
+            "dev-master": "3.4-dev"
         }
     }
 }
diff --git a/src/DynamoDbClient.php b/src/DynamoDbClient.php
@@ -9,6 +9,7 @@
 use AsyncAws\Core\RequestContext;
 use AsyncAws\DynamoDb\Enum\BillingMode;
 use AsyncAws\DynamoDb\Enum\ConditionalOperator;
+use AsyncAws\DynamoDb\Enum\MultiRegionConsistency;
 use AsyncAws\DynamoDb\Enum\ReturnConsumedCapacity;
 use AsyncAws\DynamoDb\Enum\ReturnItemCollectionMetrics;
 use AsyncAws\DynamoDb\Enum\ReturnValue;
@@ -22,6 +23,7 @@
 use AsyncAws\DynamoDb\Exception\ItemCollectionSizeLimitExceededException;
 use AsyncAws\DynamoDb\Exception\LimitExceededException;
 use AsyncAws\DynamoDb\Exception\ProvisionedThroughputExceededException;
+use AsyncAws\DynamoDb\Exception\ReplicatedWriteConflictException;
 use AsyncAws\DynamoDb\Exception\RequestLimitExceededException;
 use AsyncAws\DynamoDb\Exception\ResourceInUseException;
 use AsyncAws\DynamoDb\Exception\ResourceNotFoundException;
@@ -345,6 +347,7 @@ public function createTable($input): CreateTableOutput
      * @throws TransactionConflictException
      * @throws RequestLimitExceededException
      * @throws InternalServerErrorException
+     * @throws ReplicatedWriteConflictException
      */
     public function deleteItem($input): DeleteItemOutput
     {
@@ -357,6 +360,7 @@ public function deleteItem($input): DeleteItemOutput
             'TransactionConflictException' => TransactionConflictException::class,
             'RequestLimitExceeded' => RequestLimitExceededException::class,
             'InternalServerError' => InternalServerErrorException::class,
+            'ReplicatedWriteConflictException' => ReplicatedWriteConflictException::class,
         ], 'usesEndpointDiscovery' => true]));
 
         return new DeleteItemOutput($response);
@@ -630,6 +634,7 @@ public function listTables($input = []): ListTablesOutput
      * @throws TransactionConflictException
      * @throws RequestLimitExceededException
      * @throws InternalServerErrorException
+     * @throws ReplicatedWriteConflictException
      */
     public function putItem($input): PutItemOutput
     {
@@ -642,6 +647,7 @@ public function putItem($input): PutItemOutput
             'TransactionConflictException' => TransactionConflictException::class,
             'RequestLimitExceeded' => RequestLimitExceededException::class,
             'InternalServerError' => InternalServerErrorException::class,
+            'ReplicatedWriteConflictException' => ReplicatedWriteConflictException::class,
         ], 'usesEndpointDiscovery' => true]));
 
         return new PutItemOutput($response);
@@ -953,6 +959,7 @@ public function transactWriteItems($input): TransactWriteItemsOutput
      * @throws TransactionConflictException
      * @throws RequestLimitExceededException
      * @throws InternalServerErrorException
+     * @throws ReplicatedWriteConflictException
      */
     public function updateItem($input): UpdateItemOutput
     {
@@ -965,6 +972,7 @@ public function updateItem($input): UpdateItemOutput
             'TransactionConflictException' => TransactionConflictException::class,
             'RequestLimitExceeded' => RequestLimitExceededException::class,
             'InternalServerError' => InternalServerErrorException::class,
+            'ReplicatedWriteConflictException' => ReplicatedWriteConflictException::class,
         ], 'usesEndpointDiscovery' => true]));
 
         return new UpdateItemOutput($response);
@@ -1001,6 +1009,7 @@ public function updateItem($input): UpdateItemOutput
      *   ReplicaUpdates?: null|array<ReplicationGroupUpdate|array>,
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
+     *   MultiRegionConsistency?: null|MultiRegionConsistency::*,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
      *   WarmThroughput?: null|WarmThroughput|array,
      *   '@region'?: string|null,

diff --git a/src/Enum/MultiRegionConsistency.php b/src/Enum/MultiRegionConsistency.php
@@ -0,0 +1,17 @@
+<?php
+
+namespace AsyncAws\DynamoDb\Enum;
+
+final class MultiRegionConsistency
+{
+    public const EVENTUAL = 'EVENTUAL';
+    public const STRONG = 'STRONG';
+
+    public static function exists(string $value): bool
+    {
+        return isset([
+            self::EVENTUAL => true,
+            self::STRONG => true,
+        ][$value]);
+    }
+}
diff --git a/src/Exception/ReplicatedWriteConflictException.php b/src/Exception/ReplicatedWriteConflictException.php
@@ -0,0 +1,12 @@
+<?php
+
+namespace AsyncAws\DynamoDb\Exception;
+
+use AsyncAws\Core\Exception\Http\ClientException;
+
+/**
+ * The request was rejected because one or more items in the request are being modified by a request in another Region.
+ */
+final class ReplicatedWriteConflictException extends ClientException
+{
+}
diff --git a/src/Input/UpdateTableInput.php b/src/Input/UpdateTableInput.php
@@ -7,6 +7,7 @@
 use AsyncAws\Core\Request;
 use AsyncAws\Core\Stream\StreamFactory;
 use AsyncAws\DynamoDb\Enum\BillingMode;
+use AsyncAws\DynamoDb\Enum\MultiRegionConsistency;
 use AsyncAws\DynamoDb\Enum\TableClass;
 use AsyncAws\DynamoDb\ValueObject\AttributeDefinition;
 use AsyncAws\DynamoDb\ValueObject\GlobalSecondaryIndexUpdate;
@@ -123,6 +124,30 @@ final class UpdateTableInput extends Input
      */
     private $deletionProtectionEnabled;
 
+    /**
+     * Specifies the consistency mode for a new global table. This parameter is only valid when you create a global table by
+     * specifying one or more Create [^1] actions in the ReplicaUpdates [^2] action list.
+     *
+     * You can specify one of the following consistency modes:
+     *
+     * - `EVENTUAL`: Configures a new global table for multi-Region eventual consistency. This is the default consistency
+     *   mode for global tables.
+     * - `STRONG`: Configures a new global table for multi-Region strong consistency (preview).
+     *
+     *   > Multi-Region strong consistency (MRSC) is a new DynamoDB global tables capability currently available in preview
+     *   > mode. For more information, see Global tables multi-Region strong consistency [^3].
+     *
+     *
+     * If you don't specify this parameter, the global table consistency mode defaults to `EVENTUAL`.
+     *
+     * [^1]: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_ReplicationGroupUpdate.html#DDB-Type-ReplicationGroupUpdate-Create
+     * [^2]: https://docs.aws.amazon.com/https:/docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateTable.html#DDB-UpdateTable-request-ReplicaUpdates
+     * [^3]: https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/PreviewFeatures.html#multi-region-strong-consistency-gt
+     *
+     * @var MultiRegionConsistency::*|null
+     */
+    private $multiRegionConsistency;
+
     /**
      * Updates the maximum number of read and write units for the specified table in on-demand capacity mode. If you use
      * this parameter, you must specify `MaxReadRequestUnits`, `MaxWriteRequestUnits`, or both.
@@ -150,6 +175,7 @@ final class UpdateTableInput extends Input
      *   ReplicaUpdates?: null|array<ReplicationGroupUpdate|array>,
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
+     *   MultiRegionConsistency?: null|MultiRegionConsistency::*,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
      *   WarmThroughput?: null|WarmThroughput|array,
      *   '@region'?: string|null,
@@ -167,6 +193,7 @@ public function __construct(array $input = [])
         $this->replicaUpdates = isset($input['ReplicaUpdates']) ? array_map([ReplicationGroupUpdate::class, 'create'], $input['ReplicaUpdates']) : null;
         $this->tableClass = $input['TableClass'] ?? null;
         $this->deletionProtectionEnabled = $input['DeletionProtectionEnabled'] ?? null;
+        $this->multiRegionConsistency = $input['MultiRegionConsistency'] ?? null;
         $this->onDemandThroughput = isset($input['OnDemandThroughput']) ? OnDemandThroughput::create($input['OnDemandThroughput']) : null;
         $this->warmThroughput = isset($input['WarmThroughput']) ? WarmThroughput::create($input['WarmThroughput']) : null;
         parent::__construct($input);
@@ -184,6 +211,7 @@ public function __construct(array $input = [])
      *   ReplicaUpdates?: null|array<ReplicationGroupUpdate|array>,
      *   TableClass?: null|TableClass::*,
      *   DeletionProtectionEnabled?: null|bool,
+     *   MultiRegionConsistency?: null|MultiRegionConsistency::*,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
      *   WarmThroughput?: null|WarmThroughput|array,
      *   '@region'?: string|null,
@@ -223,6 +251,14 @@ public function getGlobalSecondaryIndexUpdates(): array
         return $this->globalSecondaryIndexUpdates ?? [];
     }
 
+    /**
+     * @return MultiRegionConsistency::*|null
+     */
+    public function getMultiRegionConsistency(): ?string
+    {
+        return $this->multiRegionConsistency;
+    }
+
     public function getOnDemandThroughput(): ?OnDemandThroughput
     {
         return $this->onDemandThroughput;
@@ -332,6 +368,16 @@ public function setGlobalSecondaryIndexUpdates(array $value): self
         return $this;
     }
 
+    /**
+     * @param MultiRegionConsistency::*|null $value
+     */
+    public function setMultiRegionConsistency(?string $value): self
+    {
+        $this->multiRegionConsistency = $value;
+
+        return $this;
+    }
+
     public function setOnDemandThroughput(?OnDemandThroughput $value): self
     {
         $this->onDemandThroughput = $value;
@@ -449,6 +495,12 @@ private function requestBody(): array
         if (null !== $v = $this->deletionProtectionEnabled) {
             $payload['DeletionProtectionEnabled'] = (bool) $v;
         }
+        if (null !== $v = $this->multiRegionConsistency) {
+            if (!MultiRegionConsistency::exists($v)) {
+                throw new InvalidArgument(\sprintf('Invalid parameter "MultiRegionConsistency" for "%s". The value "%s" is not a valid "MultiRegionConsistency".', __CLASS__, $v));
+            }
+            $payload['MultiRegionConsistency'] = $v;
+        }
         if (null !== $v = $this->onDemandThroughput) {
             $payload['OnDemandThroughput'] = $v->requestBody();
         }

diff --git a/src/Result/CreateTableOutput.php b/src/Result/CreateTableOutput.php
@@ -348,6 +348,7 @@ private function populateResultTableDescription(array $json): TableDescription
             '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']),
+            'MultiRegionConsistency' => isset($json['MultiRegionConsistency']) ? (string) $json['MultiRegionConsistency'] : null,
         ]);
     }
 

diff --git a/src/Result/DeleteTableOutput.php b/src/Result/DeleteTableOutput.php
@@ -348,6 +348,7 @@ private function populateResultTableDescription(array $json): TableDescription
             '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']),
+            'MultiRegionConsistency' => isset($json['MultiRegionConsistency']) ? (string) $json['MultiRegionConsistency'] : null,
         ]);
     }
 

diff --git a/src/Result/DescribeTableOutput.php b/src/Result/DescribeTableOutput.php
@@ -348,6 +348,7 @@ private function populateResultTableDescription(array $json): TableDescription
             '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']),
+            'MultiRegionConsistency' => isset($json['MultiRegionConsistency']) ? (string) $json['MultiRegionConsistency'] : null,
         ]);
     }
 

diff --git a/src/Result/UpdateTableOutput.php b/src/Result/UpdateTableOutput.php
@@ -348,6 +348,7 @@ private function populateResultTableDescription(array $json): TableDescription
             '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']),
+            'MultiRegionConsistency' => isset($json['MultiRegionConsistency']) ? (string) $json['MultiRegionConsistency'] : null,
         ]);
     }
 

diff --git a/src/ValueObject/TableDescription.php b/src/ValueObject/TableDescription.php
@@ -2,6 +2,7 @@
 
 namespace AsyncAws\DynamoDb\ValueObject;
 
+use AsyncAws\DynamoDb\Enum\MultiRegionConsistency;
 use AsyncAws\DynamoDb\Enum\TableStatus;
 
 /**
@@ -308,6 +309,24 @@ final class TableDescription
      */
     private $warmThroughput;
 
+    /**
+     * Indicates one of the following consistency modes for a global table:
+     *
+     * - `EVENTUAL`: Indicates that the global table is configured for multi-Region eventual consistency.
+     * - `STRONG`: Indicates that the global table is configured for multi-Region strong consistency (preview).
+     *
+     *   > Multi-Region strong consistency (MRSC) is a new DynamoDB global tables capability currently available in preview
+     *   > mode. For more information, see Global tables multi-Region strong consistency [^1].
+     *
+     *
+     * If you don't specify this field, the global table consistency mode defaults to `EVENTUAL`.
+     *
+     * [^1]: https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/PreviewFeatures.html#multi-region-strong-consistency-gt
+     *
+     * @var MultiRegionConsistency::*|null
+     */
+    private $multiRegionConsistency;
+
     /**
      * @param array{
      *   AttributeDefinitions?: null|array<AttributeDefinition|array>,
@@ -335,6 +354,7 @@ final class TableDescription
      *   DeletionProtectionEnabled?: null|bool,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
      *   WarmThroughput?: null|TableWarmThroughputDescription|array,
+     *   MultiRegionConsistency?: null|MultiRegionConsistency::*,
      * } $input
      */
     public function __construct(array $input)
@@ -364,6 +384,7 @@ public function __construct(array $input)
         $this->deletionProtectionEnabled = $input['DeletionProtectionEnabled'] ?? null;
         $this->onDemandThroughput = isset($input['OnDemandThroughput']) ? OnDemandThroughput::create($input['OnDemandThroughput']) : null;
         $this->warmThroughput = isset($input['WarmThroughput']) ? TableWarmThroughputDescription::create($input['WarmThroughput']) : null;
+        $this->multiRegionConsistency = $input['MultiRegionConsistency'] ?? null;
     }
 
     /**
@@ -393,6 +414,7 @@ public function __construct(array $input)
      *   DeletionProtectionEnabled?: null|bool,
      *   OnDemandThroughput?: null|OnDemandThroughput|array,
      *   WarmThroughput?: null|TableWarmThroughputDescription|array,
+     *   MultiRegionConsistency?: null|MultiRegionConsistency::*,
      * }|TableDescription $input
      */
     public static function create($input): self
@@ -472,6 +494,14 @@ public function getLocalSecondaryIndexes(): array
         return $this->localSecondaryIndexes ?? [];
     }
 
+    /**
+     * @return MultiRegionConsistency::*|null
+     */
+    public function getMultiRegionConsistency(): ?string
+    {
+        return $this->multiRegionConsistency;
+    }
+
     public function getOnDemandThroughput(): ?OnDemandThroughput
     {
         return $this->onDemandThroughput;