Skip to content

Commit 4263d92

Browse files
Update generated code (#1976)
update generated code
1 parent 96987fd commit 4263d92

File tree

6 files changed

+48
-5
lines changed

6 files changed

+48
-5
lines changed

manifest.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"variables": {
3-
"${LATEST}": "3.357.2"
3+
"${LATEST}": "3.358.0"
44
},
55
"endpoints": "https://raw.githubusercontent.com/aws/aws-sdk-php/${LATEST}/src/data/endpoints.json",
66
"services": {

src/Service/Kinesis/CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
### Added
66

77
- AWS api-change: Added `us-isob-west-1` region
8+
- AWS api-change: Adds support for record sizes up to 10MiB and introduces new UpdateMaxRecordSize API to modify stream record size limits. Adds record size parameters to existing CreateStream and DescribeStreamSummary APIs for request and response payloads respectively.
89

910
### Dependency bumped
1011

src/Service/Kinesis/src/Input/CreateStreamInput.php

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,12 +48,20 @@ final class CreateStreamInput extends Input
4848
*/
4949
private $tags;
5050

51+
/**
52+
* The maximum record size of a single record in kibibyte (KiB) that you can write to, and read from a stream.
53+
*
54+
* @var int|null
55+
*/
56+
private $maxRecordSizeInKiB;
57+
5158
/**
5259
* @param array{
5360
* StreamName?: string,
5461
* ShardCount?: int|null,
5562
* StreamModeDetails?: StreamModeDetails|array|null,
5663
* Tags?: array<string, string>|null,
64+
* MaxRecordSizeInKiB?: int|null,
5765
* '@region'?: string|null,
5866
* } $input
5967
*/
@@ -63,6 +71,7 @@ public function __construct(array $input = [])
6371
$this->shardCount = $input['ShardCount'] ?? null;
6472
$this->streamModeDetails = isset($input['StreamModeDetails']) ? StreamModeDetails::create($input['StreamModeDetails']) : null;
6573
$this->tags = $input['Tags'] ?? null;
74+
$this->maxRecordSizeInKiB = $input['MaxRecordSizeInKiB'] ?? null;
6675
parent::__construct($input);
6776
}
6877

@@ -72,6 +81,7 @@ public function __construct(array $input = [])
7281
* ShardCount?: int|null,
7382
* StreamModeDetails?: StreamModeDetails|array|null,
7483
* Tags?: array<string, string>|null,
84+
* MaxRecordSizeInKiB?: int|null,
7585
* '@region'?: string|null,
7686
* }|CreateStreamInput $input
7787
*/
@@ -80,6 +90,11 @@ public static function create($input): self
8090
return $input instanceof self ? $input : new self($input);
8191
}
8292

93+
public function getMaxRecordSizeInKiB(): ?int
94+
{
95+
return $this->maxRecordSizeInKiB;
96+
}
97+
8398
public function getShardCount(): ?int
8499
{
85100
return $this->shardCount;
@@ -129,6 +144,13 @@ public function request(): Request
129144
return new Request('POST', $uriString, $query, $headers, StreamFactory::create($body));
130145
}
131146

147+
public function setMaxRecordSizeInKiB(?int $value): self
148+
{
149+
$this->maxRecordSizeInKiB = $value;
150+
151+
return $this;
152+
}
153+
132154
public function setShardCount(?int $value): self
133155
{
134156
$this->shardCount = $value;
@@ -183,6 +205,9 @@ private function requestBody(): array
183205
}
184206
}
185207
}
208+
if (null !== $v = $this->maxRecordSizeInKiB) {
209+
$payload['MaxRecordSizeInKiB'] = $v;
210+
}
186211

187212
return $payload;
188213
}

