Skip to content

Commit 203e494

Browse files
Support Amazon Kinesis Data Streams Service (#1008)
* Support Amazon Kinesis Data Streams Service * Fix tests * Regenerate servicesd Co-authored-by: Jérémy Derussé <[email protected]>
1 parent 9fa5752 commit 203e494

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

src/AwsClientFactory.php

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
use AsyncAws\Ecr\EcrClient;
2020
use AsyncAws\EventBridge\EventBridgeClient;
2121
use AsyncAws\Iam\IamClient;
22+
use AsyncAws\Kinesis\KinesisClient;
2223
use AsyncAws\Lambda\LambdaClient;
2324
use AsyncAws\RdsDataService\RdsDataServiceClient;
2425
use AsyncAws\Rekognition\RekognitionClient;
@@ -187,6 +188,19 @@ public function iam(): IamClient
187188
return $this->serviceCache[__METHOD__];
188189
}
189190

191+
public function kinesis(): KinesisClient
192+
{
193+
if (!class_exists(KinesisClient::class)) {
194+
throw MissingDependency::create('aws/kinesis', 'Kinesis');
195+
}
196+
197+
if (!isset($this->serviceCache[__METHOD__])) {
198+
$this->serviceCache[__METHOD__] = new KinesisClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger);
199+
}
200+
201+
return $this->serviceCache[__METHOD__];
202+
}
203+
190204
public function lambda(): LambdaClient
191205
{
192206
if (!class_exists(LambdaClient::class)) {

0 commit comments

Comments
 (0)