amazonka-kinesis 1.6.1 → 2.0

raw patch · 129 files changed

+13594/−5836 lines, 129 filesdep +case-insensitivedep ~amazonka-coredep ~amazonka-testdep ~basesetup-changedPVP ok

version bump matches the API change (PVP)

Dependencies added: case-insensitive

Dependency ranges changed: amazonka-core, amazonka-test, base

API changes (from Hackage documentation)

Files

• README.md +3/−4
• Setup.hs +0/−2
• amazonka-kinesis.cabal +128/−97
• fixture/AddTagsToStream.yaml +10/−0
• fixture/CreateStream.yaml +10/−0
• fixture/DecreaseStreamRetentionPeriod.yaml +10/−0
• fixture/DeleteStream.yaml +10/−0
• fixture/DeregisterStreamConsumer.yaml +10/−0
• fixture/DeregisterStreamConsumerResponse.proto +0/−0
• fixture/DescribeLimits.yaml +10/−0
• fixture/DescribeStream.yaml +10/−0
• fixture/DescribeStreamConsumer.yaml +10/−0
• fixture/DescribeStreamConsumerResponse.proto +0/−0
• fixture/DisableEnhancedMonitoring.yaml +10/−0
• fixture/EnableEnhancedMonitoring.yaml +10/−0
• fixture/GetRecords.yaml +10/−0
• fixture/GetShardIterator.yaml +10/−0
• fixture/IncreaseStreamRetentionPeriod.yaml +10/−0
• fixture/ListStreamConsumers.yaml +10/−0
• fixture/ListStreamConsumersResponse.proto +0/−0
• fixture/ListStreams.yaml +10/−0
• fixture/ListTagsForStream.yaml +10/−0
• fixture/MergeShards.yaml +10/−0
• fixture/PutRecord.yaml +10/−0
• fixture/PutRecords.yaml +10/−0
• fixture/RegisterStreamConsumer.yaml +10/−0
• fixture/RegisterStreamConsumerResponse.proto +0/−0
• fixture/RemoveTagsFromStream.yaml +10/−0
• fixture/SplitShard.yaml +10/−0
• fixture/SubscribeToShard.yaml +10/−0
• fixture/SubscribeToShardResponse.proto +0/−0
• fixture/UpdateShardCount.yaml +10/−0
• fixture/UpdateStreamMode.yaml +10/−0
• fixture/UpdateStreamModeResponse.proto +0/−0
• gen/Amazonka/Kinesis.hs +421/−0
• gen/Amazonka/Kinesis/AddTagsToStream.hs +172/−0
• gen/Amazonka/Kinesis/CreateStream.hs +238/−0
• gen/Amazonka/Kinesis/DecreaseStreamRetentionPeriod.hs +194/−0
• gen/Amazonka/Kinesis/DeleteStream.hs +190/−0
• gen/Amazonka/Kinesis/DeregisterStreamConsumer.hs +197/−0
• gen/Amazonka/Kinesis/DescribeLimits.hs +202/−0
• gen/Amazonka/Kinesis/DescribeStream.hs +310/−0
• gen/Amazonka/Kinesis/DescribeStreamConsumer.hs +223/−0
• gen/Amazonka/Kinesis/DescribeStreamSummary.hs +200/−0
• gen/Amazonka/Kinesis/DisableEnhancedMonitoring.hs +230/−0
• gen/Amazonka/Kinesis/EnableEnhancedMonitoring.hs +227/−0
• gen/Amazonka/Kinesis/GetRecords.hs +337/−0
• gen/Amazonka/Kinesis/GetShardIterator.hs +384/−0
• gen/Amazonka/Kinesis/IncreaseStreamRetentionPeriod.hs +199/−0
• gen/Amazonka/Kinesis/Lens.hs +398/−0
• gen/Amazonka/Kinesis/ListShards.hs +546/−0
• gen/Amazonka/Kinesis/ListStreamConsumers.hs +390/−0
• gen/Amazonka/Kinesis/ListStreams.hs +279/−0
• gen/Amazonka/Kinesis/ListTagsForStream.hs +257/−0
• gen/Amazonka/Kinesis/MergeShards.hs +228/−0
• gen/Amazonka/Kinesis/PutRecord.hs +408/−0
• gen/Amazonka/Kinesis/PutRecords.hs +329/−0
• gen/Amazonka/Kinesis/RegisterStreamConsumer.hs +227/−0
• gen/Amazonka/Kinesis/RemoveTagsFromStream.hs +176/−0
• gen/Amazonka/Kinesis/SplitShard.hs +253/−0
• gen/Amazonka/Kinesis/StartStreamEncryption.hs +252/−0
• gen/Amazonka/Kinesis/StopStreamEncryption.hs +253/−0
• gen/Amazonka/Kinesis/SubscribeToShard.hs +249/−0
• gen/Amazonka/Kinesis/Types.hs +460/−0
• gen/Amazonka/Kinesis/Types/ChildShard.hs +101/−0
• gen/Amazonka/Kinesis/Types/Consumer.hs +145/−0
• gen/Amazonka/Kinesis/Types/ConsumerDescription.hs +160/−0
• gen/Amazonka/Kinesis/Types/ConsumerStatus.hs +76/−0
• gen/Amazonka/Kinesis/Types/EncryptionType.hs +71/−0
• gen/Amazonka/Kinesis/Types/EnhancedMetrics.hs +145/−0
• gen/Amazonka/Kinesis/Types/EnhancedMonitoringOutput.hs +123/−0
• gen/Amazonka/Kinesis/Types/HashKeyRange.hs +89/−0
• gen/Amazonka/Kinesis/Types/MetricsName.hs +101/−0
• gen/Amazonka/Kinesis/Types/PutRecordsRequestEntry.hs +145/−0
• gen/Amazonka/Kinesis/Types/PutRecordsResultEntry.hs +127/−0
• gen/Amazonka/Kinesis/Types/Record.hs +167/−0
• gen/Amazonka/Kinesis/Types/ScalingType.hs +66/−0
• gen/Amazonka/Kinesis/Types/SequenceNumberRange.hs +90/−0
• gen/Amazonka/Kinesis/Types/Shard.hs +134/−0
• gen/Amazonka/Kinesis/Types/ShardFilter.hs +192/−0
• gen/Amazonka/Kinesis/Types/ShardFilterType.hs +91/−0
• gen/Amazonka/Kinesis/Types/ShardIteratorType.hs +86/−0
• gen/Amazonka/Kinesis/Types/StartingPosition.hs +171/−0
• gen/Amazonka/Kinesis/Types/StreamDescription.hs +349/−0
• gen/Amazonka/Kinesis/Types/StreamDescriptionSummary.hs +339/−0
• gen/Amazonka/Kinesis/Types/StreamMode.hs +71/−0
• gen/Amazonka/Kinesis/Types/StreamModeDetails.hs +90/−0
• gen/Amazonka/Kinesis/Types/StreamStatus.hs +81/−0
• gen/Amazonka/Kinesis/Types/StreamSummary.hs +131/−0
• gen/Amazonka/Kinesis/Types/SubscribeToShardEvent.hs +141/−0
• gen/Amazonka/Kinesis/Types/Tag.hs +91/−0
• gen/Amazonka/Kinesis/UpdateShardCount.hs +337/−0
• gen/Amazonka/Kinesis/UpdateStreamMode.hs +168/−0
• gen/Amazonka/Kinesis/Waiters.hs +57/−0
• gen/Network/AWS/Kinesis.hs +0/−308
• gen/Network/AWS/Kinesis/AddTagsToStream.hs +0/−126
• gen/Network/AWS/Kinesis/CreateStream.hs +0/−144
• gen/Network/AWS/Kinesis/DecreaseStreamRetentionPeriod.hs +0/−136
• gen/Network/AWS/Kinesis/DeleteStream.hs +0/−121
• gen/Network/AWS/Kinesis/DescribeLimits.hs +0/−137
• gen/Network/AWS/Kinesis/DescribeStream.hs +0/−193
• gen/Network/AWS/Kinesis/DescribeStreamSummary.hs +0/−140
• gen/Network/AWS/Kinesis/DisableEnhancedMonitoring.hs +0/−114
• gen/Network/AWS/Kinesis/EnableEnhancedMonitoring.hs +0/−114
• gen/Network/AWS/Kinesis/GetRecords.hs +0/−185
• gen/Network/AWS/Kinesis/GetShardIterator.hs +0/−198
• gen/Network/AWS/Kinesis/IncreaseStreamRetentionPeriod.hs +0/−136
• gen/Network/AWS/Kinesis/ListShards.hs +0/−190
• gen/Network/AWS/Kinesis/ListStreams.hs +0/−182
• gen/Network/AWS/Kinesis/ListTagsForStream.hs +0/−177
• gen/Network/AWS/Kinesis/MergeShards.hs +0/−152
• gen/Network/AWS/Kinesis/PutRecord.hs +0/−226
• gen/Network/AWS/Kinesis/PutRecords.hs +0/−196
• gen/Network/AWS/Kinesis/RemoveTagsFromStream.hs +0/−130
• gen/Network/AWS/Kinesis/SplitShard.hs +0/−156
• gen/Network/AWS/Kinesis/StartStreamEncryption.hs +0/−141
• gen/Network/AWS/Kinesis/StopStreamEncryption.hs +0/−141
• gen/Network/AWS/Kinesis/Types.hs +0/−280
• gen/Network/AWS/Kinesis/Types/Product.hs +0/−764
• gen/Network/AWS/Kinesis/Types/Sum.hs +0/−191
• gen/Network/AWS/Kinesis/UpdateShardCount.hs +0/−201
• gen/Network/AWS/Kinesis/Waiters.hs +0/−50
• test/Main.hs +11/−9
• test/Test/AWS/Gen/Kinesis.hs +0/−453
• test/Test/AWS/Kinesis.hs +0/−26
• test/Test/AWS/Kinesis/Internal.hs +0/−16
• test/Test/Amazonka/Gen/Kinesis.hs +610/−0
• test/Test/Amazonka/Kinesis.hs +20/−0
• test/Test/Amazonka/Kinesis/Internal.hs +8/−0

@@ -7,9 +7,8 @@   ## Version--`1.6.1`-+ +`2.0` - Derived from API version @2013-12-02@ of the AWS service descriptions, licensed under Apache 2.0.  ## Description @@ -26,7 +25,7 @@ The provided lenses should be compatible with any of the major lens libraries [lens](http://hackage.haskell.org/package/lens) or [lens-family-core](http://hackage.haskell.org/package/lens-family-core). -See [Network.AWS.Kinesis](http://hackage.haskell.org/package/amazonka-kinesis/docs/Network-AWS-Kinesis.html)+See [Amazonka.Kinesis](http://hackage.haskell.org/package/amazonka-kinesis/docs/Amazonka-Kinesis.html) or [the AWS documentation](https://aws.amazon.com/documentation/) to get started.  

@@ -1,2 +0,0 @@-import           Distribution.Simple-main = defaultMain