src/Service/Kinesis/src/KinesisClient.php

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,7 @@ public function addTagsToStream($input): Result
169169
* ShardCount?: int|null,
170170
* StreamModeDetails?: StreamModeDetails|array|null,
171171
* Tags?: array<string, string>|null,
172+
* MaxRecordSizeInKiB?: int|null,
172173
* '@region'?: string|null,
173174
* }|CreateStreamInput $input
174175
*
@@ -989,7 +990,7 @@ public function mergeShards($input): Result
989990
/**
990991
* Writes a single data record into an Amazon Kinesis data stream. Call `PutRecord` to send data into the stream for
991992
* real-time ingestion and subsequent processing, one record at a time. Each shard can support writes up to 1,000
992-
* records per second, up to a maximum data write total of 1 MiB per second.
993+
* records per second, up to a maximum data write total of 10 MiB per second.
993994
*
994995
* > When invoking this API, you must use either the `StreamARN` or the `StreamName` parameter, or both. It is
995996
* > recommended that you use the `StreamARN` input parameter when you invoke this API.
@@ -1081,9 +1082,9 @@ public function putRecord($input): PutRecordOutput
10811082
* > When invoking this API, you must use either the `StreamARN` or the `StreamName` parameter, or both. It is
10821083
* > recommended that you use the `StreamARN` input parameter when you invoke this API.
10831084
*
1084-
* Each `PutRecords` request can support up to 500 records. Each record in the request can be as large as 1 MiB, up to a
1085-
* limit of 5 MiB for the entire request, including partition keys. Each shard can support writes up to 1,000 records
1086-
* per second, up to a maximum data write total of 1 MiB per second.
1085+
* Each `PutRecords` request can support up to 500 records. Each record in the request can be as large as 10 MiB, up to
1086+
* a limit of 10 MiB for the entire request, including partition keys. Each shard can support writes up to 1,000 records
1087+
* per second, up to a maximum data write total of 1 MB per second.
10871088
*
10881089
* You must specify the name of the stream that captures, stores, and transports the data; and an array of request
10891090
* `Records`, with each record in the array requiring a partition key and data blob. The record size limit applies to

src/Service/Kinesis/src/Result/DescribeStreamSummaryOutput.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,6 +82,7 @@ private function populateResultStreamDescriptionSummary(array $json): StreamDesc
8282
'KeyId' => isset($json['KeyId']) ? (string) $json['KeyId'] : null,
8383
'OpenShardCount' => (int) $json['OpenShardCount'],
8484
'ConsumerCount' => isset($json['ConsumerCount']) ? (int) $json['ConsumerCount'] : null,
85+
'MaxRecordSizeInKiB' => isset($json['MaxRecordSizeInKiB']) ? (int) $json['MaxRecordSizeInKiB'] : null,
8586
]);
8687
}
8788

src/Service/Kinesis/src/ValueObject/StreamDescriptionSummary.php

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,13 @@ final class StreamDescriptionSummary
109109
*/
110110
private $consumerCount;
111111

112+
/**
113+
* The maximum record size of a single record in kibibyte (KiB) that you can write to, and read from a stream.
114+
*
115+
* @var int|null
116+
*/
117+
private $maxRecordSizeInKiB;
118+
112119
/**
113120
* @param array{
114121
* StreamName: string,
@@ -122,6 +129,7 @@ final class StreamDescriptionSummary
122129
* KeyId?: string|null,
123130
* OpenShardCount: int,
124131
* ConsumerCount?: int|null,
132+
* MaxRecordSizeInKiB?: int|null,
125133
* } $input
126134
*/
127135
public function __construct(array $input)
@@ -137,6 +145,7 @@ public function __construct(array $input)
137145
$this->keyId = $input['KeyId'] ?? null;
138146
$this->openShardCount = $input['OpenShardCount'] ?? $this->throwException(new InvalidArgument('Missing required field "OpenShardCount".'));
139147
$this->consumerCount = $input['ConsumerCount'] ?? null;
148+
$this->maxRecordSizeInKiB = $input['MaxRecordSizeInKiB'] ?? null;
140149
}
141150

142151
/**
@@ -152,6 +161,7 @@ public function __construct(array $input)
152161
* KeyId?: string|null,
153162
* OpenShardCount: int,
154163
* ConsumerCount?: int|null,
164+
* MaxRecordSizeInKiB?: int|null,
155165
* }|StreamDescriptionSummary $input
156166
*/
157167
public static function create($input): self
@@ -185,6 +195,11 @@ public function getKeyId(): ?string
185195
return $this->keyId;
186196
}
187197

198+
public function getMaxRecordSizeInKiB(): ?int
199+
{
200+
return $this->maxRecordSizeInKiB;
201+
}
202+
188203
public function getOpenShardCount(): int
189204
{
190205
return $this->openShardCount;

0 commit comments

Comments
 (0)