@@ -1,108 +1,139 @@-name:                  amazonka-kinesis-version:               1.6.1-synopsis:              Amazon Kinesis SDK.-homepage:              https://github.com/brendanhay/amazonka-bug-reports:           https://github.com/brendanhay/amazonka/issues-license:               MPL-2.0-license-file:          LICENSE-author:                Brendan Hay-maintainer:            Brendan Hay <brendan.g.hay+amazonka@gmail.com>-copyright:             Copyright (c) 2013-2018 Brendan Hay-category:              Network, AWS, Cloud, Distributed Computing-build-type:            Simple-cabal-version:         >= 1.10-extra-source-files:    README.md fixture/*.yaml fixture/*.proto src/.gitkeep+cabal-version:      2.2+name:               amazonka-kinesis+version:            2.0+synopsis:           Amazon Kinesis SDK.+homepage:           https://github.com/brendanhay/amazonka+bug-reports:        https://github.com/brendanhay/amazonka/issues+license:            MPL-2.0+license-file:       LICENSE+author:             Brendan Hay+maintainer:+  Brendan Hay <brendan.g.hay+amazonka@gmail.com>, Jack Kelly <jack@jackkelly.name>++copyright:          Copyright (c) 2013-2023 Brendan Hay+category:           AWS+build-type:         Simple+extra-source-files:+  fixture/*.proto+  fixture/*.yaml+  README.md+  src/.gitkeep+ description:-    The types from this library are intended to be used with-    <http://hackage.haskell.org/package/amazonka amazonka>, which provides-    mechanisms for specifying AuthN/AuthZ information, sending requests,-    and receiving responses.-    .-    Lenses are used for constructing and manipulating types,-    due to the depth of nesting of AWS types and transparency regarding-    de/serialisation into more palatable Haskell values.-    The provided lenses should be compatible with any of the major lens libraries-    such as <http://hackage.haskell.org/package/lens lens> or-    <http://hackage.haskell.org/package/lens-family-core lens-family-core>.-    .-    See "Network.AWS.Kinesis" or <https://aws.amazon.com/documentation/ the AWS documentation>-    to get started.+  Derived from API version @2013-12-02@ of the AWS service descriptions, licensed under Apache 2.0.+  .+  The types from this library are intended to be used with <http://hackage.haskell.org/package/amazonka amazonka>,+  which provides mechanisms for specifying AuthN/AuthZ information, sending requests, and receiving responses.+  .+  It is recommended to use generic lenses or optics from packages such as <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify optional fields and deconstruct responses.+  .+  Generated lenses can be found in "Amazonka.Kinesis.Lens" and are+  suitable for use with a lens package such as <http://hackage.haskell.org/package/lens lens> or <http://hackage.haskell.org/package/lens-family-core lens-family-core>.+  .+  See "Amazonka.Kinesis" and the <https://aws.amazon.com/documentation/ AWS documentation> to get started.  source-repository head-    type:              git-    location:          git://github.com/brendanhay/amazonka.git-    subdir:            amazonka-kinesis+  type:     git+  location: git://github.com/brendanhay/amazonka.git+  subdir:   amazonka-kinesis  library-    default-language:  Haskell2010-    hs-source-dirs:    src gen--    ghc-options:-        -Wall-        -fwarn-incomplete-uni-patterns-        -fwarn-incomplete-record-updates-        -funbox-strict-fields--    exposed-modules:-          Network.AWS.Kinesis-        , Network.AWS.Kinesis.AddTagsToStream-        , Network.AWS.Kinesis.CreateStream-        , Network.AWS.Kinesis.DecreaseStreamRetentionPeriod-        , Network.AWS.Kinesis.DeleteStream-        , Network.AWS.Kinesis.DescribeLimits-        , Network.AWS.Kinesis.DescribeStream-        , Network.AWS.Kinesis.DescribeStreamSummary-        , Network.AWS.Kinesis.DisableEnhancedMonitoring-        , Network.AWS.Kinesis.EnableEnhancedMonitoring-        , Network.AWS.Kinesis.GetRecords-        , Network.AWS.Kinesis.GetShardIterator-        , Network.AWS.Kinesis.IncreaseStreamRetentionPeriod-        , Network.AWS.Kinesis.ListShards-        , Network.AWS.Kinesis.ListStreams-        , Network.AWS.Kinesis.ListTagsForStream-        , Network.AWS.Kinesis.MergeShards-        , Network.AWS.Kinesis.PutRecord-        , Network.AWS.Kinesis.PutRecords-        , Network.AWS.Kinesis.RemoveTagsFromStream-        , Network.AWS.Kinesis.SplitShard-        , Network.AWS.Kinesis.StartStreamEncryption-        , Network.AWS.Kinesis.StopStreamEncryption-        , Network.AWS.Kinesis.Types-        , Network.AWS.Kinesis.UpdateShardCount-        , Network.AWS.Kinesis.Waiters+  default-language: Haskell2010+  hs-source-dirs:   src gen+  ghc-options:+    -Wall -fwarn-incomplete-uni-patterns+    -fwarn-incomplete-record-updates -funbox-strict-fields -    other-modules:-          Network.AWS.Kinesis.Types.Product-        , Network.AWS.Kinesis.Types.Sum+  exposed-modules:+    Amazonka.Kinesis+    Amazonka.Kinesis.AddTagsToStream+    Amazonka.Kinesis.CreateStream+    Amazonka.Kinesis.DecreaseStreamRetentionPeriod+    Amazonka.Kinesis.DeleteStream+    Amazonka.Kinesis.DeregisterStreamConsumer+    Amazonka.Kinesis.DescribeLimits+    Amazonka.Kinesis.DescribeStream+    Amazonka.Kinesis.DescribeStreamConsumer+    Amazonka.Kinesis.DescribeStreamSummary+    Amazonka.Kinesis.DisableEnhancedMonitoring+    Amazonka.Kinesis.EnableEnhancedMonitoring+    Amazonka.Kinesis.GetRecords+    Amazonka.Kinesis.GetShardIterator+    Amazonka.Kinesis.IncreaseStreamRetentionPeriod+    Amazonka.Kinesis.Lens+    Amazonka.Kinesis.ListShards+    Amazonka.Kinesis.ListStreamConsumers+    Amazonka.Kinesis.ListStreams+    Amazonka.Kinesis.ListTagsForStream+    Amazonka.Kinesis.MergeShards+    Amazonka.Kinesis.PutRecord+    Amazonka.Kinesis.PutRecords+    Amazonka.Kinesis.RegisterStreamConsumer+    Amazonka.Kinesis.RemoveTagsFromStream+    Amazonka.Kinesis.SplitShard+    Amazonka.Kinesis.StartStreamEncryption+    Amazonka.Kinesis.StopStreamEncryption+    Amazonka.Kinesis.SubscribeToShard+    Amazonka.Kinesis.Types+    Amazonka.Kinesis.Types.ChildShard+    Amazonka.Kinesis.Types.Consumer+    Amazonka.Kinesis.Types.ConsumerDescription+    Amazonka.Kinesis.Types.ConsumerStatus+    Amazonka.Kinesis.Types.EncryptionType+    Amazonka.Kinesis.Types.EnhancedMetrics+    Amazonka.Kinesis.Types.EnhancedMonitoringOutput+    Amazonka.Kinesis.Types.HashKeyRange+    Amazonka.Kinesis.Types.MetricsName+    Amazonka.Kinesis.Types.PutRecordsRequestEntry+    Amazonka.Kinesis.Types.PutRecordsResultEntry+    Amazonka.Kinesis.Types.Record+    Amazonka.Kinesis.Types.ScalingType+    Amazonka.Kinesis.Types.SequenceNumberRange+    Amazonka.Kinesis.Types.Shard+    Amazonka.Kinesis.Types.ShardFilter+    Amazonka.Kinesis.Types.ShardFilterType+    Amazonka.Kinesis.Types.ShardIteratorType+    Amazonka.Kinesis.Types.StartingPosition+    Amazonka.Kinesis.Types.StreamDescription+    Amazonka.Kinesis.Types.StreamDescriptionSummary+    Amazonka.Kinesis.Types.StreamMode+    Amazonka.Kinesis.Types.StreamModeDetails+    Amazonka.Kinesis.Types.StreamStatus+    Amazonka.Kinesis.Types.StreamSummary+    Amazonka.Kinesis.Types.SubscribeToShardEvent+    Amazonka.Kinesis.Types.Tag+    Amazonka.Kinesis.UpdateShardCount+    Amazonka.Kinesis.UpdateStreamMode+    Amazonka.Kinesis.Waiters -    build-depends:-          amazonka-core == 1.6.1.*-        , base          >= 4.7     && < 5+  build-depends:+    , amazonka-core  >=2.0  && <2.1+    , base           >=4.12 && <5  test-suite amazonka-kinesis-test-    type:              exitcode-stdio-1.0-    default-language:  Haskell2010-    hs-source-dirs:    test-    main-is:           Main.hs--    ghc-options:       -Wall -threaded+  type:             exitcode-stdio-1.0+  default-language: Haskell2010+  hs-source-dirs:   test+  main-is:          Main.hs+  ghc-options:      -Wall -threaded -    -- This section is encoded by the template and any modules added by-    -- hand outside these namespaces will not correctly be added to the-    -- distribution package.-    other-modules:-          Test.AWS.Kinesis-        , Test.AWS.Gen.Kinesis-        , Test.AWS.Kinesis.Internal+  -- This section is encoded by the template and any modules added by+  -- hand outside these namespaces will not correctly be added to the+  -- distribution package.+  other-modules:+    Test.Amazonka.Gen.Kinesis+    Test.Amazonka.Kinesis+    Test.Amazonka.Kinesis.Internal -    build-depends:-          amazonka-core == 1.6.1.*-        , amazonka-test == 1.6.1.*-        , amazonka-kinesis-        , base-        , bytestring-        , tasty-        , tasty-hunit-        , text-        , time-        , unordered-containers+  build-depends:+    , amazonka-core         >=2.0 && <2.1+    , amazonka-kinesis+    , amazonka-test         >=2.0 && <2.1+    , base+    , bytestring+    , case-insensitive+    , tasty+    , tasty-hunit+    , text+    , time+    , unordered-containers

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/kinesis/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  kinesis.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,421 @@+{-# OPTIONS_GHC -fno-warn-duplicate-exports #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}++-- |+-- Module      : Amazonka.Kinesis+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Derived from API version @2013-12-02@ of the AWS service descriptions, licensed under Apache 2.0.+--+-- Amazon Kinesis Data Streams Service API Reference+--+-- Amazon Kinesis Data Streams is a managed service that scales elastically+-- for real-time processing of streaming big data.+module Amazonka.Kinesis+  ( -- * Service Configuration+    defaultService,++    -- * Errors+    -- $errors++    -- ** AccessDeniedException+    _AccessDeniedException,++    -- ** ExpiredIteratorException+    _ExpiredIteratorException,++    -- ** ExpiredNextTokenException+    _ExpiredNextTokenException,++    -- ** InternalFailureException+    _InternalFailureException,++    -- ** InvalidArgumentException+    _InvalidArgumentException,++    -- ** KMSAccessDeniedException+    _KMSAccessDeniedException,++    -- ** KMSDisabledException+    _KMSDisabledException,++    -- ** KMSInvalidStateException+    _KMSInvalidStateException,++    -- ** KMSNotFoundException+    _KMSNotFoundException,++    -- ** KMSOptInRequired+    _KMSOptInRequired,++    -- ** KMSThrottlingException+    _KMSThrottlingException,++    -- ** LimitExceededException+    _LimitExceededException,++    -- ** ProvisionedThroughputExceededException+    _ProvisionedThroughputExceededException,++    -- ** ResourceInUseException+    _ResourceInUseException,++    -- ** ResourceNotFoundException+    _ResourceNotFoundException,++    -- ** ValidationException+    _ValidationException,++    -- * Waiters+    -- $waiters++    -- ** StreamExists+    newStreamExists,++    -- ** StreamNotExists+    newStreamNotExists,++    -- * Operations+    -- $operations++    -- ** AddTagsToStream+    AddTagsToStream (AddTagsToStream'),+    newAddTagsToStream,+    AddTagsToStreamResponse (AddTagsToStreamResponse'),+    newAddTagsToStreamResponse,++    -- ** CreateStream+    CreateStream (CreateStream'),+    newCreateStream,+    CreateStreamResponse (CreateStreamResponse'),+    newCreateStreamResponse,++    -- ** DecreaseStreamRetentionPeriod+    DecreaseStreamRetentionPeriod (DecreaseStreamRetentionPeriod'),+    newDecreaseStreamRetentionPeriod,+    DecreaseStreamRetentionPeriodResponse (DecreaseStreamRetentionPeriodResponse'),+    newDecreaseStreamRetentionPeriodResponse,++    -- ** DeleteStream+    DeleteStream (DeleteStream'),+    newDeleteStream,+    DeleteStreamResponse (DeleteStreamResponse'),+    newDeleteStreamResponse,++    -- ** DeregisterStreamConsumer+    DeregisterStreamConsumer (DeregisterStreamConsumer'),+    newDeregisterStreamConsumer,+    DeregisterStreamConsumerResponse (DeregisterStreamConsumerResponse'),+    newDeregisterStreamConsumerResponse,++    -- ** DescribeLimits+    DescribeLimits (DescribeLimits'),+    newDescribeLimits,+    DescribeLimitsResponse (DescribeLimitsResponse'),+    newDescribeLimitsResponse,++    -- ** DescribeStream (Paginated)+    DescribeStream (DescribeStream'),+    newDescribeStream,+    DescribeStreamResponse (DescribeStreamResponse'),+    newDescribeStreamResponse,++    -- ** DescribeStreamConsumer+    DescribeStreamConsumer (DescribeStreamConsumer'),+    newDescribeStreamConsumer,+    DescribeStreamConsumerResponse (DescribeStreamConsumerResponse'),+    newDescribeStreamConsumerResponse,++    -- ** DescribeStreamSummary+    DescribeStreamSummary (DescribeStreamSummary'),+    newDescribeStreamSummary,+    DescribeStreamSummaryResponse (DescribeStreamSummaryResponse'),+    newDescribeStreamSummaryResponse,++    -- ** DisableEnhancedMonitoring+    DisableEnhancedMonitoring (DisableEnhancedMonitoring'),+    newDisableEnhancedMonitoring,+    EnhancedMonitoringOutput (EnhancedMonitoringOutput'),+    newEnhancedMonitoringOutput,++    -- ** EnableEnhancedMonitoring+    EnableEnhancedMonitoring (EnableEnhancedMonitoring'),+    newEnableEnhancedMonitoring,+    EnhancedMonitoringOutput (EnhancedMonitoringOutput'),+    newEnhancedMonitoringOutput,++    -- ** GetRecords+    GetRecords (GetRecords'),+    newGetRecords,+    GetRecordsResponse (GetRecordsResponse'),+    newGetRecordsResponse,++    -- ** GetShardIterator+    GetShardIterator (GetShardIterator'),+    newGetShardIterator,+    GetShardIteratorResponse (GetShardIteratorResponse'),+    newGetShardIteratorResponse,++    -- ** IncreaseStreamRetentionPeriod+    IncreaseStreamRetentionPeriod (IncreaseStreamRetentionPeriod'),+    newIncreaseStreamRetentionPeriod,+    IncreaseStreamRetentionPeriodResponse (IncreaseStreamRetentionPeriodResponse'),+    newIncreaseStreamRetentionPeriodResponse,++    -- ** ListShards (Paginated)+    ListShards (ListShards'),+    newListShards,+    ListShardsResponse (ListShardsResponse'),+    newListShardsResponse,++    -- ** ListStreamConsumers (Paginated)+    ListStreamConsumers (ListStreamConsumers'),+    newListStreamConsumers,+    ListStreamConsumersResponse (ListStreamConsumersResponse'),+    newListStreamConsumersResponse,++    -- ** ListStreams (Paginated)+    ListStreams (ListStreams'),+    newListStreams,+    ListStreamsResponse (ListStreamsResponse'),+    newListStreamsResponse,++    -- ** ListTagsForStream+    ListTagsForStream (ListTagsForStream'),+    newListTagsForStream,+    ListTagsForStreamResponse (ListTagsForStreamResponse'),+    newListTagsForStreamResponse,++    -- ** MergeShards+    MergeShards (MergeShards'),+    newMergeShards,+    MergeShardsResponse (MergeShardsResponse'),+    newMergeShardsResponse,++    -- ** PutRecord+    PutRecord (PutRecord'),+    newPutRecord,+    PutRecordResponse (PutRecordResponse'),+    newPutRecordResponse,++    -- ** PutRecords+    PutRecords (PutRecords'),+    newPutRecords,+    PutRecordsResponse (PutRecordsResponse'),+    newPutRecordsResponse,++    -- ** RegisterStreamConsumer+    RegisterStreamConsumer (RegisterStreamConsumer'),+    newRegisterStreamConsumer,+    RegisterStreamConsumerResponse (RegisterStreamConsumerResponse'),+    newRegisterStreamConsumerResponse,++    -- ** RemoveTagsFromStream+    RemoveTagsFromStream (RemoveTagsFromStream'),+    newRemoveTagsFromStream,+    RemoveTagsFromStreamResponse (RemoveTagsFromStreamResponse'),+    newRemoveTagsFromStreamResponse,++    -- ** SplitShard+    SplitShard (SplitShard'),+    newSplitShard,+    SplitShardResponse (SplitShardResponse'),+    newSplitShardResponse,++    -- ** StartStreamEncryption+    StartStreamEncryption (StartStreamEncryption'),+    newStartStreamEncryption,+    StartStreamEncryptionResponse (StartStreamEncryptionResponse'),+    newStartStreamEncryptionResponse,++    -- ** StopStreamEncryption+    StopStreamEncryption (StopStreamEncryption'),+    newStopStreamEncryption,+    StopStreamEncryptionResponse (StopStreamEncryptionResponse'),+    newStopStreamEncryptionResponse,++    -- ** SubscribeToShard+    SubscribeToShard (SubscribeToShard'),+    newSubscribeToShard,+    SubscribeToShardResponse (SubscribeToShardResponse'),+    newSubscribeToShardResponse,++    -- ** UpdateShardCount+    UpdateShardCount (UpdateShardCount'),+    newUpdateShardCount,+    UpdateShardCountResponse (UpdateShardCountResponse'),+    newUpdateShardCountResponse,++    -- ** UpdateStreamMode+    UpdateStreamMode (UpdateStreamMode'),+    newUpdateStreamMode,+    UpdateStreamModeResponse (UpdateStreamModeResponse'),+    newUpdateStreamModeResponse,++    -- * Types++    -- ** ConsumerStatus+    ConsumerStatus (..),++    -- ** EncryptionType+    EncryptionType (..),++    -- ** MetricsName+    MetricsName (..),++    -- ** ScalingType+    ScalingType (..),++    -- ** ShardFilterType+    ShardFilterType (..),++    -- ** ShardIteratorType+    ShardIteratorType (..),++    -- ** StreamMode+    StreamMode (..),++    -- ** StreamStatus+    StreamStatus (..),++    -- ** ChildShard+    ChildShard (ChildShard'),+    newChildShard,++    -- ** Consumer+    Consumer (Consumer'),+    newConsumer,++    -- ** ConsumerDescription+    ConsumerDescription (ConsumerDescription'),+    newConsumerDescription,++    -- ** EnhancedMetrics+    EnhancedMetrics (EnhancedMetrics'),+    newEnhancedMetrics,++    -- ** EnhancedMonitoringOutput+    EnhancedMonitoringOutput (EnhancedMonitoringOutput'),+    newEnhancedMonitoringOutput,++    -- ** HashKeyRange+    HashKeyRange (HashKeyRange'),+    newHashKeyRange,++    -- ** PutRecordsRequestEntry+    PutRecordsRequestEntry (PutRecordsRequestEntry'),+    newPutRecordsRequestEntry,++    -- ** PutRecordsResultEntry+    PutRecordsResultEntry (PutRecordsResultEntry'),+    newPutRecordsResultEntry,++    -- ** Record+    Record (Record'),+    newRecord,++    -- ** SequenceNumberRange+    SequenceNumberRange (SequenceNumberRange'),+    newSequenceNumberRange,++    -- ** Shard+    Shard (Shard'),+    newShard,++    -- ** ShardFilter+    ShardFilter (ShardFilter'),+    newShardFilter,++    -- ** StartingPosition+    StartingPosition (StartingPosition'),+    newStartingPosition,++    -- ** StreamDescription+    StreamDescription (StreamDescription'),+    newStreamDescription,++    -- ** StreamDescriptionSummary+    StreamDescriptionSummary (StreamDescriptionSummary'),+    newStreamDescriptionSummary,++    -- ** StreamModeDetails+    StreamModeDetails (StreamModeDetails'),+    newStreamModeDetails,++    -- ** StreamSummary+    StreamSummary (StreamSummary'),+    newStreamSummary,++    -- ** SubscribeToShardEvent+    SubscribeToShardEvent (SubscribeToShardEvent'),+    newSubscribeToShardEvent,++    -- ** Tag+    Tag (Tag'),+    newTag,+  )+where++import Amazonka.Kinesis.AddTagsToStream+import Amazonka.Kinesis.CreateStream+import Amazonka.Kinesis.DecreaseStreamRetentionPeriod+import Amazonka.Kinesis.DeleteStream+import Amazonka.Kinesis.DeregisterStreamConsumer+import Amazonka.Kinesis.DescribeLimits+import Amazonka.Kinesis.DescribeStream+import Amazonka.Kinesis.DescribeStreamConsumer+import Amazonka.Kinesis.DescribeStreamSummary+import Amazonka.Kinesis.DisableEnhancedMonitoring+import Amazonka.Kinesis.EnableEnhancedMonitoring+import Amazonka.Kinesis.GetRecords+import Amazonka.Kinesis.GetShardIterator+import Amazonka.Kinesis.IncreaseStreamRetentionPeriod+import Amazonka.Kinesis.Lens+import Amazonka.Kinesis.ListShards+import Amazonka.Kinesis.ListStreamConsumers+import Amazonka.Kinesis.ListStreams+import Amazonka.Kinesis.ListTagsForStream+import Amazonka.Kinesis.MergeShards+import Amazonka.Kinesis.PutRecord+import Amazonka.Kinesis.PutRecords+import Amazonka.Kinesis.RegisterStreamConsumer+import Amazonka.Kinesis.RemoveTagsFromStream+import Amazonka.Kinesis.SplitShard+import Amazonka.Kinesis.StartStreamEncryption+import Amazonka.Kinesis.StopStreamEncryption+import Amazonka.Kinesis.SubscribeToShard+import Amazonka.Kinesis.Types+import Amazonka.Kinesis.UpdateShardCount+import Amazonka.Kinesis.UpdateStreamMode+import Amazonka.Kinesis.Waiters++-- $errors+-- Error matchers are designed for use with the functions provided by+-- <http://hackage.haskell.org/package/lens/docs/Control-Exception-Lens.html Control.Exception.Lens>.+-- This allows catching (and rethrowing) service specific errors returned+-- by 'Kinesis'.++-- $operations+-- Some AWS operations return results that are incomplete and require subsequent+-- requests in order to obtain the entire result set. The process of sending+-- subsequent requests to continue where a previous request left off is called+-- pagination. For example, the 'ListObjects' operation of Amazon S3 returns up to+-- 1000 objects at a time, and you must send subsequent requests with the+-- appropriate Marker in order to retrieve the next page of results.+--+-- Operations that have an 'AWSPager' instance can transparently perform subsequent+-- requests, correctly setting Markers and other request facets to iterate through+-- the entire result set of a truncated API operation. Operations which support+-- this have an additional note in the documentation.+--+-- Many operations have the ability to filter results on the server side. See the+-- individual operation parameters for details.++-- $waiters+-- Waiters poll by repeatedly sending a request until some remote success condition+-- configured by the 'Wait' specification is fulfilled. The 'Wait' specification+-- determines how many attempts should be made, in addition to delay and retry strategies.

@@ -0,0 +1,172 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.AddTagsToStream+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Adds or updates tags for the specified Kinesis data stream. You can+-- assign up to 50 tags to a data stream.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+--+-- If tags have already been assigned to the stream, @AddTagsToStream@+-- overwrites any existing tags that correspond to the specified tag keys.+--+-- AddTagsToStream has a limit of five transactions per second per account.+module Amazonka.Kinesis.AddTagsToStream+  ( -- * Creating a Request+    AddTagsToStream (..),+    newAddTagsToStream,++    -- * Request Lenses+    addTagsToStream_streamARN,+    addTagsToStream_streamName,+    addTagsToStream_tags,++    -- * Destructuring the Response+    AddTagsToStreamResponse (..),+    newAddTagsToStreamResponse,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for @AddTagsToStream@.+--+-- /See:/ 'newAddTagsToStream' smart constructor.+data AddTagsToStream = AddTagsToStream'+  { -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the stream.+    streamName :: Prelude.Maybe Prelude.Text,+    -- | A set of up to 10 key-value pairs to use to create the tags.+    tags :: Prelude.HashMap Prelude.Text Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'AddTagsToStream' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'streamARN', 'addTagsToStream_streamARN' - The ARN of the stream.+--+-- 'streamName', 'addTagsToStream_streamName' - The name of the stream.+--+-- 'tags', 'addTagsToStream_tags' - A set of up to 10 key-value pairs to use to create the tags.+newAddTagsToStream ::+  AddTagsToStream+newAddTagsToStream =+  AddTagsToStream'+    { streamARN = Prelude.Nothing,+      streamName = Prelude.Nothing,+      tags = Prelude.mempty+    }++-- | The ARN of the stream.+addTagsToStream_streamARN :: Lens.Lens' AddTagsToStream (Prelude.Maybe Prelude.Text)+addTagsToStream_streamARN = Lens.lens (\AddTagsToStream' {streamARN} -> streamARN) (\s@AddTagsToStream' {} a -> s {streamARN = a} :: AddTagsToStream)++-- | The name of the stream.+addTagsToStream_streamName :: Lens.Lens' AddTagsToStream (Prelude.Maybe Prelude.Text)+addTagsToStream_streamName = Lens.lens (\AddTagsToStream' {streamName} -> streamName) (\s@AddTagsToStream' {} a -> s {streamName = a} :: AddTagsToStream)++-- | A set of up to 10 key-value pairs to use to create the tags.+addTagsToStream_tags :: Lens.Lens' AddTagsToStream (Prelude.HashMap Prelude.Text Prelude.Text)+addTagsToStream_tags = Lens.lens (\AddTagsToStream' {tags} -> tags) (\s@AddTagsToStream' {} a -> s {tags = a} :: AddTagsToStream) Prelude.. Lens.coerced++instance Core.AWSRequest AddTagsToStream where+  type+    AWSResponse AddTagsToStream =+      AddTagsToStreamResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveNull AddTagsToStreamResponse'++instance Prelude.Hashable AddTagsToStream where+  hashWithSalt _salt AddTagsToStream' {..} =+    _salt+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName+      `Prelude.hashWithSalt` tags++instance Prelude.NFData AddTagsToStream where+  rnf AddTagsToStream' {..} =+    Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName+      `Prelude.seq` Prelude.rnf tags++instance Data.ToHeaders AddTagsToStream where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.AddTagsToStream" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON AddTagsToStream where+  toJSON AddTagsToStream' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName,+            Prelude.Just ("Tags" Data..= tags)+          ]+      )++instance Data.ToPath AddTagsToStream where+  toPath = Prelude.const "/"++instance Data.ToQuery AddTagsToStream where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newAddTagsToStreamResponse' smart constructor.+data AddTagsToStreamResponse = AddTagsToStreamResponse'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'AddTagsToStreamResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newAddTagsToStreamResponse ::+  AddTagsToStreamResponse+newAddTagsToStreamResponse = AddTagsToStreamResponse'++instance Prelude.NFData AddTagsToStreamResponse where+  rnf _ = ()

@@ -0,0 +1,238 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.CreateStream+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Creates a Kinesis data stream. A stream captures and transports data+-- records that are continuously emitted from different data sources or+-- /producers/. Scale-out within a stream is explicitly supported by means+-- of shards, which are uniquely identified groups of data records in a+-- stream.+--+-- You can create your data stream using either on-demand or provisioned+-- capacity mode. Data streams with an on-demand mode require no capacity+-- planning and automatically scale to handle gigabytes of write and read+-- throughput per minute. With the on-demand mode, Kinesis Data Streams+-- automatically manages the shards in order to provide the necessary+-- throughput. For the data streams with a provisioned mode, you must+-- specify the number of shards for the data stream. Each shard can support+-- reads up to five transactions per second, up to a maximum data read+-- total of 2 MiB per second. Each shard can support writes up to 1,000+-- records per second, up to a maximum data write total of 1 MiB per+-- second. If the amount of data input increases or decreases, you can add+-- or remove shards.+--+-- The stream name identifies the stream. The name is scoped to the Amazon+-- Web Services account used by the application. It is also scoped by+-- Amazon Web Services Region. That is, two streams in two different+-- accounts can have the same name, and two streams in the same account,+-- but in two different Regions, can have the same name.+--+-- @CreateStream@ is an asynchronous operation. Upon receiving a+-- @CreateStream@ request, Kinesis Data Streams immediately returns and+-- sets the stream status to @CREATING@. After the stream is created,+-- Kinesis Data Streams sets the stream status to @ACTIVE@. You should+-- perform read and write operations only on an @ACTIVE@ stream.+--+-- You receive a @LimitExceededException@ when making a @CreateStream@+-- request when you try to do one of the following:+--+-- -   Have more than five streams in the @CREATING@ state at any point in+--     time.+--+-- -   Create more shards than are authorized for your account.+--+-- For the default shard limit for an Amazon Web Services account, see+-- <https://docs.aws.amazon.com/kinesis/latest/dev/service-sizes-and-limits.html Amazon Kinesis Data Streams Limits>+-- in the /Amazon Kinesis Data Streams Developer Guide/. To increase this+-- limit,+-- <https://docs.aws.amazon.com/general/latest/gr/aws_service_limits.html contact Amazon Web Services Support>.+--+-- You can use DescribeStreamSummary to check the stream status, which is+-- returned in @StreamStatus@.+--+-- CreateStream has a limit of five transactions per second per account.+module Amazonka.Kinesis.CreateStream+  ( -- * Creating a Request+    CreateStream (..),+    newCreateStream,++    -- * Request Lenses+    createStream_shardCount,+    createStream_streamModeDetails,+    createStream_streamName,++    -- * Destructuring the Response+    CreateStreamResponse (..),+    newCreateStreamResponse,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for @CreateStream@.+--+-- /See:/ 'newCreateStream' smart constructor.+data CreateStream = CreateStream'+  { -- | The number of shards that the stream will use. The throughput of the+    -- stream is a function of the number of shards; more shards are required+    -- for greater provisioned throughput.+    shardCount :: Prelude.Maybe Prelude.Natural,+    -- | Indicates the capacity mode of the data stream. Currently, in Kinesis+    -- Data Streams, you can choose between an __on-demand__ capacity mode and+    -- a __provisioned__ capacity mode for your data streams.+    streamModeDetails :: Prelude.Maybe StreamModeDetails,+    -- | A name to identify the stream. The stream name is scoped to the Amazon+    -- Web Services account used by the application that creates the stream. It+    -- is also scoped by Amazon Web Services Region. That is, two streams in+    -- two different Amazon Web Services accounts can have the same name. Two+    -- streams in the same Amazon Web Services account but in two different+    -- Regions can also have the same name.+    streamName :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'CreateStream' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'shardCount', 'createStream_shardCount' - The number of shards that the stream will use. The throughput of the+-- stream is a function of the number of shards; more shards are required+-- for greater provisioned throughput.+--+-- 'streamModeDetails', 'createStream_streamModeDetails' - Indicates the capacity mode of the data stream. Currently, in Kinesis+-- Data Streams, you can choose between an __on-demand__ capacity mode and+-- a __provisioned__ capacity mode for your data streams.+--+-- 'streamName', 'createStream_streamName' - A name to identify the stream. The stream name is scoped to the Amazon+-- Web Services account used by the application that creates the stream. It+-- is also scoped by Amazon Web Services Region. That is, two streams in+-- two different Amazon Web Services accounts can have the same name. Two+-- streams in the same Amazon Web Services account but in two different+-- Regions can also have the same name.+newCreateStream ::+  -- | 'streamName'+  Prelude.Text ->+  CreateStream+newCreateStream pStreamName_ =+  CreateStream'+    { shardCount = Prelude.Nothing,+      streamModeDetails = Prelude.Nothing,+      streamName = pStreamName_+    }++-- | The number of shards that the stream will use. The throughput of the+-- stream is a function of the number of shards; more shards are required+-- for greater provisioned throughput.+createStream_shardCount :: Lens.Lens' CreateStream (Prelude.Maybe Prelude.Natural)+createStream_shardCount = Lens.lens (\CreateStream' {shardCount} -> shardCount) (\s@CreateStream' {} a -> s {shardCount = a} :: CreateStream)++-- | Indicates the capacity mode of the data stream. Currently, in Kinesis+-- Data Streams, you can choose between an __on-demand__ capacity mode and+-- a __provisioned__ capacity mode for your data streams.+createStream_streamModeDetails :: Lens.Lens' CreateStream (Prelude.Maybe StreamModeDetails)+createStream_streamModeDetails = Lens.lens (\CreateStream' {streamModeDetails} -> streamModeDetails) (\s@CreateStream' {} a -> s {streamModeDetails = a} :: CreateStream)++-- | A name to identify the stream. The stream name is scoped to the Amazon+-- Web Services account used by the application that creates the stream. It+-- is also scoped by Amazon Web Services Region. That is, two streams in+-- two different Amazon Web Services accounts can have the same name. Two+-- streams in the same Amazon Web Services account but in two different+-- Regions can also have the same name.+createStream_streamName :: Lens.Lens' CreateStream Prelude.Text+createStream_streamName = Lens.lens (\CreateStream' {streamName} -> streamName) (\s@CreateStream' {} a -> s {streamName = a} :: CreateStream)++instance Core.AWSRequest CreateStream where+  type AWSResponse CreateStream = CreateStreamResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response = Response.receiveNull CreateStreamResponse'++instance Prelude.Hashable CreateStream where+  hashWithSalt _salt CreateStream' {..} =+    _salt+      `Prelude.hashWithSalt` shardCount+      `Prelude.hashWithSalt` streamModeDetails+      `Prelude.hashWithSalt` streamName++instance Prelude.NFData CreateStream where+  rnf CreateStream' {..} =+    Prelude.rnf shardCount+      `Prelude.seq` Prelude.rnf streamModeDetails+      `Prelude.seq` Prelude.rnf streamName++instance Data.ToHeaders CreateStream where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.CreateStream" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON CreateStream where+  toJSON CreateStream' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("ShardCount" Data..=) Prelude.<$> shardCount,+            ("StreamModeDetails" Data..=)+              Prelude.<$> streamModeDetails,+            Prelude.Just ("StreamName" Data..= streamName)+          ]+      )++instance Data.ToPath CreateStream where+  toPath = Prelude.const "/"++instance Data.ToQuery CreateStream where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newCreateStreamResponse' smart constructor.+data CreateStreamResponse = CreateStreamResponse'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'CreateStreamResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newCreateStreamResponse ::+  CreateStreamResponse+newCreateStreamResponse = CreateStreamResponse'++instance Prelude.NFData CreateStreamResponse where+  rnf _ = ()

@@ -0,0 +1,194 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.DecreaseStreamRetentionPeriod+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Decreases the Kinesis data stream\'s retention period, which is the+-- length of time data records are accessible after they are added to the+-- stream. The minimum value of a stream\'s retention period is 24 hours.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+--+-- This operation may result in lost data. For example, if the stream\'s+-- retention period is 48 hours and is decreased to 24 hours, any data+-- already in the stream that is older than 24 hours is inaccessible.+module Amazonka.Kinesis.DecreaseStreamRetentionPeriod+  ( -- * Creating a Request+    DecreaseStreamRetentionPeriod (..),+    newDecreaseStreamRetentionPeriod,++    -- * Request Lenses+    decreaseStreamRetentionPeriod_streamARN,+    decreaseStreamRetentionPeriod_streamName,+    decreaseStreamRetentionPeriod_retentionPeriodHours,++    -- * Destructuring the Response+    DecreaseStreamRetentionPeriodResponse (..),+    newDecreaseStreamRetentionPeriodResponse,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for DecreaseStreamRetentionPeriod.+--+-- /See:/ 'newDecreaseStreamRetentionPeriod' smart constructor.+data DecreaseStreamRetentionPeriod = DecreaseStreamRetentionPeriod'+  { -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the stream to modify.+    streamName :: Prelude.Maybe Prelude.Text,+    -- | The new retention period of the stream, in hours. Must be less than the+    -- current retention period.+    retentionPeriodHours :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DecreaseStreamRetentionPeriod' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'streamARN', 'decreaseStreamRetentionPeriod_streamARN' - The ARN of the stream.+--+-- 'streamName', 'decreaseStreamRetentionPeriod_streamName' - The name of the stream to modify.+--+-- 'retentionPeriodHours', 'decreaseStreamRetentionPeriod_retentionPeriodHours' - The new retention period of the stream, in hours. Must be less than the+-- current retention period.+newDecreaseStreamRetentionPeriod ::+  -- | 'retentionPeriodHours'+  Prelude.Int ->+  DecreaseStreamRetentionPeriod+newDecreaseStreamRetentionPeriod+  pRetentionPeriodHours_ =+    DecreaseStreamRetentionPeriod'+      { streamARN =+          Prelude.Nothing,+        streamName = Prelude.Nothing,+        retentionPeriodHours =+          pRetentionPeriodHours_+      }++-- | The ARN of the stream.+decreaseStreamRetentionPeriod_streamARN :: Lens.Lens' DecreaseStreamRetentionPeriod (Prelude.Maybe Prelude.Text)+decreaseStreamRetentionPeriod_streamARN = Lens.lens (\DecreaseStreamRetentionPeriod' {streamARN} -> streamARN) (\s@DecreaseStreamRetentionPeriod' {} a -> s {streamARN = a} :: DecreaseStreamRetentionPeriod)++-- | The name of the stream to modify.+decreaseStreamRetentionPeriod_streamName :: Lens.Lens' DecreaseStreamRetentionPeriod (Prelude.Maybe Prelude.Text)+decreaseStreamRetentionPeriod_streamName = Lens.lens (\DecreaseStreamRetentionPeriod' {streamName} -> streamName) (\s@DecreaseStreamRetentionPeriod' {} a -> s {streamName = a} :: DecreaseStreamRetentionPeriod)++-- | The new retention period of the stream, in hours. Must be less than the+-- current retention period.+decreaseStreamRetentionPeriod_retentionPeriodHours :: Lens.Lens' DecreaseStreamRetentionPeriod Prelude.Int+decreaseStreamRetentionPeriod_retentionPeriodHours = Lens.lens (\DecreaseStreamRetentionPeriod' {retentionPeriodHours} -> retentionPeriodHours) (\s@DecreaseStreamRetentionPeriod' {} a -> s {retentionPeriodHours = a} :: DecreaseStreamRetentionPeriod)++instance+  Core.AWSRequest+    DecreaseStreamRetentionPeriod+  where+  type+    AWSResponse DecreaseStreamRetentionPeriod =+      DecreaseStreamRetentionPeriodResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveNull+      DecreaseStreamRetentionPeriodResponse'++instance+  Prelude.Hashable+    DecreaseStreamRetentionPeriod+  where+  hashWithSalt _salt DecreaseStreamRetentionPeriod' {..} =+    _salt+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName+      `Prelude.hashWithSalt` retentionPeriodHours++instance Prelude.NFData DecreaseStreamRetentionPeriod where+  rnf DecreaseStreamRetentionPeriod' {..} =+    Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName+      `Prelude.seq` Prelude.rnf retentionPeriodHours++instance Data.ToHeaders DecreaseStreamRetentionPeriod where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.DecreaseStreamRetentionPeriod" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DecreaseStreamRetentionPeriod where+  toJSON DecreaseStreamRetentionPeriod' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName,+            Prelude.Just+              ( "RetentionPeriodHours"+                  Data..= retentionPeriodHours+              )+          ]+      )++instance Data.ToPath DecreaseStreamRetentionPeriod where+  toPath = Prelude.const "/"++instance Data.ToQuery DecreaseStreamRetentionPeriod where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newDecreaseStreamRetentionPeriodResponse' smart constructor.+data DecreaseStreamRetentionPeriodResponse = DecreaseStreamRetentionPeriodResponse'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DecreaseStreamRetentionPeriodResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newDecreaseStreamRetentionPeriodResponse ::+  DecreaseStreamRetentionPeriodResponse+newDecreaseStreamRetentionPeriodResponse =+  DecreaseStreamRetentionPeriodResponse'++instance+  Prelude.NFData+    DecreaseStreamRetentionPeriodResponse+  where+  rnf _ = ()

@@ -0,0 +1,190 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.DeleteStream+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Deletes a Kinesis data stream and all its shards and data. You must shut+-- down any applications that are operating on the stream before you delete+-- the stream. If an application attempts to operate on a deleted stream,+-- it receives the exception @ResourceNotFoundException@.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+--+-- If the stream is in the @ACTIVE@ state, you can delete it. After a+-- @DeleteStream@ request, the specified stream is in the @DELETING@ state+-- until Kinesis Data Streams completes the deletion.+--+-- __Note:__ Kinesis Data Streams might continue to accept data read and+-- write operations, such as PutRecord, PutRecords, and GetRecords, on a+-- stream in the @DELETING@ state until the stream deletion is complete.+--+-- When you delete a stream, any shards in that stream are also deleted,+-- and any tags are dissociated from the stream.+--+-- You can use the DescribeStreamSummary operation to check the state of+-- the stream, which is returned in @StreamStatus@.+--+-- DeleteStream has a limit of five transactions per second per account.+module Amazonka.Kinesis.DeleteStream+  ( -- * Creating a Request+    DeleteStream (..),+    newDeleteStream,++    -- * Request Lenses+    deleteStream_enforceConsumerDeletion,+    deleteStream_streamARN,+    deleteStream_streamName,++    -- * Destructuring the Response+    DeleteStreamResponse (..),+    newDeleteStreamResponse,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for DeleteStream.+--+-- /See:/ 'newDeleteStream' smart constructor.+data DeleteStream = DeleteStream'+  { -- | If this parameter is unset (@null@) or if you set it to @false@, and the+    -- stream has registered consumers, the call to @DeleteStream@ fails with a+    -- @ResourceInUseException@.+    enforceConsumerDeletion :: Prelude.Maybe Prelude.Bool,+    -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the stream to delete.+    streamName :: Prelude.Maybe Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DeleteStream' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'enforceConsumerDeletion', 'deleteStream_enforceConsumerDeletion' - If this parameter is unset (@null@) or if you set it to @false@, and the+-- stream has registered consumers, the call to @DeleteStream@ fails with a+-- @ResourceInUseException@.+--+-- 'streamARN', 'deleteStream_streamARN' - The ARN of the stream.+--+-- 'streamName', 'deleteStream_streamName' - The name of the stream to delete.+newDeleteStream ::+  DeleteStream+newDeleteStream =+  DeleteStream'+    { enforceConsumerDeletion =+        Prelude.Nothing,+      streamARN = Prelude.Nothing,+      streamName = Prelude.Nothing+    }++-- | If this parameter is unset (@null@) or if you set it to @false@, and the+-- stream has registered consumers, the call to @DeleteStream@ fails with a+-- @ResourceInUseException@.+deleteStream_enforceConsumerDeletion :: Lens.Lens' DeleteStream (Prelude.Maybe Prelude.Bool)+deleteStream_enforceConsumerDeletion = Lens.lens (\DeleteStream' {enforceConsumerDeletion} -> enforceConsumerDeletion) (\s@DeleteStream' {} a -> s {enforceConsumerDeletion = a} :: DeleteStream)++-- | The ARN of the stream.+deleteStream_streamARN :: Lens.Lens' DeleteStream (Prelude.Maybe Prelude.Text)+deleteStream_streamARN = Lens.lens (\DeleteStream' {streamARN} -> streamARN) (\s@DeleteStream' {} a -> s {streamARN = a} :: DeleteStream)++-- | The name of the stream to delete.+deleteStream_streamName :: Lens.Lens' DeleteStream (Prelude.Maybe Prelude.Text)+deleteStream_streamName = Lens.lens (\DeleteStream' {streamName} -> streamName) (\s@DeleteStream' {} a -> s {streamName = a} :: DeleteStream)++instance Core.AWSRequest DeleteStream where+  type AWSResponse DeleteStream = DeleteStreamResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response = Response.receiveNull DeleteStreamResponse'++instance Prelude.Hashable DeleteStream where+  hashWithSalt _salt DeleteStream' {..} =+    _salt+      `Prelude.hashWithSalt` enforceConsumerDeletion+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName++instance Prelude.NFData DeleteStream where+  rnf DeleteStream' {..} =+    Prelude.rnf enforceConsumerDeletion+      `Prelude.seq` Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName++instance Data.ToHeaders DeleteStream where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.DeleteStream" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DeleteStream where+  toJSON DeleteStream' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("EnforceConsumerDeletion" Data..=)+              Prelude.<$> enforceConsumerDeletion,+            ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName+          ]+      )++instance Data.ToPath DeleteStream where+  toPath = Prelude.const "/"++instance Data.ToQuery DeleteStream where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newDeleteStreamResponse' smart constructor.+data DeleteStreamResponse = DeleteStreamResponse'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DeleteStreamResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newDeleteStreamResponse ::+  DeleteStreamResponse+newDeleteStreamResponse = DeleteStreamResponse'++instance Prelude.NFData DeleteStreamResponse where+  rnf _ = ()

@@ -0,0 +1,197 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.DeregisterStreamConsumer+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- To deregister a consumer, provide its ARN. Alternatively, you can+-- provide the ARN of the data stream and the name you gave the consumer+-- when you registered it. You may also provide all three parameters, as+-- long as they don\'t conflict with each other. If you don\'t know the+-- name or ARN of the consumer that you want to deregister, you can use the+-- ListStreamConsumers operation to get a list of the descriptions of all+-- the consumers that are currently registered with a given data stream.+-- The description of a consumer contains its name and ARN.+--+-- This operation has a limit of five transactions per second per stream.+module Amazonka.Kinesis.DeregisterStreamConsumer+  ( -- * Creating a Request+    DeregisterStreamConsumer (..),+    newDeregisterStreamConsumer,++    -- * Request Lenses+    deregisterStreamConsumer_consumerARN,+    deregisterStreamConsumer_consumerName,+    deregisterStreamConsumer_streamARN,++    -- * Destructuring the Response+    DeregisterStreamConsumerResponse (..),+    newDeregisterStreamConsumerResponse,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | /See:/ 'newDeregisterStreamConsumer' smart constructor.+data DeregisterStreamConsumer = DeregisterStreamConsumer'+  { -- | The ARN returned by Kinesis Data Streams when you registered the+    -- consumer. If you don\'t know the ARN of the consumer that you want to+    -- deregister, you can use the ListStreamConsumers operation to get a list+    -- of the descriptions of all the consumers that are currently registered+    -- with a given data stream. The description of a consumer contains its+    -- ARN.+    consumerARN :: Prelude.Maybe Prelude.Text,+    -- | The name that you gave to the consumer.+    consumerName :: Prelude.Maybe Prelude.Text,+    -- | The ARN of the Kinesis data stream that the consumer is registered with.+    -- For more information, see+    -- <https://docs.aws.amazon.com/general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-kinesis-streams Amazon Resource Names (ARNs) and Amazon Web Services Service Namespaces>.+    streamARN :: Prelude.Maybe Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DeregisterStreamConsumer' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'consumerARN', 'deregisterStreamConsumer_consumerARN' - The ARN returned by Kinesis Data Streams when you registered the+-- consumer. If you don\'t know the ARN of the consumer that you want to+-- deregister, you can use the ListStreamConsumers operation to get a list+-- of the descriptions of all the consumers that are currently registered+-- with a given data stream. The description of a consumer contains its+-- ARN.+--+-- 'consumerName', 'deregisterStreamConsumer_consumerName' - The name that you gave to the consumer.+--+-- 'streamARN', 'deregisterStreamConsumer_streamARN' - The ARN of the Kinesis data stream that the consumer is registered with.+-- For more information, see+-- <https://docs.aws.amazon.com/general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-kinesis-streams Amazon Resource Names (ARNs) and Amazon Web Services Service Namespaces>.+newDeregisterStreamConsumer ::+  DeregisterStreamConsumer+newDeregisterStreamConsumer =+  DeregisterStreamConsumer'+    { consumerARN =+        Prelude.Nothing,+      consumerName = Prelude.Nothing,+      streamARN = Prelude.Nothing+    }++-- | The ARN returned by Kinesis Data Streams when you registered the+-- consumer. If you don\'t know the ARN of the consumer that you want to+-- deregister, you can use the ListStreamConsumers operation to get a list+-- of the descriptions of all the consumers that are currently registered+-- with a given data stream. The description of a consumer contains its+-- ARN.+deregisterStreamConsumer_consumerARN :: Lens.Lens' DeregisterStreamConsumer (Prelude.Maybe Prelude.Text)+deregisterStreamConsumer_consumerARN = Lens.lens (\DeregisterStreamConsumer' {consumerARN} -> consumerARN) (\s@DeregisterStreamConsumer' {} a -> s {consumerARN = a} :: DeregisterStreamConsumer)++-- | The name that you gave to the consumer.+deregisterStreamConsumer_consumerName :: Lens.Lens' DeregisterStreamConsumer (Prelude.Maybe Prelude.Text)+deregisterStreamConsumer_consumerName = Lens.lens (\DeregisterStreamConsumer' {consumerName} -> consumerName) (\s@DeregisterStreamConsumer' {} a -> s {consumerName = a} :: DeregisterStreamConsumer)++-- | The ARN of the Kinesis data stream that the consumer is registered with.+-- For more information, see+-- <https://docs.aws.amazon.com/general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-kinesis-streams Amazon Resource Names (ARNs) and Amazon Web Services Service Namespaces>.+deregisterStreamConsumer_streamARN :: Lens.Lens' DeregisterStreamConsumer (Prelude.Maybe Prelude.Text)+deregisterStreamConsumer_streamARN = Lens.lens (\DeregisterStreamConsumer' {streamARN} -> streamARN) (\s@DeregisterStreamConsumer' {} a -> s {streamARN = a} :: DeregisterStreamConsumer)++instance Core.AWSRequest DeregisterStreamConsumer where+  type+    AWSResponse DeregisterStreamConsumer =+      DeregisterStreamConsumerResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveNull+      DeregisterStreamConsumerResponse'++instance Prelude.Hashable DeregisterStreamConsumer where+  hashWithSalt _salt DeregisterStreamConsumer' {..} =+    _salt+      `Prelude.hashWithSalt` consumerARN+      `Prelude.hashWithSalt` consumerName+      `Prelude.hashWithSalt` streamARN++instance Prelude.NFData DeregisterStreamConsumer where+  rnf DeregisterStreamConsumer' {..} =+    Prelude.rnf consumerARN+      `Prelude.seq` Prelude.rnf consumerName+      `Prelude.seq` Prelude.rnf streamARN++instance Data.ToHeaders DeregisterStreamConsumer where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.DeregisterStreamConsumer" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DeregisterStreamConsumer where+  toJSON DeregisterStreamConsumer' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("ConsumerARN" Data..=) Prelude.<$> consumerARN,+            ("ConsumerName" Data..=) Prelude.<$> consumerName,+            ("StreamARN" Data..=) Prelude.<$> streamARN+          ]+      )++instance Data.ToPath DeregisterStreamConsumer where+  toPath = Prelude.const "/"++instance Data.ToQuery DeregisterStreamConsumer where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newDeregisterStreamConsumerResponse' smart constructor.+data DeregisterStreamConsumerResponse = DeregisterStreamConsumerResponse'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DeregisterStreamConsumerResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newDeregisterStreamConsumerResponse ::+  DeregisterStreamConsumerResponse+newDeregisterStreamConsumerResponse =+  DeregisterStreamConsumerResponse'++instance+  Prelude.NFData+    DeregisterStreamConsumerResponse+  where+  rnf _ = ()

@@ -0,0 +1,202 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.DescribeLimits+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Describes the shard limits and usage for the account.+--+-- If you update your account limits, the old limits might be returned for+-- a few minutes.+--+-- This operation has a limit of one transaction per second per account.+module Amazonka.Kinesis.DescribeLimits+  ( -- * Creating a Request+    DescribeLimits (..),+    newDescribeLimits,++    -- * Destructuring the Response+    DescribeLimitsResponse (..),+    newDescribeLimitsResponse,++    -- * Response Lenses+    describeLimitsResponse_httpStatus,+    describeLimitsResponse_shardLimit,+    describeLimitsResponse_openShardCount,+    describeLimitsResponse_onDemandStreamCount,+    describeLimitsResponse_onDemandStreamCountLimit,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | /See:/ 'newDescribeLimits' smart constructor.+data DescribeLimits = DescribeLimits'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeLimits' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newDescribeLimits ::+  DescribeLimits+newDescribeLimits = DescribeLimits'++instance Core.AWSRequest DescribeLimits where+  type+    AWSResponse DescribeLimits =+      DescribeLimitsResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          DescribeLimitsResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "ShardLimit")+            Prelude.<*> (x Data..:> "OpenShardCount")+            Prelude.<*> (x Data..:> "OnDemandStreamCount")+            Prelude.<*> (x Data..:> "OnDemandStreamCountLimit")+      )++instance Prelude.Hashable DescribeLimits where+  hashWithSalt _salt _ =+    _salt `Prelude.hashWithSalt` ()++instance Prelude.NFData DescribeLimits where+  rnf _ = ()++instance Data.ToHeaders DescribeLimits where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.DescribeLimits" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DescribeLimits where+  toJSON = Prelude.const (Data.Object Prelude.mempty)++instance Data.ToPath DescribeLimits where+  toPath = Prelude.const "/"++instance Data.ToQuery DescribeLimits where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newDescribeLimitsResponse' smart constructor.+data DescribeLimitsResponse = DescribeLimitsResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | The maximum number of shards.+    shardLimit :: Prelude.Natural,+    -- | The number of open shards.+    openShardCount :: Prelude.Natural,+    -- | Indicates the number of data streams with the on-demand capacity mode.+    onDemandStreamCount :: Prelude.Natural,+    -- | The maximum number of data streams with the on-demand capacity mode.+    onDemandStreamCountLimit :: Prelude.Natural+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeLimitsResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'describeLimitsResponse_httpStatus' - The response's http status code.+--+-- 'shardLimit', 'describeLimitsResponse_shardLimit' - The maximum number of shards.+--+-- 'openShardCount', 'describeLimitsResponse_openShardCount' - The number of open shards.+--+-- 'onDemandStreamCount', 'describeLimitsResponse_onDemandStreamCount' - Indicates the number of data streams with the on-demand capacity mode.+--+-- 'onDemandStreamCountLimit', 'describeLimitsResponse_onDemandStreamCountLimit' - The maximum number of data streams with the on-demand capacity mode.+newDescribeLimitsResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'shardLimit'+  Prelude.Natural ->+  -- | 'openShardCount'+  Prelude.Natural ->+  -- | 'onDemandStreamCount'+  Prelude.Natural ->+  -- | 'onDemandStreamCountLimit'+  Prelude.Natural ->+  DescribeLimitsResponse+newDescribeLimitsResponse+  pHttpStatus_+  pShardLimit_+  pOpenShardCount_+  pOnDemandStreamCount_+  pOnDemandStreamCountLimit_ =+    DescribeLimitsResponse'+      { httpStatus = pHttpStatus_,+        shardLimit = pShardLimit_,+        openShardCount = pOpenShardCount_,+        onDemandStreamCount = pOnDemandStreamCount_,+        onDemandStreamCountLimit =+          pOnDemandStreamCountLimit_+      }++-- | The response's http status code.+describeLimitsResponse_httpStatus :: Lens.Lens' DescribeLimitsResponse Prelude.Int+describeLimitsResponse_httpStatus = Lens.lens (\DescribeLimitsResponse' {httpStatus} -> httpStatus) (\s@DescribeLimitsResponse' {} a -> s {httpStatus = a} :: DescribeLimitsResponse)++-- | The maximum number of shards.+describeLimitsResponse_shardLimit :: Lens.Lens' DescribeLimitsResponse Prelude.Natural+describeLimitsResponse_shardLimit = Lens.lens (\DescribeLimitsResponse' {shardLimit} -> shardLimit) (\s@DescribeLimitsResponse' {} a -> s {shardLimit = a} :: DescribeLimitsResponse)++-- | The number of open shards.+describeLimitsResponse_openShardCount :: Lens.Lens' DescribeLimitsResponse Prelude.Natural+describeLimitsResponse_openShardCount = Lens.lens (\DescribeLimitsResponse' {openShardCount} -> openShardCount) (\s@DescribeLimitsResponse' {} a -> s {openShardCount = a} :: DescribeLimitsResponse)++-- | Indicates the number of data streams with the on-demand capacity mode.+describeLimitsResponse_onDemandStreamCount :: Lens.Lens' DescribeLimitsResponse Prelude.Natural+describeLimitsResponse_onDemandStreamCount = Lens.lens (\DescribeLimitsResponse' {onDemandStreamCount} -> onDemandStreamCount) (\s@DescribeLimitsResponse' {} a -> s {onDemandStreamCount = a} :: DescribeLimitsResponse)++-- | The maximum number of data streams with the on-demand capacity mode.+describeLimitsResponse_onDemandStreamCountLimit :: Lens.Lens' DescribeLimitsResponse Prelude.Natural+describeLimitsResponse_onDemandStreamCountLimit = Lens.lens (\DescribeLimitsResponse' {onDemandStreamCountLimit} -> onDemandStreamCountLimit) (\s@DescribeLimitsResponse' {} a -> s {onDemandStreamCountLimit = a} :: DescribeLimitsResponse)++instance Prelude.NFData DescribeLimitsResponse where+  rnf DescribeLimitsResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf shardLimit+      `Prelude.seq` Prelude.rnf openShardCount+      `Prelude.seq` Prelude.rnf onDemandStreamCount+      `Prelude.seq` Prelude.rnf onDemandStreamCountLimit

@@ -0,0 +1,310 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.DescribeStream+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Describes the specified Kinesis data stream.+--+-- This API has been revised. It\'s highly recommended that you use the+-- DescribeStreamSummary API to get a summarized description of the+-- specified Kinesis data stream and the ListShards API to list the shards+-- in a specified data stream and obtain information about each shard.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+--+-- The information returned includes the stream name, Amazon Resource Name+-- (ARN), creation time, enhanced metric configuration, and shard map. The+-- shard map is an array of shard objects. For each shard object, there is+-- the hash key and sequence number ranges that the shard spans, and the+-- IDs of any earlier shards that played in a role in creating the shard.+-- Every record ingested in the stream is identified by a sequence number,+-- which is assigned when the record is put into the stream.+--+-- You can limit the number of shards returned by each call. For more+-- information, see+-- <https://docs.aws.amazon.com/kinesis/latest/dev/kinesis-using-sdk-java-retrieve-shards.html Retrieving Shards from a Stream>+-- in the /Amazon Kinesis Data Streams Developer Guide/.+--+-- There are no guarantees about the chronological order shards returned.+-- To process shards in chronological order, use the ID of the parent shard+-- to track the lineage to the oldest shard.+--+-- This operation has a limit of 10 transactions per second per account.+--+-- This operation returns paginated results.+module Amazonka.Kinesis.DescribeStream+  ( -- * Creating a Request+    DescribeStream (..),+    newDescribeStream,++    -- * Request Lenses+    describeStream_exclusiveStartShardId,+    describeStream_limit,+    describeStream_streamARN,+    describeStream_streamName,++    -- * Destructuring the Response+    DescribeStreamResponse (..),+    newDescribeStreamResponse,++    -- * Response Lenses+    describeStreamResponse_httpStatus,+    describeStreamResponse_streamDescription,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for @DescribeStream@.+--+-- /See:/ 'newDescribeStream' smart constructor.+data DescribeStream = DescribeStream'+  { -- | The shard ID of the shard to start with.+    --+    -- Specify this parameter to indicate that you want to describe the stream+    -- starting with the shard whose ID immediately follows+    -- @ExclusiveStartShardId@.+    --+    -- If you don\'t specify this parameter, the default behavior for+    -- @DescribeStream@ is to describe the stream starting with the first shard+    -- in the stream.+    exclusiveStartShardId :: Prelude.Maybe Prelude.Text,+    -- | The maximum number of shards to return in a single call. The default+    -- value is 100. If you specify a value greater than 100, at most 100+    -- results are returned.+    limit :: Prelude.Maybe Prelude.Natural,+    -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the stream to describe.+    streamName :: Prelude.Maybe Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeStream' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'exclusiveStartShardId', 'describeStream_exclusiveStartShardId' - The shard ID of the shard to start with.+--+-- Specify this parameter to indicate that you want to describe the stream+-- starting with the shard whose ID immediately follows+-- @ExclusiveStartShardId@.+--+-- If you don\'t specify this parameter, the default behavior for+-- @DescribeStream@ is to describe the stream starting with the first shard+-- in the stream.+--+-- 'limit', 'describeStream_limit' - The maximum number of shards to return in a single call. The default+-- value is 100. If you specify a value greater than 100, at most 100+-- results are returned.+--+-- 'streamARN', 'describeStream_streamARN' - The ARN of the stream.+--+-- 'streamName', 'describeStream_streamName' - The name of the stream to describe.+newDescribeStream ::+  DescribeStream+newDescribeStream =+  DescribeStream'+    { exclusiveStartShardId =+        Prelude.Nothing,+      limit = Prelude.Nothing,+      streamARN = Prelude.Nothing,+      streamName = Prelude.Nothing+    }++-- | The shard ID of the shard to start with.+--+-- Specify this parameter to indicate that you want to describe the stream+-- starting with the shard whose ID immediately follows+-- @ExclusiveStartShardId@.+--+-- If you don\'t specify this parameter, the default behavior for+-- @DescribeStream@ is to describe the stream starting with the first shard+-- in the stream.+describeStream_exclusiveStartShardId :: Lens.Lens' DescribeStream (Prelude.Maybe Prelude.Text)+describeStream_exclusiveStartShardId = Lens.lens (\DescribeStream' {exclusiveStartShardId} -> exclusiveStartShardId) (\s@DescribeStream' {} a -> s {exclusiveStartShardId = a} :: DescribeStream)++-- | The maximum number of shards to return in a single call. The default+-- value is 100. If you specify a value greater than 100, at most 100+-- results are returned.+describeStream_limit :: Lens.Lens' DescribeStream (Prelude.Maybe Prelude.Natural)+describeStream_limit = Lens.lens (\DescribeStream' {limit} -> limit) (\s@DescribeStream' {} a -> s {limit = a} :: DescribeStream)++-- | The ARN of the stream.+describeStream_streamARN :: Lens.Lens' DescribeStream (Prelude.Maybe Prelude.Text)+describeStream_streamARN = Lens.lens (\DescribeStream' {streamARN} -> streamARN) (\s@DescribeStream' {} a -> s {streamARN = a} :: DescribeStream)++-- | The name of the stream to describe.+describeStream_streamName :: Lens.Lens' DescribeStream (Prelude.Maybe Prelude.Text)+describeStream_streamName = Lens.lens (\DescribeStream' {streamName} -> streamName) (\s@DescribeStream' {} a -> s {streamName = a} :: DescribeStream)++instance Core.AWSPager DescribeStream where+  page rq rs+    | Core.stop+        ( rs+            Lens.^. describeStreamResponse_streamDescription+            Prelude.. streamDescription_hasMoreShards+        ) =+        Prelude.Nothing+    | Prelude.isNothing+        ( rs+            Lens.^? describeStreamResponse_streamDescription+            Prelude.. streamDescription_shards+            Prelude.. Lens._last+            Prelude.. shard_shardId+        ) =+        Prelude.Nothing+    | Prelude.otherwise =+        Prelude.Just+          Prelude.$ rq+          Prelude.& describeStream_exclusiveStartShardId+          Lens..~ rs+          Lens.^? describeStreamResponse_streamDescription+          Prelude.. streamDescription_shards+          Prelude.. Lens._last+          Prelude.. shard_shardId++instance Core.AWSRequest DescribeStream where+  type+    AWSResponse DescribeStream =+      DescribeStreamResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          DescribeStreamResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "StreamDescription")+      )++instance Prelude.Hashable DescribeStream where+  hashWithSalt _salt DescribeStream' {..} =+    _salt+      `Prelude.hashWithSalt` exclusiveStartShardId+      `Prelude.hashWithSalt` limit+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName++instance Prelude.NFData DescribeStream where+  rnf DescribeStream' {..} =+    Prelude.rnf exclusiveStartShardId+      `Prelude.seq` Prelude.rnf limit+      `Prelude.seq` Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName++instance Data.ToHeaders DescribeStream where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.DescribeStream" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DescribeStream where+  toJSON DescribeStream' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("ExclusiveStartShardId" Data..=)+              Prelude.<$> exclusiveStartShardId,+            ("Limit" Data..=) Prelude.<$> limit,+            ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName+          ]+      )++instance Data.ToPath DescribeStream where+  toPath = Prelude.const "/"++instance Data.ToQuery DescribeStream where+  toQuery = Prelude.const Prelude.mempty++-- | Represents the output for @DescribeStream@.+--+-- /See:/ 'newDescribeStreamResponse' smart constructor.+data DescribeStreamResponse = DescribeStreamResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | The current status of the stream, the stream Amazon Resource Name (ARN),+    -- an array of shard objects that comprise the stream, and whether there+    -- are more shards available.+    streamDescription :: StreamDescription+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeStreamResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'describeStreamResponse_httpStatus' - The response's http status code.+--+-- 'streamDescription', 'describeStreamResponse_streamDescription' - The current status of the stream, the stream Amazon Resource Name (ARN),+-- an array of shard objects that comprise the stream, and whether there+-- are more shards available.+newDescribeStreamResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'streamDescription'+  StreamDescription ->+  DescribeStreamResponse+newDescribeStreamResponse+  pHttpStatus_+  pStreamDescription_ =+    DescribeStreamResponse'+      { httpStatus = pHttpStatus_,+        streamDescription = pStreamDescription_+      }++-- | The response's http status code.+describeStreamResponse_httpStatus :: Lens.Lens' DescribeStreamResponse Prelude.Int+describeStreamResponse_httpStatus = Lens.lens (\DescribeStreamResponse' {httpStatus} -> httpStatus) (\s@DescribeStreamResponse' {} a -> s {httpStatus = a} :: DescribeStreamResponse)++-- | The current status of the stream, the stream Amazon Resource Name (ARN),+-- an array of shard objects that comprise the stream, and whether there+-- are more shards available.+describeStreamResponse_streamDescription :: Lens.Lens' DescribeStreamResponse StreamDescription+describeStreamResponse_streamDescription = Lens.lens (\DescribeStreamResponse' {streamDescription} -> streamDescription) (\s@DescribeStreamResponse' {} a -> s {streamDescription = a} :: DescribeStreamResponse)++instance Prelude.NFData DescribeStreamResponse where+  rnf DescribeStreamResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf streamDescription

@@ -0,0 +1,223 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.DescribeStreamConsumer+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- To get the description of a registered consumer, provide the ARN of the+-- consumer. Alternatively, you can provide the ARN of the data stream and+-- the name you gave the consumer when you registered it. You may also+-- provide all three parameters, as long as they don\'t conflict with each+-- other. If you don\'t know the name or ARN of the consumer that you want+-- to describe, you can use the ListStreamConsumers operation to get a list+-- of the descriptions of all the consumers that are currently registered+-- with a given data stream.+--+-- This operation has a limit of 20 transactions per second per stream.+module Amazonka.Kinesis.DescribeStreamConsumer+  ( -- * Creating a Request+    DescribeStreamConsumer (..),+    newDescribeStreamConsumer,++    -- * Request Lenses+    describeStreamConsumer_consumerARN,+    describeStreamConsumer_consumerName,+    describeStreamConsumer_streamARN,++    -- * Destructuring the Response+    DescribeStreamConsumerResponse (..),+    newDescribeStreamConsumerResponse,++    -- * Response Lenses+    describeStreamConsumerResponse_httpStatus,+    describeStreamConsumerResponse_consumerDescription,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | /See:/ 'newDescribeStreamConsumer' smart constructor.+data DescribeStreamConsumer = DescribeStreamConsumer'+  { -- | The ARN returned by Kinesis Data Streams when you registered the+    -- consumer.+    consumerARN :: Prelude.Maybe Prelude.Text,+    -- | The name that you gave to the consumer.+    consumerName :: Prelude.Maybe Prelude.Text,+    -- | The ARN of the Kinesis data stream that the consumer is registered with.+    -- For more information, see+    -- <https://docs.aws.amazon.com/general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-kinesis-streams Amazon Resource Names (ARNs) and Amazon Web Services Service Namespaces>.+    streamARN :: Prelude.Maybe Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeStreamConsumer' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'consumerARN', 'describeStreamConsumer_consumerARN' - The ARN returned by Kinesis Data Streams when you registered the+-- consumer.+--+-- 'consumerName', 'describeStreamConsumer_consumerName' - The name that you gave to the consumer.+--+-- 'streamARN', 'describeStreamConsumer_streamARN' - The ARN of the Kinesis data stream that the consumer is registered with.+-- For more information, see+-- <https://docs.aws.amazon.com/general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-kinesis-streams Amazon Resource Names (ARNs) and Amazon Web Services Service Namespaces>.+newDescribeStreamConsumer ::+  DescribeStreamConsumer+newDescribeStreamConsumer =+  DescribeStreamConsumer'+    { consumerARN =+        Prelude.Nothing,+      consumerName = Prelude.Nothing,+      streamARN = Prelude.Nothing+    }++-- | The ARN returned by Kinesis Data Streams when you registered the+-- consumer.+describeStreamConsumer_consumerARN :: Lens.Lens' DescribeStreamConsumer (Prelude.Maybe Prelude.Text)+describeStreamConsumer_consumerARN = Lens.lens (\DescribeStreamConsumer' {consumerARN} -> consumerARN) (\s@DescribeStreamConsumer' {} a -> s {consumerARN = a} :: DescribeStreamConsumer)++-- | The name that you gave to the consumer.+describeStreamConsumer_consumerName :: Lens.Lens' DescribeStreamConsumer (Prelude.Maybe Prelude.Text)+describeStreamConsumer_consumerName = Lens.lens (\DescribeStreamConsumer' {consumerName} -> consumerName) (\s@DescribeStreamConsumer' {} a -> s {consumerName = a} :: DescribeStreamConsumer)++-- | The ARN of the Kinesis data stream that the consumer is registered with.+-- For more information, see+-- <https://docs.aws.amazon.com/general/latest/gr/aws-arns-and-namespaces.html#arn-syntax-kinesis-streams Amazon Resource Names (ARNs) and Amazon Web Services Service Namespaces>.+describeStreamConsumer_streamARN :: Lens.Lens' DescribeStreamConsumer (Prelude.Maybe Prelude.Text)+describeStreamConsumer_streamARN = Lens.lens (\DescribeStreamConsumer' {streamARN} -> streamARN) (\s@DescribeStreamConsumer' {} a -> s {streamARN = a} :: DescribeStreamConsumer)++instance Core.AWSRequest DescribeStreamConsumer where+  type+    AWSResponse DescribeStreamConsumer =+      DescribeStreamConsumerResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          DescribeStreamConsumerResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "ConsumerDescription")+      )++instance Prelude.Hashable DescribeStreamConsumer where+  hashWithSalt _salt DescribeStreamConsumer' {..} =+    _salt+      `Prelude.hashWithSalt` consumerARN+      `Prelude.hashWithSalt` consumerName+      `Prelude.hashWithSalt` streamARN++instance Prelude.NFData DescribeStreamConsumer where+  rnf DescribeStreamConsumer' {..} =+    Prelude.rnf consumerARN+      `Prelude.seq` Prelude.rnf consumerName+      `Prelude.seq` Prelude.rnf streamARN++instance Data.ToHeaders DescribeStreamConsumer where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.DescribeStreamConsumer" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DescribeStreamConsumer where+  toJSON DescribeStreamConsumer' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("ConsumerARN" Data..=) Prelude.<$> consumerARN,+            ("ConsumerName" Data..=) Prelude.<$> consumerName,+            ("StreamARN" Data..=) Prelude.<$> streamARN+          ]+      )++instance Data.ToPath DescribeStreamConsumer where+  toPath = Prelude.const "/"++instance Data.ToQuery DescribeStreamConsumer where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newDescribeStreamConsumerResponse' smart constructor.+data DescribeStreamConsumerResponse = DescribeStreamConsumerResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | An object that represents the details of the consumer.+    consumerDescription :: ConsumerDescription+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeStreamConsumerResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'describeStreamConsumerResponse_httpStatus' - The response's http status code.+--+-- 'consumerDescription', 'describeStreamConsumerResponse_consumerDescription' - An object that represents the details of the consumer.+newDescribeStreamConsumerResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'consumerDescription'+  ConsumerDescription ->+  DescribeStreamConsumerResponse+newDescribeStreamConsumerResponse+  pHttpStatus_+  pConsumerDescription_ =+    DescribeStreamConsumerResponse'+      { httpStatus =+          pHttpStatus_,+        consumerDescription = pConsumerDescription_+      }++-- | The response's http status code.+describeStreamConsumerResponse_httpStatus :: Lens.Lens' DescribeStreamConsumerResponse Prelude.Int+describeStreamConsumerResponse_httpStatus = Lens.lens (\DescribeStreamConsumerResponse' {httpStatus} -> httpStatus) (\s@DescribeStreamConsumerResponse' {} a -> s {httpStatus = a} :: DescribeStreamConsumerResponse)++-- | An object that represents the details of the consumer.+describeStreamConsumerResponse_consumerDescription :: Lens.Lens' DescribeStreamConsumerResponse ConsumerDescription+describeStreamConsumerResponse_consumerDescription = Lens.lens (\DescribeStreamConsumerResponse' {consumerDescription} -> consumerDescription) (\s@DescribeStreamConsumerResponse' {} a -> s {consumerDescription = a} :: DescribeStreamConsumerResponse)++instance+  Prelude.NFData+    DescribeStreamConsumerResponse+  where+  rnf DescribeStreamConsumerResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf consumerDescription

@@ -0,0 +1,200 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.DescribeStreamSummary+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Provides a summarized description of the specified Kinesis data stream+-- without the shard list.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+--+-- The information returned includes the stream name, Amazon Resource Name+-- (ARN), status, record retention period, approximate creation time,+-- monitoring, encryption details, and open shard count.+--+-- DescribeStreamSummary has a limit of 20 transactions per second per+-- account.+module Amazonka.Kinesis.DescribeStreamSummary+  ( -- * Creating a Request+    DescribeStreamSummary (..),+    newDescribeStreamSummary,++    -- * Request Lenses+    describeStreamSummary_streamARN,+    describeStreamSummary_streamName,++    -- * Destructuring the Response+    DescribeStreamSummaryResponse (..),+    newDescribeStreamSummaryResponse,++    -- * Response Lenses+    describeStreamSummaryResponse_httpStatus,+    describeStreamSummaryResponse_streamDescriptionSummary,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | /See:/ 'newDescribeStreamSummary' smart constructor.+data DescribeStreamSummary = DescribeStreamSummary'+  { -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the stream to describe.+    streamName :: Prelude.Maybe Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeStreamSummary' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'streamARN', 'describeStreamSummary_streamARN' - The ARN of the stream.+--+-- 'streamName', 'describeStreamSummary_streamName' - The name of the stream to describe.+newDescribeStreamSummary ::+  DescribeStreamSummary+newDescribeStreamSummary =+  DescribeStreamSummary'+    { streamARN = Prelude.Nothing,+      streamName = Prelude.Nothing+    }++-- | The ARN of the stream.+describeStreamSummary_streamARN :: Lens.Lens' DescribeStreamSummary (Prelude.Maybe Prelude.Text)+describeStreamSummary_streamARN = Lens.lens (\DescribeStreamSummary' {streamARN} -> streamARN) (\s@DescribeStreamSummary' {} a -> s {streamARN = a} :: DescribeStreamSummary)++-- | The name of the stream to describe.+describeStreamSummary_streamName :: Lens.Lens' DescribeStreamSummary (Prelude.Maybe Prelude.Text)+describeStreamSummary_streamName = Lens.lens (\DescribeStreamSummary' {streamName} -> streamName) (\s@DescribeStreamSummary' {} a -> s {streamName = a} :: DescribeStreamSummary)++instance Core.AWSRequest DescribeStreamSummary where+  type+    AWSResponse DescribeStreamSummary =+      DescribeStreamSummaryResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          DescribeStreamSummaryResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "StreamDescriptionSummary")+      )++instance Prelude.Hashable DescribeStreamSummary where+  hashWithSalt _salt DescribeStreamSummary' {..} =+    _salt+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName++instance Prelude.NFData DescribeStreamSummary where+  rnf DescribeStreamSummary' {..} =+    Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName++instance Data.ToHeaders DescribeStreamSummary where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.DescribeStreamSummary" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DescribeStreamSummary where+  toJSON DescribeStreamSummary' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName+          ]+      )++instance Data.ToPath DescribeStreamSummary where+  toPath = Prelude.const "/"++instance Data.ToQuery DescribeStreamSummary where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newDescribeStreamSummaryResponse' smart constructor.+data DescribeStreamSummaryResponse = DescribeStreamSummaryResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | A StreamDescriptionSummary containing information about the stream.+    streamDescriptionSummary :: StreamDescriptionSummary+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeStreamSummaryResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'describeStreamSummaryResponse_httpStatus' - The response's http status code.+--+-- 'streamDescriptionSummary', 'describeStreamSummaryResponse_streamDescriptionSummary' - A StreamDescriptionSummary containing information about the stream.+newDescribeStreamSummaryResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'streamDescriptionSummary'+  StreamDescriptionSummary ->+  DescribeStreamSummaryResponse+newDescribeStreamSummaryResponse+  pHttpStatus_+  pStreamDescriptionSummary_ =+    DescribeStreamSummaryResponse'+      { httpStatus =+          pHttpStatus_,+        streamDescriptionSummary =+          pStreamDescriptionSummary_+      }++-- | The response's http status code.+describeStreamSummaryResponse_httpStatus :: Lens.Lens' DescribeStreamSummaryResponse Prelude.Int+describeStreamSummaryResponse_httpStatus = Lens.lens (\DescribeStreamSummaryResponse' {httpStatus} -> httpStatus) (\s@DescribeStreamSummaryResponse' {} a -> s {httpStatus = a} :: DescribeStreamSummaryResponse)++-- | A StreamDescriptionSummary containing information about the stream.+describeStreamSummaryResponse_streamDescriptionSummary :: Lens.Lens' DescribeStreamSummaryResponse StreamDescriptionSummary+describeStreamSummaryResponse_streamDescriptionSummary = Lens.lens (\DescribeStreamSummaryResponse' {streamDescriptionSummary} -> streamDescriptionSummary) (\s@DescribeStreamSummaryResponse' {} a -> s {streamDescriptionSummary = a} :: DescribeStreamSummaryResponse)++instance Prelude.NFData DescribeStreamSummaryResponse where+  rnf DescribeStreamSummaryResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf streamDescriptionSummary

@@ -0,0 +1,230 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.DisableEnhancedMonitoring+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Disables enhanced monitoring.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+module Amazonka.Kinesis.DisableEnhancedMonitoring+  ( -- * Creating a Request+    DisableEnhancedMonitoring (..),+    newDisableEnhancedMonitoring,++    -- * Request Lenses+    disableEnhancedMonitoring_streamARN,+    disableEnhancedMonitoring_streamName,+    disableEnhancedMonitoring_shardLevelMetrics,++    -- * Destructuring the Response+    EnhancedMonitoringOutput (..),+    newEnhancedMonitoringOutput,++    -- * Response Lenses+    enhancedMonitoringOutput_currentShardLevelMetrics,+    enhancedMonitoringOutput_desiredShardLevelMetrics,+    enhancedMonitoringOutput_streamARN,+    enhancedMonitoringOutput_streamName,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for DisableEnhancedMonitoring.+--+-- /See:/ 'newDisableEnhancedMonitoring' smart constructor.+data DisableEnhancedMonitoring = DisableEnhancedMonitoring'+  { -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the Kinesis data stream for which to disable enhanced+    -- monitoring.+    streamName :: Prelude.Maybe Prelude.Text,+    -- | List of shard-level metrics to disable.+    --+    -- The following are the valid shard-level metrics. The value \"@ALL@\"+    -- disables every metric.+    --+    -- -   @IncomingBytes@+    --+    -- -   @IncomingRecords@+    --+    -- -   @OutgoingBytes@+    --+    -- -   @OutgoingRecords@+    --+    -- -   @WriteProvisionedThroughputExceeded@+    --+    -- -   @ReadProvisionedThroughputExceeded@+    --+    -- -   @IteratorAgeMilliseconds@+    --+    -- -   @ALL@+    --+    -- For more information, see+    -- <https://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html Monitoring the Amazon Kinesis Data Streams Service with Amazon CloudWatch>+    -- in the /Amazon Kinesis Data Streams Developer Guide/.+    shardLevelMetrics :: [MetricsName]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DisableEnhancedMonitoring' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'streamARN', 'disableEnhancedMonitoring_streamARN' - The ARN of the stream.+--+-- 'streamName', 'disableEnhancedMonitoring_streamName' - The name of the Kinesis data stream for which to disable enhanced+-- monitoring.+--+-- 'shardLevelMetrics', 'disableEnhancedMonitoring_shardLevelMetrics' - List of shard-level metrics to disable.+--+-- The following are the valid shard-level metrics. The value \"@ALL@\"+-- disables every metric.+--+-- -   @IncomingBytes@+--+-- -   @IncomingRecords@+--+-- -   @OutgoingBytes@+--+-- -   @OutgoingRecords@+--+-- -   @WriteProvisionedThroughputExceeded@+--+-- -   @ReadProvisionedThroughputExceeded@+--+-- -   @IteratorAgeMilliseconds@+--+-- -   @ALL@+--+-- For more information, see+-- <https://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html Monitoring the Amazon Kinesis Data Streams Service with Amazon CloudWatch>+-- in the /Amazon Kinesis Data Streams Developer Guide/.+newDisableEnhancedMonitoring ::+  DisableEnhancedMonitoring+newDisableEnhancedMonitoring =+  DisableEnhancedMonitoring'+    { streamARN =+        Prelude.Nothing,+      streamName = Prelude.Nothing,+      shardLevelMetrics = Prelude.mempty+    }++-- | The ARN of the stream.+disableEnhancedMonitoring_streamARN :: Lens.Lens' DisableEnhancedMonitoring (Prelude.Maybe Prelude.Text)+disableEnhancedMonitoring_streamARN = Lens.lens (\DisableEnhancedMonitoring' {streamARN} -> streamARN) (\s@DisableEnhancedMonitoring' {} a -> s {streamARN = a} :: DisableEnhancedMonitoring)++-- | The name of the Kinesis data stream for which to disable enhanced+-- monitoring.+disableEnhancedMonitoring_streamName :: Lens.Lens' DisableEnhancedMonitoring (Prelude.Maybe Prelude.Text)+disableEnhancedMonitoring_streamName = Lens.lens (\DisableEnhancedMonitoring' {streamName} -> streamName) (\s@DisableEnhancedMonitoring' {} a -> s {streamName = a} :: DisableEnhancedMonitoring)++-- | List of shard-level metrics to disable.+--+-- The following are the valid shard-level metrics. The value \"@ALL@\"+-- disables every metric.+--+-- -   @IncomingBytes@+--+-- -   @IncomingRecords@+--+-- -   @OutgoingBytes@+--+-- -   @OutgoingRecords@+--+-- -   @WriteProvisionedThroughputExceeded@+--+-- -   @ReadProvisionedThroughputExceeded@+--+-- -   @IteratorAgeMilliseconds@+--+-- -   @ALL@+--+-- For more information, see+-- <https://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html Monitoring the Amazon Kinesis Data Streams Service with Amazon CloudWatch>+-- in the /Amazon Kinesis Data Streams Developer Guide/.+disableEnhancedMonitoring_shardLevelMetrics :: Lens.Lens' DisableEnhancedMonitoring [MetricsName]+disableEnhancedMonitoring_shardLevelMetrics = Lens.lens (\DisableEnhancedMonitoring' {shardLevelMetrics} -> shardLevelMetrics) (\s@DisableEnhancedMonitoring' {} a -> s {shardLevelMetrics = a} :: DisableEnhancedMonitoring) Prelude.. Lens.coerced++instance Core.AWSRequest DisableEnhancedMonitoring where+  type+    AWSResponse DisableEnhancedMonitoring =+      EnhancedMonitoringOutput+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      (\s h x -> Data.eitherParseJSON x)++instance Prelude.Hashable DisableEnhancedMonitoring where+  hashWithSalt _salt DisableEnhancedMonitoring' {..} =+    _salt+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName+      `Prelude.hashWithSalt` shardLevelMetrics++instance Prelude.NFData DisableEnhancedMonitoring where+  rnf DisableEnhancedMonitoring' {..} =+    Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName+      `Prelude.seq` Prelude.rnf shardLevelMetrics++instance Data.ToHeaders DisableEnhancedMonitoring where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.DisableEnhancedMonitoring" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DisableEnhancedMonitoring where+  toJSON DisableEnhancedMonitoring' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName,+            Prelude.Just+              ("ShardLevelMetrics" Data..= shardLevelMetrics)+          ]+      )++instance Data.ToPath DisableEnhancedMonitoring where+  toPath = Prelude.const "/"++instance Data.ToQuery DisableEnhancedMonitoring where+  toQuery = Prelude.const Prelude.mempty

@@ -0,0 +1,227 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.EnableEnhancedMonitoring+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Enables enhanced Kinesis data stream monitoring for shard-level metrics.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+module Amazonka.Kinesis.EnableEnhancedMonitoring+  ( -- * Creating a Request+    EnableEnhancedMonitoring (..),+    newEnableEnhancedMonitoring,++    -- * Request Lenses+    enableEnhancedMonitoring_streamARN,+    enableEnhancedMonitoring_streamName,+    enableEnhancedMonitoring_shardLevelMetrics,++    -- * Destructuring the Response+    EnhancedMonitoringOutput (..),+    newEnhancedMonitoringOutput,++    -- * Response Lenses+    enhancedMonitoringOutput_currentShardLevelMetrics,+    enhancedMonitoringOutput_desiredShardLevelMetrics,+    enhancedMonitoringOutput_streamARN,+    enhancedMonitoringOutput_streamName,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for EnableEnhancedMonitoring.+--+-- /See:/ 'newEnableEnhancedMonitoring' smart constructor.+data EnableEnhancedMonitoring = EnableEnhancedMonitoring'+  { -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the stream for which to enable enhanced monitoring.+    streamName :: Prelude.Maybe Prelude.Text,+    -- | List of shard-level metrics to enable.+    --+    -- The following are the valid shard-level metrics. The value \"@ALL@\"+    -- enables every metric.+    --+    -- -   @IncomingBytes@+    --+    -- -   @IncomingRecords@+    --+    -- -   @OutgoingBytes@+    --+    -- -   @OutgoingRecords@+    --+    -- -   @WriteProvisionedThroughputExceeded@+    --+    -- -   @ReadProvisionedThroughputExceeded@+    --+    -- -   @IteratorAgeMilliseconds@+    --+    -- -   @ALL@+    --+    -- For more information, see+    -- <https://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html Monitoring the Amazon Kinesis Data Streams Service with Amazon CloudWatch>+    -- in the /Amazon Kinesis Data Streams Developer Guide/.+    shardLevelMetrics :: [MetricsName]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'EnableEnhancedMonitoring' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'streamARN', 'enableEnhancedMonitoring_streamARN' - The ARN of the stream.+--+-- 'streamName', 'enableEnhancedMonitoring_streamName' - The name of the stream for which to enable enhanced monitoring.+--+-- 'shardLevelMetrics', 'enableEnhancedMonitoring_shardLevelMetrics' - List of shard-level metrics to enable.+--+-- The following are the valid shard-level metrics. The value \"@ALL@\"+-- enables every metric.+--+-- -   @IncomingBytes@+--+-- -   @IncomingRecords@+--+-- -   @OutgoingBytes@+--+-- -   @OutgoingRecords@+--+-- -   @WriteProvisionedThroughputExceeded@+--+-- -   @ReadProvisionedThroughputExceeded@+--+-- -   @IteratorAgeMilliseconds@+--+-- -   @ALL@+--+-- For more information, see+-- <https://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html Monitoring the Amazon Kinesis Data Streams Service with Amazon CloudWatch>+-- in the /Amazon Kinesis Data Streams Developer Guide/.+newEnableEnhancedMonitoring ::+  EnableEnhancedMonitoring+newEnableEnhancedMonitoring =+  EnableEnhancedMonitoring'+    { streamARN =+        Prelude.Nothing,+      streamName = Prelude.Nothing,+      shardLevelMetrics = Prelude.mempty+    }++-- | The ARN of the stream.+enableEnhancedMonitoring_streamARN :: Lens.Lens' EnableEnhancedMonitoring (Prelude.Maybe Prelude.Text)+enableEnhancedMonitoring_streamARN = Lens.lens (\EnableEnhancedMonitoring' {streamARN} -> streamARN) (\s@EnableEnhancedMonitoring' {} a -> s {streamARN = a} :: EnableEnhancedMonitoring)++-- | The name of the stream for which to enable enhanced monitoring.+enableEnhancedMonitoring_streamName :: Lens.Lens' EnableEnhancedMonitoring (Prelude.Maybe Prelude.Text)+enableEnhancedMonitoring_streamName = Lens.lens (\EnableEnhancedMonitoring' {streamName} -> streamName) (\s@EnableEnhancedMonitoring' {} a -> s {streamName = a} :: EnableEnhancedMonitoring)++-- | List of shard-level metrics to enable.+--+-- The following are the valid shard-level metrics. The value \"@ALL@\"+-- enables every metric.+--+-- -   @IncomingBytes@+--+-- -   @IncomingRecords@+--+-- -   @OutgoingBytes@+--+-- -   @OutgoingRecords@+--+-- -   @WriteProvisionedThroughputExceeded@+--+-- -   @ReadProvisionedThroughputExceeded@+--+-- -   @IteratorAgeMilliseconds@+--+-- -   @ALL@+--+-- For more information, see+-- <https://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html Monitoring the Amazon Kinesis Data Streams Service with Amazon CloudWatch>+-- in the /Amazon Kinesis Data Streams Developer Guide/.+enableEnhancedMonitoring_shardLevelMetrics :: Lens.Lens' EnableEnhancedMonitoring [MetricsName]+enableEnhancedMonitoring_shardLevelMetrics = Lens.lens (\EnableEnhancedMonitoring' {shardLevelMetrics} -> shardLevelMetrics) (\s@EnableEnhancedMonitoring' {} a -> s {shardLevelMetrics = a} :: EnableEnhancedMonitoring) Prelude.. Lens.coerced++instance Core.AWSRequest EnableEnhancedMonitoring where+  type+    AWSResponse EnableEnhancedMonitoring =+      EnhancedMonitoringOutput+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      (\s h x -> Data.eitherParseJSON x)++instance Prelude.Hashable EnableEnhancedMonitoring where+  hashWithSalt _salt EnableEnhancedMonitoring' {..} =+    _salt+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName+      `Prelude.hashWithSalt` shardLevelMetrics++instance Prelude.NFData EnableEnhancedMonitoring where+  rnf EnableEnhancedMonitoring' {..} =+    Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName+      `Prelude.seq` Prelude.rnf shardLevelMetrics++instance Data.ToHeaders EnableEnhancedMonitoring where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.EnableEnhancedMonitoring" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON EnableEnhancedMonitoring where+  toJSON EnableEnhancedMonitoring' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName,+            Prelude.Just+              ("ShardLevelMetrics" Data..= shardLevelMetrics)+          ]+      )++instance Data.ToPath EnableEnhancedMonitoring where+  toPath = Prelude.const "/"++instance Data.ToQuery EnableEnhancedMonitoring where+  toQuery = Prelude.const Prelude.mempty

@@ -0,0 +1,337 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.GetRecords+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Gets data records from a Kinesis data stream\'s shard.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter in addition to the @ShardIterator@ parameter.+--+-- Specify a shard iterator using the @ShardIterator@ parameter. The shard+-- iterator specifies the position in the shard from which you want to+-- start reading data records sequentially. If there are no records+-- available in the portion of the shard that the iterator points to,+-- GetRecords returns an empty list. It might take multiple calls to get to+-- a portion of the shard that contains records.+--+-- You can scale by provisioning multiple shards per stream while+-- considering service limits (for more information, see+-- <https://docs.aws.amazon.com/kinesis/latest/dev/service-sizes-and-limits.html Amazon Kinesis Data Streams Limits>+-- in the /Amazon Kinesis Data Streams Developer Guide/). Your application+-- should have one thread per shard, each reading continuously from its+-- stream. To read from a stream continually, call GetRecords in a loop.+-- Use GetShardIterator to get the shard iterator to specify in the first+-- GetRecords call. GetRecords returns a new shard iterator in+-- @NextShardIterator@. Specify the shard iterator returned in+-- @NextShardIterator@ in subsequent calls to GetRecords. If the shard has+-- been closed, the shard iterator can\'t return more data and GetRecords+-- returns @null@ in @NextShardIterator@. You can terminate the loop when+-- the shard is closed, or when the shard iterator reaches the record with+-- the sequence number or other attribute that marks it as the last record+-- to process.+--+-- Each data record can be up to 1 MiB in size, and each shard can read up+-- to 2 MiB per second. You can ensure that your calls don\'t exceed the+-- maximum supported size or throughput by using the @Limit@ parameter to+-- specify the maximum number of records that GetRecords can return.+-- Consider your average record size when determining this limit. The+-- maximum number of records that can be returned per call is 10,000.+--+-- The size of the data returned by GetRecords varies depending on the+-- utilization of the shard. It is recommended that consumer applications+-- retrieve records via the @GetRecords@ command using the 5 TPS limit to+-- remain caught up. Retrieving records less frequently can lead to+-- consumer applications falling behind. The maximum size of data that+-- GetRecords can return is 10 MiB. If a call returns this amount of data,+-- subsequent calls made within the next 5 seconds throw+-- @ProvisionedThroughputExceededException@. If there is insufficient+-- provisioned throughput on the stream, subsequent calls made within the+-- next 1 second throw @ProvisionedThroughputExceededException@. GetRecords+-- doesn\'t return any data when it throws an exception. For this reason,+-- we recommend that you wait 1 second between calls to GetRecords.+-- However, it\'s possible that the application will get exceptions for+-- longer than 1 second.+--+-- To detect whether the application is falling behind in processing, you+-- can use the @MillisBehindLatest@ response attribute. You can also+-- monitor the stream using CloudWatch metrics and other mechanisms (see+-- <https://docs.aws.amazon.com/kinesis/latest/dev/monitoring.html Monitoring>+-- in the /Amazon Kinesis Data Streams Developer Guide/).+--+-- Each Amazon Kinesis record includes a value,+-- @ApproximateArrivalTimestamp@, that is set when a stream successfully+-- receives and stores a record. This is commonly referred to as a+-- server-side time stamp, whereas a client-side time stamp is set when a+-- data producer creates or sends the record to a stream (a data producer+-- is any data source putting data records into a stream, for example with+-- PutRecords). The time stamp has millisecond precision. There are no+-- guarantees about the time stamp accuracy, or that the time stamp is+-- always increasing. For example, records in a shard or across a stream+-- might have time stamps that are out of order.+--+-- This operation has a limit of five transactions per second per shard.+module Amazonka.Kinesis.GetRecords+  ( -- * Creating a Request+    GetRecords (..),+    newGetRecords,++    -- * Request Lenses+    getRecords_limit,+    getRecords_streamARN,+    getRecords_shardIterator,++    -- * Destructuring the Response+    GetRecordsResponse (..),+    newGetRecordsResponse,++    -- * Response Lenses+    getRecordsResponse_childShards,+    getRecordsResponse_millisBehindLatest,+    getRecordsResponse_nextShardIterator,+    getRecordsResponse_httpStatus,+    getRecordsResponse_records,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for GetRecords.+--+-- /See:/ 'newGetRecords' smart constructor.+data GetRecords = GetRecords'+  { -- | The maximum number of records to return. Specify a value of up to+    -- 10,000. If you specify a value that is greater than 10,000, GetRecords+    -- throws @InvalidArgumentException@. The default value is 10,000.+    limit :: Prelude.Maybe Prelude.Natural,+    -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The position in the shard from which you want to start sequentially+    -- reading data records. A shard iterator specifies this position using the+    -- sequence number of a data record in the shard.+    shardIterator :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'GetRecords' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'limit', 'getRecords_limit' - The maximum number of records to return. Specify a value of up to+-- 10,000. If you specify a value that is greater than 10,000, GetRecords+-- throws @InvalidArgumentException@. The default value is 10,000.+--+-- 'streamARN', 'getRecords_streamARN' - The ARN of the stream.+--+-- 'shardIterator', 'getRecords_shardIterator' - The position in the shard from which you want to start sequentially+-- reading data records. A shard iterator specifies this position using the+-- sequence number of a data record in the shard.+newGetRecords ::+  -- | 'shardIterator'+  Prelude.Text ->+  GetRecords+newGetRecords pShardIterator_ =+  GetRecords'+    { limit = Prelude.Nothing,+      streamARN = Prelude.Nothing,+      shardIterator = pShardIterator_+    }++-- | The maximum number of records to return. Specify a value of up to+-- 10,000. If you specify a value that is greater than 10,000, GetRecords+-- throws @InvalidArgumentException@. The default value is 10,000.+getRecords_limit :: Lens.Lens' GetRecords (Prelude.Maybe Prelude.Natural)+getRecords_limit = Lens.lens (\GetRecords' {limit} -> limit) (\s@GetRecords' {} a -> s {limit = a} :: GetRecords)++-- | The ARN of the stream.+getRecords_streamARN :: Lens.Lens' GetRecords (Prelude.Maybe Prelude.Text)+getRecords_streamARN = Lens.lens (\GetRecords' {streamARN} -> streamARN) (\s@GetRecords' {} a -> s {streamARN = a} :: GetRecords)++-- | The position in the shard from which you want to start sequentially+-- reading data records. A shard iterator specifies this position using the+-- sequence number of a data record in the shard.+getRecords_shardIterator :: Lens.Lens' GetRecords Prelude.Text+getRecords_shardIterator = Lens.lens (\GetRecords' {shardIterator} -> shardIterator) (\s@GetRecords' {} a -> s {shardIterator = a} :: GetRecords)++instance Core.AWSRequest GetRecords where+  type AWSResponse GetRecords = GetRecordsResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          GetRecordsResponse'+            Prelude.<$> (x Data..?> "ChildShards" Core..!@ Prelude.mempty)+            Prelude.<*> (x Data..?> "MillisBehindLatest")+            Prelude.<*> (x Data..?> "NextShardIterator")+            Prelude.<*> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..?> "Records" Core..!@ Prelude.mempty)+      )++instance Prelude.Hashable GetRecords where+  hashWithSalt _salt GetRecords' {..} =+    _salt+      `Prelude.hashWithSalt` limit+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` shardIterator++instance Prelude.NFData GetRecords where+  rnf GetRecords' {..} =+    Prelude.rnf limit+      `Prelude.seq` Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf shardIterator++instance Data.ToHeaders GetRecords where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.GetRecords" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON GetRecords where+  toJSON GetRecords' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("Limit" Data..=) Prelude.<$> limit,+            ("StreamARN" Data..=) Prelude.<$> streamARN,+            Prelude.Just+              ("ShardIterator" Data..= shardIterator)+          ]+      )++instance Data.ToPath GetRecords where+  toPath = Prelude.const "/"++instance Data.ToQuery GetRecords where+  toQuery = Prelude.const Prelude.mempty++-- | Represents the output for GetRecords.+--+-- /See:/ 'newGetRecordsResponse' smart constructor.+data GetRecordsResponse = GetRecordsResponse'+  { -- | The list of the current shard\'s child shards, returned in the+    -- @GetRecords@ API\'s response only when the end of the current shard is+    -- reached.+    childShards :: Prelude.Maybe [ChildShard],+    -- | The number of milliseconds the GetRecords response is from the tip of+    -- the stream, indicating how far behind current time the consumer is. A+    -- value of zero indicates that record processing is caught up, and there+    -- are no new records to process at this moment.+    millisBehindLatest :: Prelude.Maybe Prelude.Natural,+    -- | The next position in the shard from which to start sequentially reading+    -- data records. If set to @null@, the shard has been closed and the+    -- requested iterator does not return any more data.+    nextShardIterator :: Prelude.Maybe Prelude.Text,+    -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | The data records retrieved from the shard.+    records :: [Record]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'GetRecordsResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'childShards', 'getRecordsResponse_childShards' - The list of the current shard\'s child shards, returned in the+-- @GetRecords@ API\'s response only when the end of the current shard is+-- reached.+--+-- 'millisBehindLatest', 'getRecordsResponse_millisBehindLatest' - The number of milliseconds the GetRecords response is from the tip of+-- the stream, indicating how far behind current time the consumer is. A+-- value of zero indicates that record processing is caught up, and there+-- are no new records to process at this moment.+--+-- 'nextShardIterator', 'getRecordsResponse_nextShardIterator' - The next position in the shard from which to start sequentially reading+-- data records. If set to @null@, the shard has been closed and the+-- requested iterator does not return any more data.+--+-- 'httpStatus', 'getRecordsResponse_httpStatus' - The response's http status code.+--+-- 'records', 'getRecordsResponse_records' - The data records retrieved from the shard.+newGetRecordsResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  GetRecordsResponse+newGetRecordsResponse pHttpStatus_ =+  GetRecordsResponse'+    { childShards = Prelude.Nothing,+      millisBehindLatest = Prelude.Nothing,+      nextShardIterator = Prelude.Nothing,+      httpStatus = pHttpStatus_,+      records = Prelude.mempty+    }++-- | The list of the current shard\'s child shards, returned in the+-- @GetRecords@ API\'s response only when the end of the current shard is+-- reached.+getRecordsResponse_childShards :: Lens.Lens' GetRecordsResponse (Prelude.Maybe [ChildShard])+getRecordsResponse_childShards = Lens.lens (\GetRecordsResponse' {childShards} -> childShards) (\s@GetRecordsResponse' {} a -> s {childShards = a} :: GetRecordsResponse) Prelude.. Lens.mapping Lens.coerced++-- | The number of milliseconds the GetRecords response is from the tip of+-- the stream, indicating how far behind current time the consumer is. A+-- value of zero indicates that record processing is caught up, and there+-- are no new records to process at this moment.+getRecordsResponse_millisBehindLatest :: Lens.Lens' GetRecordsResponse (Prelude.Maybe Prelude.Natural)+getRecordsResponse_millisBehindLatest = Lens.lens (\GetRecordsResponse' {millisBehindLatest} -> millisBehindLatest) (\s@GetRecordsResponse' {} a -> s {millisBehindLatest = a} :: GetRecordsResponse)++-- | The next position in the shard from which to start sequentially reading+-- data records. If set to @null@, the shard has been closed and the+-- requested iterator does not return any more data.+getRecordsResponse_nextShardIterator :: Lens.Lens' GetRecordsResponse (Prelude.Maybe Prelude.Text)+getRecordsResponse_nextShardIterator = Lens.lens (\GetRecordsResponse' {nextShardIterator} -> nextShardIterator) (\s@GetRecordsResponse' {} a -> s {nextShardIterator = a} :: GetRecordsResponse)++-- | The response's http status code.+getRecordsResponse_httpStatus :: Lens.Lens' GetRecordsResponse Prelude.Int+getRecordsResponse_httpStatus = Lens.lens (\GetRecordsResponse' {httpStatus} -> httpStatus) (\s@GetRecordsResponse' {} a -> s {httpStatus = a} :: GetRecordsResponse)++-- | The data records retrieved from the shard.+getRecordsResponse_records :: Lens.Lens' GetRecordsResponse [Record]+getRecordsResponse_records = Lens.lens (\GetRecordsResponse' {records} -> records) (\s@GetRecordsResponse' {} a -> s {records = a} :: GetRecordsResponse) Prelude.. Lens.coerced++instance Prelude.NFData GetRecordsResponse where+  rnf GetRecordsResponse' {..} =+    Prelude.rnf childShards+      `Prelude.seq` Prelude.rnf millisBehindLatest+      `Prelude.seq` Prelude.rnf nextShardIterator+      `Prelude.seq` Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf records

@@ -0,0 +1,384 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.GetShardIterator+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Gets an Amazon Kinesis shard iterator. A shard iterator expires 5+-- minutes after it is returned to the requester.+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+--+-- A shard iterator specifies the shard position from which to start+-- reading data records sequentially. The position is specified using the+-- sequence number of a data record in a shard. A sequence number is the+-- identifier associated with every record ingested in the stream, and is+-- assigned when a record is put into the stream. Each stream has one or+-- more shards.+--+-- You must specify the shard iterator type. For example, you can set the+-- @ShardIteratorType@ parameter to read exactly from the position denoted+-- by a specific sequence number by using the @AT_SEQUENCE_NUMBER@ shard+-- iterator type. Alternatively, the parameter can read right after the+-- sequence number by using the @AFTER_SEQUENCE_NUMBER@ shard iterator+-- type, using sequence numbers returned by earlier calls to PutRecord,+-- PutRecords, GetRecords, or DescribeStream. In the request, you can+-- specify the shard iterator type @AT_TIMESTAMP@ to read records from an+-- arbitrary point in time, @TRIM_HORIZON@ to cause @ShardIterator@ to+-- point to the last untrimmed record in the shard in the system (the+-- oldest data record in the shard), or @LATEST@ so that you always read+-- the most recent data in the shard.+--+-- When you read repeatedly from a stream, use a GetShardIterator request+-- to get the first shard iterator for use in your first GetRecords request+-- and for subsequent reads use the shard iterator returned by the+-- GetRecords request in @NextShardIterator@. A new shard iterator is+-- returned by every GetRecords request in @NextShardIterator@, which you+-- use in the @ShardIterator@ parameter of the next GetRecords request.+--+-- If a GetShardIterator request is made too often, you receive a+-- @ProvisionedThroughputExceededException@. For more information about+-- throughput limits, see GetRecords, and+-- <https://docs.aws.amazon.com/kinesis/latest/dev/service-sizes-and-limits.html Streams Limits>+-- in the /Amazon Kinesis Data Streams Developer Guide/.+--+-- If the shard is closed, GetShardIterator returns a valid iterator for+-- the last sequence number of the shard. A shard can be closed as a result+-- of using SplitShard or MergeShards.+--+-- GetShardIterator has a limit of five transactions per second per account+-- per open shard.+module Amazonka.Kinesis.GetShardIterator+  ( -- * Creating a Request+    GetShardIterator (..),+    newGetShardIterator,++    -- * Request Lenses+    getShardIterator_startingSequenceNumber,+    getShardIterator_streamARN,+    getShardIterator_streamName,+    getShardIterator_timestamp,+    getShardIterator_shardId,+    getShardIterator_shardIteratorType,++    -- * Destructuring the Response+    GetShardIteratorResponse (..),+    newGetShardIteratorResponse,++    -- * Response Lenses+    getShardIteratorResponse_shardIterator,+    getShardIteratorResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for @GetShardIterator@.+--+-- /See:/ 'newGetShardIterator' smart constructor.+data GetShardIterator = GetShardIterator'+  { -- | The sequence number of the data record in the shard from which to start+    -- reading. Used with shard iterator type AT_SEQUENCE_NUMBER and+    -- AFTER_SEQUENCE_NUMBER.+    startingSequenceNumber :: Prelude.Maybe Prelude.Text,+    -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the Amazon Kinesis data stream.+    streamName :: Prelude.Maybe Prelude.Text,+    -- | The time stamp of the data record from which to start reading. Used with+    -- shard iterator type AT_TIMESTAMP. A time stamp is the Unix epoch date+    -- with precision in milliseconds. For example,+    -- @2016-04-04T19:58:46.480-00:00@ or @1459799926.480@. If a record with+    -- this exact time stamp does not exist, the iterator returned is for the+    -- next (later) record. If the time stamp is older than the current trim+    -- horizon, the iterator returned is for the oldest untrimmed data record+    -- (TRIM_HORIZON).+    timestamp :: Prelude.Maybe Data.POSIX,+    -- | The shard ID of the Kinesis Data Streams shard to get the iterator for.+    shardId :: Prelude.Text,+    -- | Determines how the shard iterator is used to start reading data records+    -- from the shard.+    --+    -- The following are the valid Amazon Kinesis shard iterator types:+    --+    -- -   AT_SEQUENCE_NUMBER - Start reading from the position denoted by a+    --     specific sequence number, provided in the value+    --     @StartingSequenceNumber@.+    --+    -- -   AFTER_SEQUENCE_NUMBER - Start reading right after the position+    --     denoted by a specific sequence number, provided in the value+    --     @StartingSequenceNumber@.+    --+    -- -   AT_TIMESTAMP - Start reading from the position denoted by a specific+    --     time stamp, provided in the value @Timestamp@.+    --+    -- -   TRIM_HORIZON - Start reading at the last untrimmed record in the+    --     shard in the system, which is the oldest data record in the shard.+    --+    -- -   LATEST - Start reading just after the most recent record in the+    --     shard, so that you always read the most recent data in the shard.+    shardIteratorType :: ShardIteratorType+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'GetShardIterator' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'startingSequenceNumber', 'getShardIterator_startingSequenceNumber' - The sequence number of the data record in the shard from which to start+-- reading. Used with shard iterator type AT_SEQUENCE_NUMBER and+-- AFTER_SEQUENCE_NUMBER.+--+-- 'streamARN', 'getShardIterator_streamARN' - The ARN of the stream.+--+-- 'streamName', 'getShardIterator_streamName' - The name of the Amazon Kinesis data stream.+--+-- 'timestamp', 'getShardIterator_timestamp' - The time stamp of the data record from which to start reading. Used with+-- shard iterator type AT_TIMESTAMP. A time stamp is the Unix epoch date+-- with precision in milliseconds. For example,+-- @2016-04-04T19:58:46.480-00:00@ or @1459799926.480@. If a record with+-- this exact time stamp does not exist, the iterator returned is for the+-- next (later) record. If the time stamp is older than the current trim+-- horizon, the iterator returned is for the oldest untrimmed data record+-- (TRIM_HORIZON).+--+-- 'shardId', 'getShardIterator_shardId' - The shard ID of the Kinesis Data Streams shard to get the iterator for.+--+-- 'shardIteratorType', 'getShardIterator_shardIteratorType' - Determines how the shard iterator is used to start reading data records+-- from the shard.+--+-- The following are the valid Amazon Kinesis shard iterator types:+--+-- -   AT_SEQUENCE_NUMBER - Start reading from the position denoted by a+--     specific sequence number, provided in the value+--     @StartingSequenceNumber@.+--+-- -   AFTER_SEQUENCE_NUMBER - Start reading right after the position+--     denoted by a specific sequence number, provided in the value+--     @StartingSequenceNumber@.+--+-- -   AT_TIMESTAMP - Start reading from the position denoted by a specific+--     time stamp, provided in the value @Timestamp@.+--+-- -   TRIM_HORIZON - Start reading at the last untrimmed record in the+--     shard in the system, which is the oldest data record in the shard.+--+-- -   LATEST - Start reading just after the most recent record in the+--     shard, so that you always read the most recent data in the shard.+newGetShardIterator ::+  -- | 'shardId'+  Prelude.Text ->+  -- | 'shardIteratorType'+  ShardIteratorType ->+  GetShardIterator+newGetShardIterator pShardId_ pShardIteratorType_ =+  GetShardIterator'+    { startingSequenceNumber =+        Prelude.Nothing,+      streamARN = Prelude.Nothing,+      streamName = Prelude.Nothing,+      timestamp = Prelude.Nothing,+      shardId = pShardId_,+      shardIteratorType = pShardIteratorType_+    }++-- | The sequence number of the data record in the shard from which to start+-- reading. Used with shard iterator type AT_SEQUENCE_NUMBER and+-- AFTER_SEQUENCE_NUMBER.+getShardIterator_startingSequenceNumber :: Lens.Lens' GetShardIterator (Prelude.Maybe Prelude.Text)+getShardIterator_startingSequenceNumber = Lens.lens (\GetShardIterator' {startingSequenceNumber} -> startingSequenceNumber) (\s@GetShardIterator' {} a -> s {startingSequenceNumber = a} :: GetShardIterator)++-- | The ARN of the stream.+getShardIterator_streamARN :: Lens.Lens' GetShardIterator (Prelude.Maybe Prelude.Text)+getShardIterator_streamARN = Lens.lens (\GetShardIterator' {streamARN} -> streamARN) (\s@GetShardIterator' {} a -> s {streamARN = a} :: GetShardIterator)++-- | The name of the Amazon Kinesis data stream.+getShardIterator_streamName :: Lens.Lens' GetShardIterator (Prelude.Maybe Prelude.Text)+getShardIterator_streamName = Lens.lens (\GetShardIterator' {streamName} -> streamName) (\s@GetShardIterator' {} a -> s {streamName = a} :: GetShardIterator)++-- | The time stamp of the data record from which to start reading. Used with+-- shard iterator type AT_TIMESTAMP. A time stamp is the Unix epoch date+-- with precision in milliseconds. For example,+-- @2016-04-04T19:58:46.480-00:00@ or @1459799926.480@. If a record with+-- this exact time stamp does not exist, the iterator returned is for the+-- next (later) record. If the time stamp is older than the current trim+-- horizon, the iterator returned is for the oldest untrimmed data record+-- (TRIM_HORIZON).+getShardIterator_timestamp :: Lens.Lens' GetShardIterator (Prelude.Maybe Prelude.UTCTime)+getShardIterator_timestamp = Lens.lens (\GetShardIterator' {timestamp} -> timestamp) (\s@GetShardIterator' {} a -> s {timestamp = a} :: GetShardIterator) Prelude.. Lens.mapping Data._Time++-- | The shard ID of the Kinesis Data Streams shard to get the iterator for.+getShardIterator_shardId :: Lens.Lens' GetShardIterator Prelude.Text+getShardIterator_shardId = Lens.lens (\GetShardIterator' {shardId} -> shardId) (\s@GetShardIterator' {} a -> s {shardId = a} :: GetShardIterator)++-- | Determines how the shard iterator is used to start reading data records+-- from the shard.+--+-- The following are the valid Amazon Kinesis shard iterator types:+--+-- -   AT_SEQUENCE_NUMBER - Start reading from the position denoted by a+--     specific sequence number, provided in the value+--     @StartingSequenceNumber@.+--+-- -   AFTER_SEQUENCE_NUMBER - Start reading right after the position+--     denoted by a specific sequence number, provided in the value+--     @StartingSequenceNumber@.+--+-- -   AT_TIMESTAMP - Start reading from the position denoted by a specific+--     time stamp, provided in the value @Timestamp@.+--+-- -   TRIM_HORIZON - Start reading at the last untrimmed record in the+--     shard in the system, which is the oldest data record in the shard.+--+-- -   LATEST - Start reading just after the most recent record in the+--     shard, so that you always read the most recent data in the shard.+getShardIterator_shardIteratorType :: Lens.Lens' GetShardIterator ShardIteratorType+getShardIterator_shardIteratorType = Lens.lens (\GetShardIterator' {shardIteratorType} -> shardIteratorType) (\s@GetShardIterator' {} a -> s {shardIteratorType = a} :: GetShardIterator)++instance Core.AWSRequest GetShardIterator where+  type+    AWSResponse GetShardIterator =+      GetShardIteratorResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          GetShardIteratorResponse'+            Prelude.<$> (x Data..?> "ShardIterator")+            Prelude.<*> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable GetShardIterator where+  hashWithSalt _salt GetShardIterator' {..} =+    _salt+      `Prelude.hashWithSalt` startingSequenceNumber+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName+      `Prelude.hashWithSalt` timestamp+      `Prelude.hashWithSalt` shardId+      `Prelude.hashWithSalt` shardIteratorType++instance Prelude.NFData GetShardIterator where+  rnf GetShardIterator' {..} =+    Prelude.rnf startingSequenceNumber+      `Prelude.seq` Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName+      `Prelude.seq` Prelude.rnf timestamp+      `Prelude.seq` Prelude.rnf shardId+      `Prelude.seq` Prelude.rnf shardIteratorType++instance Data.ToHeaders GetShardIterator where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.GetShardIterator" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON GetShardIterator where+  toJSON GetShardIterator' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("StartingSequenceNumber" Data..=)+              Prelude.<$> startingSequenceNumber,+            ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName,+            ("Timestamp" Data..=) Prelude.<$> timestamp,+            Prelude.Just ("ShardId" Data..= shardId),+            Prelude.Just+              ("ShardIteratorType" Data..= shardIteratorType)+          ]+      )++instance Data.ToPath GetShardIterator where+  toPath = Prelude.const "/"++instance Data.ToQuery GetShardIterator where+  toQuery = Prelude.const Prelude.mempty++-- | Represents the output for @GetShardIterator@.+--+-- /See:/ 'newGetShardIteratorResponse' smart constructor.+data GetShardIteratorResponse = GetShardIteratorResponse'+  { -- | The position in the shard from which to start reading data records+    -- sequentially. A shard iterator specifies this position using the+    -- sequence number of a data record in a shard.+    shardIterator :: Prelude.Maybe Prelude.Text,+    -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'GetShardIteratorResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'shardIterator', 'getShardIteratorResponse_shardIterator' - The position in the shard from which to start reading data records+-- sequentially. A shard iterator specifies this position using the+-- sequence number of a data record in a shard.+--+-- 'httpStatus', 'getShardIteratorResponse_httpStatus' - The response's http status code.+newGetShardIteratorResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  GetShardIteratorResponse+newGetShardIteratorResponse pHttpStatus_ =+  GetShardIteratorResponse'+    { shardIterator =+        Prelude.Nothing,+      httpStatus = pHttpStatus_+    }++-- | The position in the shard from which to start reading data records+-- sequentially. A shard iterator specifies this position using the+-- sequence number of a data record in a shard.+getShardIteratorResponse_shardIterator :: Lens.Lens' GetShardIteratorResponse (Prelude.Maybe Prelude.Text)+getShardIteratorResponse_shardIterator = Lens.lens (\GetShardIteratorResponse' {shardIterator} -> shardIterator) (\s@GetShardIteratorResponse' {} a -> s {shardIterator = a} :: GetShardIteratorResponse)++-- | The response's http status code.+getShardIteratorResponse_httpStatus :: Lens.Lens' GetShardIteratorResponse Prelude.Int+getShardIteratorResponse_httpStatus = Lens.lens (\GetShardIteratorResponse' {httpStatus} -> httpStatus) (\s@GetShardIteratorResponse' {} a -> s {httpStatus = a} :: GetShardIteratorResponse)++instance Prelude.NFData GetShardIteratorResponse where+  rnf GetShardIteratorResponse' {..} =+    Prelude.rnf shardIterator+      `Prelude.seq` Prelude.rnf httpStatus

@@ -0,0 +1,199 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.IncreaseStreamRetentionPeriod+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Increases the Kinesis data stream\'s retention period, which is the+-- length of time data records are accessible after they are added to the+-- stream. The maximum value of a stream\'s retention period is 8760 hours+-- (365 days).+--+-- When invoking this API, it is recommended you use the @StreamARN@ input+-- parameter rather than the @StreamName@ input parameter.+--+-- If you choose a longer stream retention period, this operation increases+-- the time period during which records that have not yet expired are+-- accessible. However, it does not make previous, expired data (older than+-- the stream\'s previous retention period) accessible after the operation+-- has been called. For example, if a stream\'s retention period is set to+-- 24 hours and is increased to 168 hours, any data that is older than 24+-- hours remains inaccessible to consumer applications.+module Amazonka.Kinesis.IncreaseStreamRetentionPeriod+  ( -- * Creating a Request+    IncreaseStreamRetentionPeriod (..),+    newIncreaseStreamRetentionPeriod,++    -- * Request Lenses+    increaseStreamRetentionPeriod_streamARN,+    increaseStreamRetentionPeriod_streamName,+    increaseStreamRetentionPeriod_retentionPeriodHours,++    -- * Destructuring the Response+    IncreaseStreamRetentionPeriodResponse (..),+    newIncreaseStreamRetentionPeriodResponse,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.Kinesis.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Represents the input for IncreaseStreamRetentionPeriod.+--+-- /See:/ 'newIncreaseStreamRetentionPeriod' smart constructor.+data IncreaseStreamRetentionPeriod = IncreaseStreamRetentionPeriod'+  { -- | The ARN of the stream.+    streamARN :: Prelude.Maybe Prelude.Text,+    -- | The name of the stream to modify.+    streamName :: Prelude.Maybe Prelude.Text,+    -- | The new retention period of the stream, in hours. Must be more than the+    -- current retention period.+    retentionPeriodHours :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'IncreaseStreamRetentionPeriod' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'streamARN', 'increaseStreamRetentionPeriod_streamARN' - The ARN of the stream.+--+-- 'streamName', 'increaseStreamRetentionPeriod_streamName' - The name of the stream to modify.+--+-- 'retentionPeriodHours', 'increaseStreamRetentionPeriod_retentionPeriodHours' - The new retention period of the stream, in hours. Must be more than the+-- current retention period.+newIncreaseStreamRetentionPeriod ::+  -- | 'retentionPeriodHours'+  Prelude.Int ->+  IncreaseStreamRetentionPeriod+newIncreaseStreamRetentionPeriod+  pRetentionPeriodHours_ =+    IncreaseStreamRetentionPeriod'+      { streamARN =+          Prelude.Nothing,+        streamName = Prelude.Nothing,+        retentionPeriodHours =+          pRetentionPeriodHours_+      }++-- | The ARN of the stream.+increaseStreamRetentionPeriod_streamARN :: Lens.Lens' IncreaseStreamRetentionPeriod (Prelude.Maybe Prelude.Text)+increaseStreamRetentionPeriod_streamARN = Lens.lens (\IncreaseStreamRetentionPeriod' {streamARN} -> streamARN) (\s@IncreaseStreamRetentionPeriod' {} a -> s {streamARN = a} :: IncreaseStreamRetentionPeriod)++-- | The name of the stream to modify.+increaseStreamRetentionPeriod_streamName :: Lens.Lens' IncreaseStreamRetentionPeriod (Prelude.Maybe Prelude.Text)+increaseStreamRetentionPeriod_streamName = Lens.lens (\IncreaseStreamRetentionPeriod' {streamName} -> streamName) (\s@IncreaseStreamRetentionPeriod' {} a -> s {streamName = a} :: IncreaseStreamRetentionPeriod)++-- | The new retention period of the stream, in hours. Must be more than the+-- current retention period.+increaseStreamRetentionPeriod_retentionPeriodHours :: Lens.Lens' IncreaseStreamRetentionPeriod Prelude.Int+increaseStreamRetentionPeriod_retentionPeriodHours = Lens.lens (\IncreaseStreamRetentionPeriod' {retentionPeriodHours} -> retentionPeriodHours) (\s@IncreaseStreamRetentionPeriod' {} a -> s {retentionPeriodHours = a} :: IncreaseStreamRetentionPeriod)++instance+  Core.AWSRequest+    IncreaseStreamRetentionPeriod+  where+  type+    AWSResponse IncreaseStreamRetentionPeriod =+      IncreaseStreamRetentionPeriodResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveNull+      IncreaseStreamRetentionPeriodResponse'++instance+  Prelude.Hashable+    IncreaseStreamRetentionPeriod+  where+  hashWithSalt _salt IncreaseStreamRetentionPeriod' {..} =+    _salt+      `Prelude.hashWithSalt` streamARN+      `Prelude.hashWithSalt` streamName+      `Prelude.hashWithSalt` retentionPeriodHours++instance Prelude.NFData IncreaseStreamRetentionPeriod where+  rnf IncreaseStreamRetentionPeriod' {..} =+    Prelude.rnf streamARN+      `Prelude.seq` Prelude.rnf streamName+      `Prelude.seq` Prelude.rnf retentionPeriodHours++instance Data.ToHeaders IncreaseStreamRetentionPeriod where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "Kinesis_20131202.IncreaseStreamRetentionPeriod" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON IncreaseStreamRetentionPeriod where+  toJSON IncreaseStreamRetentionPeriod' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("StreamARN" Data..=) Prelude.<$> streamARN,+            ("StreamName" Data..=) Prelude.<$> streamName,+            Prelude.Just+              ( "RetentionPeriodHours"+                  Data..= retentionPeriodHours+              )+          ]+      )++instance Data.ToPath IncreaseStreamRetentionPeriod where+  toPath = Prelude.const "/"++instance Data.ToQuery IncreaseStreamRetentionPeriod where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newIncreaseStreamRetentionPeriodResponse' smart constructor.+data IncreaseStreamRetentionPeriodResponse = IncreaseStreamRetentionPeriodResponse'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'IncreaseStreamRetentionPeriodResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newIncreaseStreamRetentionPeriodResponse ::+  IncreaseStreamRetentionPeriodResponse+newIncreaseStreamRetentionPeriodResponse =+  IncreaseStreamRetentionPeriodResponse'++instance+  Prelude.NFData+    IncreaseStreamRetentionPeriodResponse+  where+  rnf _ = ()

@@ -0,0 +1,398 @@+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-duplicate-exports #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.Kinesis.Lens+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+module Amazonka.Kinesis.Lens+  ( -- * Operations++    -- ** AddTagsToStream+    addTagsToStream_streamARN,+    addTagsToStream_streamName,+    addTagsToStream_tags,++    -- ** CreateStream+    createStream_shardCount,+    createStream_streamModeDetails,+    createStream_streamName,++    -- ** DecreaseStreamRetentionPeriod+    decreaseStreamRetentionPeriod_streamARN,+    decreaseStreamRetentionPeriod_streamName,+    decreaseStreamRetentionPeriod_retentionPeriodHours,++    -- ** DeleteStream+    deleteStream_enforceConsumerDeletion,+    deleteStream_streamARN,+    deleteStream_streamName,++    -- ** DeregisterStreamConsumer+    deregisterStreamConsumer_consumerARN,+    deregisterStreamConsumer_consumerName,+    deregisterStreamConsumer_streamARN,++    -- ** DescribeLimits+    describeLimitsResponse_httpStatus,+    describeLimitsResponse_shardLimit,+    describeLimitsResponse_openShardCount,+    describeLimitsResponse_onDemandStreamCount,+    describeLimitsResponse_onDemandStreamCountLimit,++    -- ** DescribeStream+    describeStream_exclusiveStartShardId,+    describeStream_limit,+    describeStream_streamARN,+    describeStream_streamName,+    describeStreamResponse_httpStatus,+    describeStreamResponse_streamDescription,++    -- ** DescribeStreamConsumer+    describeStreamConsumer_consumerARN,+    describeStreamConsumer_consumerName,+    describeStreamConsumer_streamARN,+    describeStreamConsumerResponse_httpStatus,+    describeStreamConsumerResponse_consumerDescription,++    -- ** DescribeStreamSummary+    describeStreamSummary_streamARN,+    describeStreamSummary_streamName,+    describeStreamSummaryResponse_httpStatus,+    describeStreamSummaryResponse_streamDescriptionSummary,++    -- ** DisableEnhancedMonitoring+    disableEnhancedMonitoring_streamARN,+    disableEnhancedMonitoring_streamName,+    disableEnhancedMonitoring_shardLevelMetrics,+    enhancedMonitoringOutput_currentShardLevelMetrics,+    enhancedMonitoringOutput_desiredShardLevelMetrics,+    enhancedMonitoringOutput_streamARN,+    enhancedMonitoringOutput_streamName,++    -- ** EnableEnhancedMonitoring+    enableEnhancedMonitoring_streamARN,+    enableEnhancedMonitoring_streamName,+    enableEnhancedMonitoring_shardLevelMetrics,+    enhancedMonitoringOutput_currentShardLevelMetrics,+    enhancedMonitoringOutput_desiredShardLevelMetrics,+    enhancedMonitoringOutput_streamARN,+    enhancedMonitoringOutput_streamName,++    -- ** GetRecords+    getRecords_limit,+    getRecords_streamARN,+    getRecords_shardIterator,+    getRecordsResponse_childShards,+    getRecordsResponse_millisBehindLatest,+    getRecordsResponse_nextShardIterator,+    getRecordsResponse_httpStatus,+    getRecordsResponse_records,++    -- ** GetShardIterator+    getShardIterator_startingSequenceNumber,+    getShardIterator_streamARN,+    getShardIterator_streamName,+    getShardIterator_timestamp,+    getShardIterator_shardId,+    getShardIterator_shardIteratorType,+    getShardIteratorResponse_shardIterator,+    getShardIteratorResponse_httpStatus,++    -- ** IncreaseStreamRetentionPeriod+    increaseStreamRetentionPeriod_streamARN,+    increaseStreamRetentionPeriod_streamName,+    increaseStreamRetentionPeriod_retentionPeriodHours,++    -- ** ListShards+    listShards_exclusiveStartShardId,+    listShards_maxResults,+    listShards_nextToken,+    listShards_shardFilter,+    listShards_streamARN,+    listShards_streamCreationTimestamp,+    listShards_streamName,+    listShardsResponse_nextToken,+    listShardsResponse_shards,+    listShardsResponse_httpStatus,++    -- ** ListStreamConsumers+    listStreamConsumers_maxResults,+    listStreamConsumers_nextToken,+    listStreamConsumers_streamCreationTimestamp,+    listStreamConsumers_streamARN,+    listStreamConsumersResponse_consumers,+    listStreamConsumersResponse_nextToken,+    listStreamConsumersResponse_httpStatus,++    -- ** ListStreams+    listStreams_exclusiveStartStreamName,+    listStreams_limit,+    listStreams_nextToken,+    listStreamsResponse_nextToken,+    listStreamsResponse_streamSummaries,+    listStreamsResponse_httpStatus,+    listStreamsResponse_streamNames,+    listStreamsResponse_hasMoreStreams,++    -- ** ListTagsForStream+    listTagsForStream_exclusiveStartTagKey,+    listTagsForStream_limit,+    listTagsForStream_streamARN,+    listTagsForStream_streamName,+    listTagsForStreamResponse_httpStatus,+    listTagsForStreamResponse_tags,+    listTagsForStreamResponse_hasMoreTags,++    -- ** MergeShards+    mergeShards_streamARN,+    mergeShards_streamName,+    mergeShards_shardToMerge,+    mergeShards_adjacentShardToMerge,++    -- ** PutRecord+    putRecord_explicitHashKey,+    putRecord_sequenceNumberForOrdering,+    putRecord_streamARN,+    putRecord_streamName,+    putRecord_data,+    putRecord_partitionKey,+    putRecordResponse_encryptionType,+    putRecordResponse_httpStatus,+    putRecordResponse_shardId,+    putRecordResponse_sequenceNumber,++    -- ** PutRecords+    putRecords_streamARN,+    putRecords_streamName,+    putRecords_records,+    putRecordsResponse_encryptionType,+    putRecordsResponse_failedRecordCount,+    putRecordsResponse_httpStatus,+    putRecordsResponse_records,++    -- ** RegisterStreamConsumer+    registerStreamConsumer_streamARN,+    registerStreamConsumer_consumerName,+    registerStreamConsumerResponse_httpStatus,+    registerStreamConsumerResponse_consumer,++    -- ** RemoveTagsFromStream+    removeTagsFromStream_streamARN,+    removeTagsFromStream_streamName,+    removeTagsFromStream_tagKeys,++    -- ** SplitShard+    splitShard_streamARN,+    splitShard_streamName,+    splitShard_shardToSplit,+    splitShard_newStartingHashKey,++    -- ** StartStreamEncryption+    startStreamEncryption_streamARN,+    startStreamEncryption_streamName,+    startStreamEncryption_encryptionType,+    startStreamEncryption_keyId,++    -- ** StopStreamEncryption+    stopStreamEncryption_streamARN,+    stopStreamEncryption_streamName,+    stopStreamEncryption_encryptionType,+    stopStreamEncryption_keyId,++    -- ** SubscribeToShard+    subscribeToShard_consumerARN,+    subscribeToShard_shardId,+    subscribeToShard_startingPosition,+    subscribeToShardResponse_httpStatus,+    subscribeToShardResponse_eventStream,++    -- ** UpdateShardCount+    updateShardCount_streamARN,+    updateShardCount_streamName,+    updateShardCount_targetShardCount,+    updateShardCount_scalingType,+    updateShardCountResponse_currentShardCount,+    updateShardCountResponse_streamARN,+    updateShardCountResponse_streamName,+    updateShardCountResponse_targetShardCount,+    updateShardCountResponse_httpStatus,++    -- ** UpdateStreamMode+    updateStreamMode_streamARN,+    updateStreamMode_streamModeDetails,++    -- * Types++    -- ** ChildShard+    childShard_shardId,+    childShard_parentShards,+    childShard_hashKeyRange,++    -- ** Consumer+    consumer_consumerName,+    consumer_consumerARN,+    consumer_consumerStatus,+    consumer_consumerCreationTimestamp,++    -- ** ConsumerDescription+    consumerDescription_consumerName,+    consumerDescription_consumerARN,+    consumerDescription_consumerStatus,+    consumerDescription_consumerCreationTimestamp,+    consumerDescription_streamARN,++    -- ** EnhancedMetrics+    enhancedMetrics_shardLevelMetrics,++    -- ** EnhancedMonitoringOutput+    enhancedMonitoringOutput_currentShardLevelMetrics,+    enhancedMonitoringOutput_desiredShardLevelMetrics,+    enhancedMonitoringOutput_streamARN,+    enhancedMonitoringOutput_streamName,++    -- ** HashKeyRange+    hashKeyRange_startingHashKey,+    hashKeyRange_endingHashKey,++    -- ** PutRecordsRequestEntry+    putRecordsRequestEntry_explicitHashKey,+    putRecordsRequestEntry_data,+    putRecordsRequestEntry_partitionKey,++    -- ** PutRecordsResultEntry+    putRecordsResultEntry_errorCode,+    putRecordsResultEntry_errorMessage,+    putRecordsResultEntry_sequenceNumber,+    putRecordsResultEntry_shardId,++    -- ** Record+    record_approximateArrivalTimestamp,+    record_encryptionType,+    record_sequenceNumber,+    record_data,+    record_partitionKey,++    -- ** SequenceNumberRange+    sequenceNumberRange_endingSequenceNumber,+    sequenceNumberRange_startingSequenceNumber,++    -- ** Shard+    shard_adjacentParentShardId,+    shard_parentShardId,+    shard_shardId,+    shard_hashKeyRange,+    shard_sequenceNumberRange,++    -- ** ShardFilter+    shardFilter_shardId,+    shardFilter_timestamp,+    shardFilter_type,++    -- ** StartingPosition+    startingPosition_sequenceNumber,+    startingPosition_timestamp,+    startingPosition_type,++    -- ** StreamDescription+    streamDescription_encryptionType,+    streamDescription_keyId,+    streamDescription_streamModeDetails,+    streamDescription_streamName,+    streamDescription_streamARN,+    streamDescription_streamStatus,+    streamDescription_shards,+    streamDescription_hasMoreShards,+    streamDescription_retentionPeriodHours,+    streamDescription_streamCreationTimestamp,+    streamDescription_enhancedMonitoring,++    -- ** StreamDescriptionSummary+    streamDescriptionSummary_consumerCount,+    streamDescriptionSummary_encryptionType,+    streamDescriptionSummary_keyId,+    streamDescriptionSummary_streamModeDetails,+    streamDescriptionSummary_streamName,+    streamDescriptionSummary_streamARN,+    streamDescriptionSummary_streamStatus,+    streamDescriptionSummary_retentionPeriodHours,+    streamDescriptionSummary_streamCreationTimestamp,+    streamDescriptionSummary_enhancedMonitoring,+    streamDescriptionSummary_openShardCount,++    -- ** StreamModeDetails+    streamModeDetails_streamMode,++    -- ** StreamSummary+    streamSummary_streamCreationTimestamp,+    streamSummary_streamModeDetails,+    streamSummary_streamName,+    streamSummary_streamARN,+    streamSummary_streamStatus,++    -- ** SubscribeToShardEvent+    subscribeToShardEvent_childShards,+    subscribeToShardEvent_records,+    subscribeToShardEvent_continuationSequenceNumber,+    subscribeToShardEvent_millisBehindLatest,++    -- ** Tag+    tag_value,+    tag_key,+  )+where++import Amazonka.Kinesis.AddTagsToStream+import Amazonka.Kinesis.CreateStream+import Amazonka.Kinesis.DecreaseStreamRetentionPeriod+import Amazonka.Kinesis.DeleteStream+import Amazonka.Kinesis.DeregisterStreamConsumer+import Amazonka.Kinesis.DescribeLimits+import Amazonka.Kinesis.DescribeStream+import Amazonka.Kinesis.DescribeStreamConsumer+import Amazonka.Kinesis.DescribeStreamSummary+import Amazonka.Kinesis.DisableEnhancedMonitoring+import Amazonka.Kinesis.EnableEnhancedMonitoring+import Amazonka.Kinesis.GetRecords+import Amazonka.Kinesis.GetShardIterator+import Amazonka.Kinesis.IncreaseStreamRetentionPeriod+import Amazonka.Kinesis.ListShards+import Amazonka.Kinesis.ListStreamConsumers+import Amazonka.Kinesis.ListStreams+import Amazonka.Kinesis.ListTagsForStream+import Amazonka.Kinesis.MergeShards+import Amazonka.Kinesis.PutRecord+import Amazonka.Kinesis.PutRecords+import Amazonka.Kinesis.RegisterStreamConsumer+import Amazonka.Kinesis.RemoveTagsFromStream+import Amazonka.Kinesis.SplitShard+import Amazonka.Kinesis.StartStreamEncryption+import Amazonka.Kinesis.StopStreamEncryption+import Amazonka.Kinesis.SubscribeToShard+import Amazonka.Kinesis.Types.ChildShard+import Amazonka.Kinesis.Types.Consumer+import Amazonka.Kinesis.Types.ConsumerDescription+import Amazonka.Kinesis.Types.EnhancedMetrics+import Amazonka.Kinesis.Types.EnhancedMonitoringOutput+import Amazonka.Kinesis.Types.HashKeyRange+import Amazonka.Kinesis.Types.PutRecordsRequestEntry+import Amazonka.Kinesis.Types.PutRecordsResultEntry+import Amazonka.Kinesis.Types.Record+import Amazonka.Kinesis.Types.SequenceNumberRange+import Amazonka.Kinesis.Types.Shard+import Amazonka.Kinesis.Types.ShardFilter+import Amazonka.Kinesis.Types.StartingPosition+import Amazonka.Kinesis.Types.StreamDescription+import Amazonka.Kinesis.Types.StreamDescriptionSummary+import Amazonka.Kinesis.Types.StreamModeDetails+import Amazonka.Kinesis.Types.StreamSummary+import Amazonka.Kinesis.Types.SubscribeToShardEvent+import Amazonka.Kinesis.Types.Tag+import Amazonka.Kinesis.UpdateShardCount+import Amazonka.Kinesis.UpdateStreamMode