summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBrendanHay <>2017-11-15 08:20:00 (GMT)
committerhdiff <hdiff@hdiff.luite.com>2017-11-15 08:20:00 (GMT)
commit7862d2437ab23504af8a34ac287ba81a00bf25ad (patch)
tree6a8b5323d38044e7b53aca56117ff93dbb0f7042
parent06a55eb2c96306e176889983748e552145733a3c (diff)
version 1.5.01.5.0
-rw-r--r--README.md2
-rw-r--r--amazonka-kinesis.cabal29
-rw-r--r--fixture/StartStreamEncryption.yaml10
-rw-r--r--fixture/StartStreamEncryptionResponse.proto0
-rw-r--r--fixture/StopStreamEncryption.yaml10
-rw-r--r--fixture/StopStreamEncryptionResponse.proto0
-rw-r--r--gen/Network/AWS/Kinesis.hs78
-rw-r--r--gen/Network/AWS/Kinesis/AddTagsToStream.hs41
-rw-r--r--gen/Network/AWS/Kinesis/CreateStream.hs42
-rw-r--r--gen/Network/AWS/Kinesis/DecreaseStreamRetentionPeriod.hs43
-rw-r--r--gen/Network/AWS/Kinesis/DeleteStream.hs39
-rw-r--r--gen/Network/AWS/Kinesis/DescribeLimits.hs48
-rw-r--r--gen/Network/AWS/Kinesis/DescribeStream.hs60
-rw-r--r--gen/Network/AWS/Kinesis/DisableEnhancedMonitoring.hs34
-rw-r--r--gen/Network/AWS/Kinesis/EnableEnhancedMonitoring.hs34
-rw-r--r--gen/Network/AWS/Kinesis/GetRecords.hs59
-rw-r--r--gen/Network/AWS/Kinesis/GetShardIterator.hs64
-rw-r--r--gen/Network/AWS/Kinesis/IncreaseStreamRetentionPeriod.hs43
-rw-r--r--gen/Network/AWS/Kinesis/ListStreams.hs57
-rw-r--r--gen/Network/AWS/Kinesis/ListTagsForStream.hs62
-rw-r--r--gen/Network/AWS/Kinesis/MergeShards.hs48
-rw-r--r--gen/Network/AWS/Kinesis/PutRecord.hs86
-rw-r--r--gen/Network/AWS/Kinesis/PutRecords.hs71
-rw-r--r--gen/Network/AWS/Kinesis/RemoveTagsFromStream.hs42
-rw-r--r--gen/Network/AWS/Kinesis/SplitShard.hs48
-rw-r--r--gen/Network/AWS/Kinesis/StartStreamEncryption.hs141
-rw-r--r--gen/Network/AWS/Kinesis/StopStreamEncryption.hs141
-rw-r--r--gen/Network/AWS/Kinesis/Types.hs129
-rw-r--r--gen/Network/AWS/Kinesis/Types/Product.hs300
-rw-r--r--gen/Network/AWS/Kinesis/Types/Sum.hs84
-rw-r--r--gen/Network/AWS/Kinesis/UpdateShardCount.hs86
-rw-r--r--gen/Network/AWS/Kinesis/Waiters.hs51
-rw-r--r--test/Main.hs4
-rw-r--r--test/Test/AWS/Gen/Kinesis.hs44
34 files changed, 1318 insertions, 712 deletions
diff --git a/README.md b/README.md
index fc71636..27edec4 100644
--- a/README.md
+++ b/README.md
@@ -8,7 +8,7 @@
## Version
-`1.4.5`
+`1.5.0`
## Description
diff --git a/amazonka-kinesis.cabal b/amazonka-kinesis.cabal
index 67998a2..be3372e 100644
--- a/amazonka-kinesis.cabal
+++ b/amazonka-kinesis.cabal
@@ -1,13 +1,13 @@
name: amazonka-kinesis
-version: 1.4.5
+version: 1.5.0
synopsis: Amazon Kinesis SDK.
homepage: https://github.com/brendanhay/amazonka
bug-reports: https://github.com/brendanhay/amazonka/issues
-license: OtherLicense
+license: MPL-2.0
license-file: LICENSE
author: Brendan Hay
-maintainer: Brendan Hay <brendan.g.hay@gmail.com>
-copyright: Copyright (c) 2013-2016 Brendan Hay
+maintainer: Brendan Hay <brendan.g.hay+amazonka@gmail.com>
+copyright: Copyright (c) 2013-2017 Brendan Hay
category: Network, AWS, Cloud, Distributed Computing
build-type: Simple
cabal-version: >= 1.10
@@ -29,14 +29,19 @@ description:
to get started.
source-repository head
- type: git
- location: git://github.com/brendanhay/amazonka.git
+ type: git
+ location: git://github.com/brendanhay/amazonka.git
+ subdir: amazonka-kinesis
library
default-language: Haskell2010
hs-source-dirs: src gen
- ghc-options: -Wall
+ ghc-options:
+ -Wall
+ -fwarn-incomplete-uni-patterns
+ -fwarn-incomplete-record-updates
+ -funbox-strict-fields
exposed-modules:
Network.AWS.Kinesis
@@ -58,6 +63,8 @@ library
, 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
@@ -67,7 +74,7 @@ library
, Network.AWS.Kinesis.Types.Sum
build-depends:
- amazonka-core == 1.4.5.*
+ amazonka-core == 1.5.0.*
, base >= 4.7 && < 5
test-suite amazonka-kinesis-test
@@ -87,9 +94,9 @@ test-suite amazonka-kinesis-test
, Test.AWS.Kinesis.Internal
build-depends:
- amazonka-core == 1.4.5.*
- , amazonka-test == 1.4.5.*
- , amazonka-kinesis == 1.4.5.*
+ amazonka-core == 1.5.0.*
+ , amazonka-test == 1.5.0.*
+ , amazonka-kinesis
, base
, bytestring
, tasty
diff --git a/fixture/StartStreamEncryption.yaml b/fixture/StartStreamEncryption.yaml
new file mode 100644
index 0000000..acc24a2
--- /dev/null
+++ b/fixture/StartStreamEncryption.yaml
@@ -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:
+ ''
diff --git a/fixture/StartStreamEncryptionResponse.proto b/fixture/StartStreamEncryptionResponse.proto
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/fixture/StartStreamEncryptionResponse.proto
diff --git a/fixture/StopStreamEncryption.yaml b/fixture/StopStreamEncryption.yaml
new file mode 100644
index 0000000..acc24a2
--- /dev/null
+++ b/fixture/StopStreamEncryption.yaml
@@ -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:
+ ''
diff --git a/fixture/StopStreamEncryptionResponse.proto b/fixture/StopStreamEncryptionResponse.proto
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/fixture/StopStreamEncryptionResponse.proto
diff --git a/gen/Network/AWS/Kinesis.hs b/gen/Network/AWS/Kinesis.hs
index c91dedd..c5f2016 100644
--- a/gen/Network/AWS/Kinesis.hs
+++ b/gen/Network/AWS/Kinesis.hs
@@ -5,9 +5,9 @@
-- |
-- Module : Network.AWS.Kinesis
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -23,18 +23,36 @@ module Network.AWS.Kinesis
-- * Errors
-- $errors
+ -- ** KMSInvalidStateException
+ , _KMSInvalidStateException
+
+ -- ** KMSThrottlingException
+ , _KMSThrottlingException
+
-- ** ExpiredIteratorException
, _ExpiredIteratorException
-- ** InvalidArgumentException
, _InvalidArgumentException
+ -- ** KMSOptInRequired
+ , _KMSOptInRequired
+
-- ** ProvisionedThroughputExceededException
, _ProvisionedThroughputExceededException
+ -- ** KMSNotFoundException
+ , _KMSNotFoundException
+
+ -- ** KMSDisabledException
+ , _KMSDisabledException
+
-- ** ResourceNotFoundException
, _ResourceNotFoundException
+ -- ** KMSAccessDeniedException
+ , _KMSAccessDeniedException
+
-- ** LimitExceededException
, _LimitExceededException
@@ -68,6 +86,9 @@ module Network.AWS.Kinesis
-- ** GetRecords
, module Network.AWS.Kinesis.GetRecords
+ -- ** StopStreamEncryption
+ , module Network.AWS.Kinesis.StopStreamEncryption
+
-- ** EnableEnhancedMonitoring
, module Network.AWS.Kinesis.EnableEnhancedMonitoring
@@ -101,6 +122,9 @@ module Network.AWS.Kinesis
-- ** CreateStream
, module Network.AWS.Kinesis.CreateStream
+ -- ** StartStreamEncryption
+ , module Network.AWS.Kinesis.StartStreamEncryption
+
-- ** SplitShard
, module Network.AWS.Kinesis.SplitShard
@@ -112,6 +136,9 @@ module Network.AWS.Kinesis
-- * Types
+ -- ** EncryptionType
+ , EncryptionType (..)
+
-- ** MetricsName
, MetricsName (..)
@@ -160,6 +187,7 @@ module Network.AWS.Kinesis
-- ** Record
, Record
, record
+ , rEncryptionType
, rApproximateArrivalTimestamp
, rSequenceNumber
, rData
@@ -183,6 +211,8 @@ module Network.AWS.Kinesis
-- ** StreamDescription
, StreamDescription
, streamDescription
+ , sdEncryptionType
+ , sdKeyId
, sdStreamName
, sdStreamARN
, sdStreamStatus
@@ -199,27 +229,29 @@ module Network.AWS.Kinesis
, tagKey
) where
-import Network.AWS.Kinesis.AddTagsToStream
-import Network.AWS.Kinesis.CreateStream
-import Network.AWS.Kinesis.DecreaseStreamRetentionPeriod
-import Network.AWS.Kinesis.DeleteStream
-import Network.AWS.Kinesis.DescribeLimits
-import Network.AWS.Kinesis.DescribeStream
-import Network.AWS.Kinesis.DisableEnhancedMonitoring
-import Network.AWS.Kinesis.EnableEnhancedMonitoring
-import Network.AWS.Kinesis.GetRecords
-import Network.AWS.Kinesis.GetShardIterator
-import Network.AWS.Kinesis.IncreaseStreamRetentionPeriod
-import Network.AWS.Kinesis.ListStreams
-import Network.AWS.Kinesis.ListTagsForStream
-import Network.AWS.Kinesis.MergeShards
-import Network.AWS.Kinesis.PutRecord
-import Network.AWS.Kinesis.PutRecords
-import Network.AWS.Kinesis.RemoveTagsFromStream
-import Network.AWS.Kinesis.SplitShard
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.UpdateShardCount
-import Network.AWS.Kinesis.Waiters
+import Network.AWS.Kinesis.AddTagsToStream
+import Network.AWS.Kinesis.CreateStream
+import Network.AWS.Kinesis.DecreaseStreamRetentionPeriod
+import Network.AWS.Kinesis.DeleteStream
+import Network.AWS.Kinesis.DescribeLimits
+import Network.AWS.Kinesis.DescribeStream
+import Network.AWS.Kinesis.DisableEnhancedMonitoring
+import Network.AWS.Kinesis.EnableEnhancedMonitoring
+import Network.AWS.Kinesis.GetRecords
+import Network.AWS.Kinesis.GetShardIterator
+import Network.AWS.Kinesis.IncreaseStreamRetentionPeriod
+import Network.AWS.Kinesis.ListStreams
+import Network.AWS.Kinesis.ListTagsForStream
+import Network.AWS.Kinesis.MergeShards
+import Network.AWS.Kinesis.PutRecord
+import Network.AWS.Kinesis.PutRecords
+import Network.AWS.Kinesis.RemoveTagsFromStream
+import Network.AWS.Kinesis.SplitShard
+import Network.AWS.Kinesis.StartStreamEncryption
+import Network.AWS.Kinesis.StopStreamEncryption
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.UpdateShardCount
+import Network.AWS.Kinesis.Waiters
{- $errors
Error matchers are designed for use with the functions provided by
diff --git a/gen/Network/AWS/Kinesis/AddTagsToStream.hs b/gen/Network/AWS/Kinesis/AddTagsToStream.hs
index 9838063..6637d96 100644
--- a/gen/Network/AWS/Kinesis/AddTagsToStream.hs
+++ b/gen/Network/AWS/Kinesis/AddTagsToStream.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.AddTagsToStream
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -37,12 +37,12 @@ module Network.AWS.Kinesis.AddTagsToStream
, AddTagsToStreamResponse
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @AddTagsToStream@ .
--
@@ -50,9 +50,10 @@ import Network.AWS.Response
--
-- /See:/ 'addTagsToStream' smart constructor.
data AddTagsToStream = AddTagsToStream'
- { _attsStreamName :: !Text
- , _attsTags :: !(Map Text Text)
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _attsStreamName :: !Text
+ , _attsTags :: !(Map Text Text)
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'AddTagsToStream' with the minimum fields required to make a request.
--
@@ -65,10 +66,8 @@ addTagsToStream
:: Text -- ^ 'attsStreamName'
-> AddTagsToStream
addTagsToStream pStreamName_ =
- AddTagsToStream'
- { _attsStreamName = pStreamName_
- , _attsTags = mempty
- }
+ AddTagsToStream' {_attsStreamName = pStreamName_, _attsTags = mempty}
+
-- | The name of the stream.
attsStreamName :: Lens' AddTagsToStream Text
@@ -83,9 +82,9 @@ instance AWSRequest AddTagsToStream where
request = postJSON kinesis
response = receiveNull AddTagsToStreamResponse'
-instance Hashable AddTagsToStream
+instance Hashable AddTagsToStream where
-instance NFData AddTagsToStream
+instance NFData AddTagsToStream where
instance ToHeaders AddTagsToStream where
toHeaders
@@ -111,8 +110,9 @@ instance ToQuery AddTagsToStream where
-- | /See:/ 'addTagsToStreamResponse' smart constructor.
data AddTagsToStreamResponse =
- AddTagsToStreamResponse'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ AddTagsToStreamResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'AddTagsToStreamResponse' with the minimum fields required to make a request.
--
@@ -120,4 +120,5 @@ addTagsToStreamResponse
:: AddTagsToStreamResponse
addTagsToStreamResponse = AddTagsToStreamResponse'
-instance NFData AddTagsToStreamResponse
+
+instance NFData AddTagsToStreamResponse where
diff --git a/gen/Network/AWS/Kinesis/CreateStream.hs b/gen/Network/AWS/Kinesis/CreateStream.hs
index f8c1e80..8cbfa08 100644
--- a/gen/Network/AWS/Kinesis/CreateStream.hs
+++ b/gen/Network/AWS/Kinesis/CreateStream.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.CreateStream
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -55,12 +55,12 @@ module Network.AWS.Kinesis.CreateStream
, CreateStreamResponse
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @CreateStream@ .
--
@@ -68,9 +68,10 @@ import Network.AWS.Response
--
-- /See:/ 'createStream' smart constructor.
data CreateStream = CreateStream'
- { _csStreamName :: !Text
- , _csShardCount :: !Nat
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _csStreamName :: !Text
+ , _csShardCount :: !Nat
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'CreateStream' with the minimum fields required to make a request.
--
@@ -84,10 +85,9 @@ createStream
-> Natural -- ^ 'csShardCount'
-> CreateStream
createStream pStreamName_ pShardCount_ =
- CreateStream'
- { _csStreamName = pStreamName_
- , _csShardCount = _Nat # pShardCount_
- }
+ CreateStream'
+ {_csStreamName = pStreamName_, _csShardCount = _Nat # pShardCount_}
+
-- | A name to identify the stream. The stream name is scoped to the AWS account used by the application that creates the stream. It is also scoped by region. That is, two streams in two different AWS accounts can have the same name, and two streams in the same AWS account but in two different regions can have the same name.
csStreamName :: Lens' CreateStream Text
@@ -102,9 +102,9 @@ instance AWSRequest CreateStream where
request = postJSON kinesis
response = receiveNull CreateStreamResponse'
-instance Hashable CreateStream
+instance Hashable CreateStream where
-instance NFData CreateStream
+instance NFData CreateStream where
instance ToHeaders CreateStream where
toHeaders
@@ -130,8 +130,9 @@ instance ToQuery CreateStream where
-- | /See:/ 'createStreamResponse' smart constructor.
data CreateStreamResponse =
- CreateStreamResponse'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ CreateStreamResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'CreateStreamResponse' with the minimum fields required to make a request.
--
@@ -139,4 +140,5 @@ createStreamResponse
:: CreateStreamResponse
createStreamResponse = CreateStreamResponse'
-instance NFData CreateStreamResponse
+
+instance NFData CreateStreamResponse where
diff --git a/gen/Network/AWS/Kinesis/DecreaseStreamRetentionPeriod.hs b/gen/Network/AWS/Kinesis/DecreaseStreamRetentionPeriod.hs
index d0a1fa2..91a57ec 100644
--- a/gen/Network/AWS/Kinesis/DecreaseStreamRetentionPeriod.hs
+++ b/gen/Network/AWS/Kinesis/DecreaseStreamRetentionPeriod.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.DecreaseStreamRetentionPeriod
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -37,12 +37,12 @@ module Network.AWS.Kinesis.DecreaseStreamRetentionPeriod
, DecreaseStreamRetentionPeriodResponse
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for 'DecreaseStreamRetentionPeriod' .
--
@@ -50,9 +50,10 @@ import Network.AWS.Response
--
-- /See:/ 'decreaseStreamRetentionPeriod' smart constructor.
data DecreaseStreamRetentionPeriod = DecreaseStreamRetentionPeriod'
- { _dsrpStreamName :: !Text
- , _dsrpRetentionPeriodHours :: !Nat
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _dsrpStreamName :: !Text
+ , _dsrpRetentionPeriodHours :: !Nat
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DecreaseStreamRetentionPeriod' with the minimum fields required to make a request.
--
@@ -66,10 +67,11 @@ decreaseStreamRetentionPeriod
-> Natural -- ^ 'dsrpRetentionPeriodHours'
-> DecreaseStreamRetentionPeriod
decreaseStreamRetentionPeriod pStreamName_ pRetentionPeriodHours_ =
- DecreaseStreamRetentionPeriod'
- { _dsrpStreamName = pStreamName_
- , _dsrpRetentionPeriodHours = _Nat # pRetentionPeriodHours_
- }
+ DecreaseStreamRetentionPeriod'
+ { _dsrpStreamName = pStreamName_
+ , _dsrpRetentionPeriodHours = _Nat # pRetentionPeriodHours_
+ }
+
-- | The name of the stream to modify.
dsrpStreamName :: Lens' DecreaseStreamRetentionPeriod Text
@@ -87,9 +89,9 @@ instance AWSRequest DecreaseStreamRetentionPeriod
response
= receiveNull DecreaseStreamRetentionPeriodResponse'
-instance Hashable DecreaseStreamRetentionPeriod
+instance Hashable DecreaseStreamRetentionPeriod where
-instance NFData DecreaseStreamRetentionPeriod
+instance NFData DecreaseStreamRetentionPeriod where
instance ToHeaders DecreaseStreamRetentionPeriod
where
@@ -119,8 +121,9 @@ instance ToQuery DecreaseStreamRetentionPeriod where
-- | /See:/ 'decreaseStreamRetentionPeriodResponse' smart constructor.
data DecreaseStreamRetentionPeriodResponse =
- DecreaseStreamRetentionPeriodResponse'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ DecreaseStreamRetentionPeriodResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DecreaseStreamRetentionPeriodResponse' with the minimum fields required to make a request.
--
@@ -128,4 +131,6 @@ decreaseStreamRetentionPeriodResponse
:: DecreaseStreamRetentionPeriodResponse
decreaseStreamRetentionPeriodResponse = DecreaseStreamRetentionPeriodResponse'
+
instance NFData DecreaseStreamRetentionPeriodResponse
+ where
diff --git a/gen/Network/AWS/Kinesis/DeleteStream.hs b/gen/Network/AWS/Kinesis/DeleteStream.hs
index 7c940a8..76bb52b 100644
--- a/gen/Network/AWS/Kinesis/DeleteStream.hs
+++ b/gen/Network/AWS/Kinesis/DeleteStream.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.DeleteStream
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -44,12 +44,12 @@ module Network.AWS.Kinesis.DeleteStream
, DeleteStreamResponse
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for 'DeleteStream' .
--
@@ -57,8 +57,9 @@ import Network.AWS.Response
--
-- /See:/ 'deleteStream' smart constructor.
newtype DeleteStream = DeleteStream'
- { _dsStreamName :: Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _dsStreamName :: Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DeleteStream' with the minimum fields required to make a request.
--
@@ -68,10 +69,8 @@ newtype DeleteStream = DeleteStream'
deleteStream
:: Text -- ^ 'dsStreamName'
-> DeleteStream
-deleteStream pStreamName_ =
- DeleteStream'
- { _dsStreamName = pStreamName_
- }
+deleteStream pStreamName_ = DeleteStream' {_dsStreamName = pStreamName_}
+
-- | The name of the stream to delete.
dsStreamName :: Lens' DeleteStream Text
@@ -82,9 +81,9 @@ instance AWSRequest DeleteStream where
request = postJSON kinesis
response = receiveNull DeleteStreamResponse'
-instance Hashable DeleteStream
+instance Hashable DeleteStream where
-instance NFData DeleteStream
+instance NFData DeleteStream where
instance ToHeaders DeleteStream where
toHeaders
@@ -108,8 +107,9 @@ instance ToQuery DeleteStream where
-- | /See:/ 'deleteStreamResponse' smart constructor.
data DeleteStreamResponse =
- DeleteStreamResponse'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ DeleteStreamResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DeleteStreamResponse' with the minimum fields required to make a request.
--
@@ -117,4 +117,5 @@ deleteStreamResponse
:: DeleteStreamResponse
deleteStreamResponse = DeleteStreamResponse'
-instance NFData DeleteStreamResponse
+
+instance NFData DeleteStreamResponse where
diff --git a/gen/Network/AWS/Kinesis/DescribeLimits.hs b/gen/Network/AWS/Kinesis/DescribeLimits.hs
index cdf59ef..dcf8ae1 100644
--- a/gen/Network/AWS/Kinesis/DescribeLimits.hs
+++ b/gen/Network/AWS/Kinesis/DescribeLimits.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.DescribeLimits
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -40,17 +40,18 @@ module Network.AWS.Kinesis.DescribeLimits
, dlrsOpenShardCount
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | /See:/ 'describeLimits' smart constructor.
data DescribeLimits =
- DescribeLimits'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ DescribeLimits'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DescribeLimits' with the minimum fields required to make a request.
--
@@ -58,6 +59,7 @@ describeLimits
:: DescribeLimits
describeLimits = DescribeLimits'
+
instance AWSRequest DescribeLimits where
type Rs DescribeLimits = DescribeLimitsResponse
request = postJSON kinesis
@@ -68,9 +70,9 @@ instance AWSRequest DescribeLimits where
(pure (fromEnum s)) <*> (x .:> "ShardLimit") <*>
(x .:> "OpenShardCount"))
-instance Hashable DescribeLimits
+instance Hashable DescribeLimits where
-instance NFData DescribeLimits
+instance NFData DescribeLimits where
instance ToHeaders DescribeLimits where
toHeaders
@@ -92,10 +94,11 @@ instance ToQuery DescribeLimits where
-- | /See:/ 'describeLimitsResponse' smart constructor.
data DescribeLimitsResponse = DescribeLimitsResponse'
- { _dlrsResponseStatus :: !Int
- , _dlrsShardLimit :: !Nat
- , _dlrsOpenShardCount :: !Nat
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _dlrsResponseStatus :: !Int
+ , _dlrsShardLimit :: !Nat
+ , _dlrsOpenShardCount :: !Nat
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DescribeLimitsResponse' with the minimum fields required to make a request.
--
@@ -112,11 +115,12 @@ describeLimitsResponse
-> Natural -- ^ 'dlrsOpenShardCount'
-> DescribeLimitsResponse
describeLimitsResponse pResponseStatus_ pShardLimit_ pOpenShardCount_ =
- DescribeLimitsResponse'
- { _dlrsResponseStatus = pResponseStatus_
- , _dlrsShardLimit = _Nat # pShardLimit_
- , _dlrsOpenShardCount = _Nat # pOpenShardCount_
- }
+ DescribeLimitsResponse'
+ { _dlrsResponseStatus = pResponseStatus_
+ , _dlrsShardLimit = _Nat # pShardLimit_
+ , _dlrsOpenShardCount = _Nat # pOpenShardCount_
+ }
+
-- | -- | The response status code.
dlrsResponseStatus :: Lens' DescribeLimitsResponse Int
@@ -130,4 +134,4 @@ dlrsShardLimit = lens _dlrsShardLimit (\ s a -> s{_dlrsShardLimit = a}) . _Nat;
dlrsOpenShardCount :: Lens' DescribeLimitsResponse Natural
dlrsOpenShardCount = lens _dlrsOpenShardCount (\ s a -> s{_dlrsOpenShardCount = a}) . _Nat;
-instance NFData DescribeLimitsResponse
+instance NFData DescribeLimitsResponse where
diff --git a/gen/Network/AWS/Kinesis/DescribeStream.hs b/gen/Network/AWS/Kinesis/DescribeStream.hs
index 03819d1..df1e01e 100644
--- a/gen/Network/AWS/Kinesis/DescribeStream.hs
+++ b/gen/Network/AWS/Kinesis/DescribeStream.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.DescribeStream
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -49,13 +49,13 @@ module Network.AWS.Kinesis.DescribeStream
, dsrsStreamDescription
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Pager
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Pager
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @DescribeStream@ .
--
@@ -63,10 +63,11 @@ import Network.AWS.Response
--
-- /See:/ 'describeStream' smart constructor.
data DescribeStream = DescribeStream'
- { _dExclusiveStartShardId :: !(Maybe Text)
- , _dLimit :: !(Maybe Nat)
- , _dStreamName :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _dExclusiveStartShardId :: !(Maybe Text)
+ , _dLimit :: !(Maybe Nat)
+ , _dStreamName :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DescribeStream' with the minimum fields required to make a request.
--
@@ -81,11 +82,12 @@ describeStream
:: Text -- ^ 'dStreamName'
-> DescribeStream
describeStream pStreamName_ =
- DescribeStream'
- { _dExclusiveStartShardId = Nothing
- , _dLimit = Nothing
- , _dStreamName = pStreamName_
- }
+ DescribeStream'
+ { _dExclusiveStartShardId = Nothing
+ , _dLimit = Nothing
+ , _dStreamName = pStreamName_
+ }
+
-- | The shard ID of the shard to start with.
dExclusiveStartShardId :: Lens' DescribeStream (Maybe Text)
@@ -123,9 +125,9 @@ instance AWSRequest DescribeStream where
DescribeStreamResponse' <$>
(pure (fromEnum s)) <*> (x .:> "StreamDescription"))
-instance Hashable DescribeStream
+instance Hashable DescribeStream where
-instance NFData DescribeStream
+instance NFData DescribeStream where
instance ToHeaders DescribeStream where
toHeaders
@@ -157,9 +159,10 @@ instance ToQuery DescribeStream where
--
-- /See:/ 'describeStreamResponse' smart constructor.
data DescribeStreamResponse = DescribeStreamResponse'
- { _dsrsResponseStatus :: !Int
- , _dsrsStreamDescription :: !StreamDescription
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _dsrsResponseStatus :: !Int
+ , _dsrsStreamDescription :: !StreamDescription
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DescribeStreamResponse' with the minimum fields required to make a request.
--
@@ -173,10 +176,11 @@ describeStreamResponse
-> StreamDescription -- ^ 'dsrsStreamDescription'
-> DescribeStreamResponse
describeStreamResponse pResponseStatus_ pStreamDescription_ =
- DescribeStreamResponse'
- { _dsrsResponseStatus = pResponseStatus_
- , _dsrsStreamDescription = pStreamDescription_
- }
+ DescribeStreamResponse'
+ { _dsrsResponseStatus = pResponseStatus_
+ , _dsrsStreamDescription = pStreamDescription_
+ }
+
-- | -- | The response status code.
dsrsResponseStatus :: Lens' DescribeStreamResponse Int
@@ -186,4 +190,4 @@ dsrsResponseStatus = lens _dsrsResponseStatus (\ s a -> s{_dsrsResponseStatus =
dsrsStreamDescription :: Lens' DescribeStreamResponse StreamDescription
dsrsStreamDescription = lens _dsrsStreamDescription (\ s a -> s{_dsrsStreamDescription = a});
-instance NFData DescribeStreamResponse
+instance NFData DescribeStreamResponse where
diff --git a/gen/Network/AWS/Kinesis/DisableEnhancedMonitoring.hs b/gen/Network/AWS/Kinesis/DisableEnhancedMonitoring.hs
index 5a38a9d..e413e81 100644
--- a/gen/Network/AWS/Kinesis/DisableEnhancedMonitoring.hs
+++ b/gen/Network/AWS/Kinesis/DisableEnhancedMonitoring.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.DisableEnhancedMonitoring
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -39,12 +39,12 @@ module Network.AWS.Kinesis.DisableEnhancedMonitoring
, emoStreamName
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for 'DisableEnhancedMonitoring' .
--
@@ -52,9 +52,10 @@ import Network.AWS.Response
--
-- /See:/ 'disableEnhancedMonitoring' smart constructor.
data DisableEnhancedMonitoring = DisableEnhancedMonitoring'
- { _demStreamName :: !Text
- , _demShardLevelMetrics :: ![MetricsName]
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _demStreamName :: !Text
+ , _demShardLevelMetrics :: ![MetricsName]
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'DisableEnhancedMonitoring' with the minimum fields required to make a request.
--
@@ -67,10 +68,9 @@ disableEnhancedMonitoring
:: Text -- ^ 'demStreamName'
-> DisableEnhancedMonitoring
disableEnhancedMonitoring pStreamName_ =
- DisableEnhancedMonitoring'
- { _demStreamName = pStreamName_
- , _demShardLevelMetrics = mempty
- }
+ DisableEnhancedMonitoring'
+ {_demStreamName = pStreamName_, _demShardLevelMetrics = mempty}
+
-- | The name of the Amazon Kinesis stream for which to disable enhanced monitoring.
demStreamName :: Lens' DisableEnhancedMonitoring Text
@@ -86,9 +86,9 @@ instance AWSRequest DisableEnhancedMonitoring where
request = postJSON kinesis
response = receiveJSON (\ s h x -> eitherParseJSON x)
-instance Hashable DisableEnhancedMonitoring
+instance Hashable DisableEnhancedMonitoring where
-instance NFData DisableEnhancedMonitoring
+instance NFData DisableEnhancedMonitoring where
instance ToHeaders DisableEnhancedMonitoring where
toHeaders
diff --git a/gen/Network/AWS/Kinesis/EnableEnhancedMonitoring.hs b/gen/Network/AWS/Kinesis/EnableEnhancedMonitoring.hs
index 21c65e6..8a7a367 100644
--- a/gen/Network/AWS/Kinesis/EnableEnhancedMonitoring.hs
+++ b/gen/Network/AWS/Kinesis/EnableEnhancedMonitoring.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.EnableEnhancedMonitoring
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -39,12 +39,12 @@ module Network.AWS.Kinesis.EnableEnhancedMonitoring
, emoStreamName
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for 'EnableEnhancedMonitoring' .
--
@@ -52,9 +52,10 @@ import Network.AWS.Response
--
-- /See:/ 'enableEnhancedMonitoring' smart constructor.
data EnableEnhancedMonitoring = EnableEnhancedMonitoring'
- { _eemStreamName :: !Text
- , _eemShardLevelMetrics :: ![MetricsName]
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _eemStreamName :: !Text
+ , _eemShardLevelMetrics :: ![MetricsName]
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'EnableEnhancedMonitoring' with the minimum fields required to make a request.
--
@@ -67,10 +68,9 @@ enableEnhancedMonitoring
:: Text -- ^ 'eemStreamName'
-> EnableEnhancedMonitoring
enableEnhancedMonitoring pStreamName_ =
- EnableEnhancedMonitoring'
- { _eemStreamName = pStreamName_
- , _eemShardLevelMetrics = mempty
- }
+ EnableEnhancedMonitoring'
+ {_eemStreamName = pStreamName_, _eemShardLevelMetrics = mempty}
+
-- | The name of the stream for which to enable enhanced monitoring.
eemStreamName :: Lens' EnableEnhancedMonitoring Text
@@ -86,9 +86,9 @@ instance AWSRequest EnableEnhancedMonitoring where
request = postJSON kinesis
response = receiveJSON (\ s h x -> eitherParseJSON x)
-instance Hashable EnableEnhancedMonitoring
+instance Hashable EnableEnhancedMonitoring where
-instance NFData EnableEnhancedMonitoring
+instance NFData EnableEnhancedMonitoring where
instance ToHeaders EnableEnhancedMonitoring where
toHeaders
diff --git a/gen/Network/AWS/Kinesis/GetRecords.hs b/gen/Network/AWS/Kinesis/GetRecords.hs
index 1bfe899..a5d60bf 100644
--- a/gen/Network/AWS/Kinesis/GetRecords.hs
+++ b/gen/Network/AWS/Kinesis/GetRecords.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.GetRecords
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -52,12 +52,12 @@ module Network.AWS.Kinesis.GetRecords
, grrsRecords
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for 'GetRecords' .
--
@@ -65,9 +65,10 @@ import Network.AWS.Response
--
-- /See:/ 'getRecords' smart constructor.
data GetRecords = GetRecords'
- { _grLimit :: !(Maybe Nat)
- , _grShardIterator :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _grLimit :: !(Maybe Nat)
+ , _grShardIterator :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'GetRecords' with the minimum fields required to make a request.
--
@@ -80,10 +81,8 @@ getRecords
:: Text -- ^ 'grShardIterator'
-> GetRecords
getRecords pShardIterator_ =
- GetRecords'
- { _grLimit = Nothing
- , _grShardIterator = pShardIterator_
- }
+ GetRecords' {_grLimit = Nothing, _grShardIterator = 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@ .
grLimit :: Lens' GetRecords (Maybe Natural)
@@ -105,9 +104,9 @@ instance AWSRequest GetRecords where
<*> (pure (fromEnum s))
<*> (x .?> "Records" .!@ mempty))
-instance Hashable GetRecords
+instance Hashable GetRecords where
-instance NFData GetRecords
+instance NFData GetRecords where
instance ToHeaders GetRecords where
toHeaders
@@ -137,11 +136,12 @@ instance ToQuery GetRecords where
--
-- /See:/ 'getRecordsResponse' smart constructor.
data GetRecordsResponse = GetRecordsResponse'
- { _grrsNextShardIterator :: !(Maybe Text)
- , _grrsMillisBehindLatest :: !(Maybe Nat)
- , _grrsResponseStatus :: !Int
- , _grrsRecords :: ![Record]
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _grrsNextShardIterator :: !(Maybe Text)
+ , _grrsMillisBehindLatest :: !(Maybe Nat)
+ , _grrsResponseStatus :: !Int
+ , _grrsRecords :: ![Record]
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'GetRecordsResponse' with the minimum fields required to make a request.
--
@@ -158,12 +158,13 @@ getRecordsResponse
:: Int -- ^ 'grrsResponseStatus'
-> GetRecordsResponse
getRecordsResponse pResponseStatus_ =
- GetRecordsResponse'
- { _grrsNextShardIterator = Nothing
- , _grrsMillisBehindLatest = Nothing
- , _grrsResponseStatus = pResponseStatus_
- , _grrsRecords = mempty
- }
+ GetRecordsResponse'
+ { _grrsNextShardIterator = Nothing
+ , _grrsMillisBehindLatest = Nothing
+ , _grrsResponseStatus = pResponseStatus_
+ , _grrsRecords = mempty
+ }
+
-- | 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 will not return any more data.
grrsNextShardIterator :: Lens' GetRecordsResponse (Maybe Text)
@@ -181,4 +182,4 @@ grrsResponseStatus = lens _grrsResponseStatus (\ s a -> s{_grrsResponseStatus =
grrsRecords :: Lens' GetRecordsResponse [Record]
grrsRecords = lens _grrsRecords (\ s a -> s{_grrsRecords = a}) . _Coerce;
-instance NFData GetRecordsResponse
+instance NFData GetRecordsResponse where
diff --git a/gen/Network/AWS/Kinesis/GetShardIterator.hs b/gen/Network/AWS/Kinesis/GetShardIterator.hs
index aeb8f28..9cbb3b8 100644
--- a/gen/Network/AWS/Kinesis/GetShardIterator.hs
+++ b/gen/Network/AWS/Kinesis/GetShardIterator.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.GetShardIterator
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -53,12 +53,12 @@ module Network.AWS.Kinesis.GetShardIterator
, gsirsResponseStatus
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @GetShardIterator@ .
--
@@ -66,12 +66,13 @@ import Network.AWS.Response
--
-- /See:/ 'getShardIterator' smart constructor.
data GetShardIterator = GetShardIterator'
- { _gsiStartingSequenceNumber :: !(Maybe Text)
- , _gsiTimestamp :: !(Maybe POSIX)
- , _gsiStreamName :: !Text
- , _gsiShardId :: !Text
- , _gsiShardIteratorType :: !ShardIteratorType
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _gsiStartingSequenceNumber :: !(Maybe Text)
+ , _gsiTimestamp :: !(Maybe POSIX)
+ , _gsiStreamName :: !Text
+ , _gsiShardId :: !Text
+ , _gsiShardIteratorType :: !ShardIteratorType
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'GetShardIterator' with the minimum fields required to make a request.
--
@@ -92,13 +93,14 @@ getShardIterator
-> ShardIteratorType -- ^ 'gsiShardIteratorType'
-> GetShardIterator
getShardIterator pStreamName_ pShardId_ pShardIteratorType_ =
- GetShardIterator'
- { _gsiStartingSequenceNumber = Nothing
- , _gsiTimestamp = Nothing
- , _gsiStreamName = pStreamName_
- , _gsiShardId = pShardId_
- , _gsiShardIteratorType = pShardIteratorType_
- }
+ GetShardIterator'
+ { _gsiStartingSequenceNumber = Nothing
+ , _gsiTimestamp = Nothing
+ , _gsiStreamName = pStreamName_
+ , _gsiShardId = pShardId_
+ , _gsiShardIteratorType = 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.
gsiStartingSequenceNumber :: Lens' GetShardIterator (Maybe Text)
@@ -129,9 +131,9 @@ instance AWSRequest GetShardIterator where
GetShardIteratorResponse' <$>
(x .?> "ShardIterator") <*> (pure (fromEnum s)))
-instance Hashable GetShardIterator
+instance Hashable GetShardIterator where
-instance NFData GetShardIterator
+instance NFData GetShardIterator where
instance ToHeaders GetShardIterator where
toHeaders
@@ -165,9 +167,10 @@ instance ToQuery GetShardIterator where
--
-- /See:/ 'getShardIteratorResponse' smart constructor.
data GetShardIteratorResponse = GetShardIteratorResponse'
- { _gsirsShardIterator :: !(Maybe Text)
- , _gsirsResponseStatus :: !Int
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _gsirsShardIterator :: !(Maybe Text)
+ , _gsirsResponseStatus :: !Int
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'GetShardIteratorResponse' with the minimum fields required to make a request.
--
@@ -180,10 +183,9 @@ getShardIteratorResponse
:: Int -- ^ 'gsirsResponseStatus'
-> GetShardIteratorResponse
getShardIteratorResponse pResponseStatus_ =
- GetShardIteratorResponse'
- { _gsirsShardIterator = Nothing
- , _gsirsResponseStatus = pResponseStatus_
- }
+ GetShardIteratorResponse'
+ {_gsirsShardIterator = Nothing, _gsirsResponseStatus = pResponseStatus_}
+
-- | 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.
gsirsShardIterator :: Lens' GetShardIteratorResponse (Maybe Text)
@@ -193,4 +195,4 @@ gsirsShardIterator = lens _gsirsShardIterator (\ s a -> s{_gsirsShardIterator =
gsirsResponseStatus :: Lens' GetShardIteratorResponse Int
gsirsResponseStatus = lens _gsirsResponseStatus (\ s a -> s{_gsirsResponseStatus = a});
-instance NFData GetShardIteratorResponse
+instance NFData GetShardIteratorResponse where
diff --git a/gen/Network/AWS/Kinesis/IncreaseStreamRetentionPeriod.hs b/gen/Network/AWS/Kinesis/IncreaseStreamRetentionPeriod.hs
index 8bf5f50..7216a25 100644
--- a/gen/Network/AWS/Kinesis/IncreaseStreamRetentionPeriod.hs
+++ b/gen/Network/AWS/Kinesis/IncreaseStreamRetentionPeriod.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.IncreaseStreamRetentionPeriod
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -37,12 +37,12 @@ module Network.AWS.Kinesis.IncreaseStreamRetentionPeriod
, IncreaseStreamRetentionPeriodResponse
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for 'IncreaseStreamRetentionPeriod' .
--
@@ -50,9 +50,10 @@ import Network.AWS.Response
--
-- /See:/ 'increaseStreamRetentionPeriod' smart constructor.
data IncreaseStreamRetentionPeriod = IncreaseStreamRetentionPeriod'
- { _isrpStreamName :: !Text
- , _isrpRetentionPeriodHours :: !Nat
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _isrpStreamName :: !Text
+ , _isrpRetentionPeriodHours :: !Nat
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'IncreaseStreamRetentionPeriod' with the minimum fields required to make a request.
--
@@ -66,10 +67,11 @@ increaseStreamRetentionPeriod
-> Natural -- ^ 'isrpRetentionPeriodHours'
-> IncreaseStreamRetentionPeriod
increaseStreamRetentionPeriod pStreamName_ pRetentionPeriodHours_ =
- IncreaseStreamRetentionPeriod'
- { _isrpStreamName = pStreamName_
- , _isrpRetentionPeriodHours = _Nat # pRetentionPeriodHours_
- }
+ IncreaseStreamRetentionPeriod'
+ { _isrpStreamName = pStreamName_
+ , _isrpRetentionPeriodHours = _Nat # pRetentionPeriodHours_
+ }
+
-- | The name of the stream to modify.
isrpStreamName :: Lens' IncreaseStreamRetentionPeriod Text
@@ -87,9 +89,9 @@ instance AWSRequest IncreaseStreamRetentionPeriod
response
= receiveNull IncreaseStreamRetentionPeriodResponse'
-instance Hashable IncreaseStreamRetentionPeriod
+instance Hashable IncreaseStreamRetentionPeriod where
-instance NFData IncreaseStreamRetentionPeriod
+instance NFData IncreaseStreamRetentionPeriod where
instance ToHeaders IncreaseStreamRetentionPeriod
where
@@ -119,8 +121,9 @@ instance ToQuery IncreaseStreamRetentionPeriod where
-- | /See:/ 'increaseStreamRetentionPeriodResponse' smart constructor.
data IncreaseStreamRetentionPeriodResponse =
- IncreaseStreamRetentionPeriodResponse'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ IncreaseStreamRetentionPeriodResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'IncreaseStreamRetentionPeriodResponse' with the minimum fields required to make a request.
--
@@ -128,4 +131,6 @@ increaseStreamRetentionPeriodResponse
:: IncreaseStreamRetentionPeriodResponse
increaseStreamRetentionPeriodResponse = IncreaseStreamRetentionPeriodResponse'
+
instance NFData IncreaseStreamRetentionPeriodResponse
+ where
diff --git a/gen/Network/AWS/Kinesis/ListStreams.hs b/gen/Network/AWS/Kinesis/ListStreams.hs
index 778fd53..9d7639d 100644
--- a/gen/Network/AWS/Kinesis/ListStreams.hs
+++ b/gen/Network/AWS/Kinesis/ListStreams.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.ListStreams
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -47,13 +47,13 @@ module Network.AWS.Kinesis.ListStreams
, lsrsHasMoreStreams
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Pager
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Pager
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @ListStreams@ .
--
@@ -61,9 +61,10 @@ import Network.AWS.Response
--
-- /See:/ 'listStreams' smart constructor.
data ListStreams = ListStreams'
- { _lsLimit :: !(Maybe Nat)
- , _lsExclusiveStartStreamName :: !(Maybe Text)
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _lsLimit :: !(Maybe Nat)
+ , _lsExclusiveStartStreamName :: !(Maybe Text)
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'ListStreams' with the minimum fields required to make a request.
--
@@ -75,10 +76,8 @@ data ListStreams = ListStreams'
listStreams
:: ListStreams
listStreams =
- ListStreams'
- { _lsLimit = Nothing
- , _lsExclusiveStartStreamName = Nothing
- }
+ ListStreams' {_lsLimit = Nothing, _lsExclusiveStartStreamName = Nothing}
+
-- | The maximum number of streams to list.
lsLimit :: Lens' ListStreams (Maybe Natural)
@@ -108,9 +107,9 @@ instance AWSRequest ListStreams where
(x .?> "StreamNames" .!@ mempty)
<*> (x .:> "HasMoreStreams"))
-instance Hashable ListStreams
+instance Hashable ListStreams where
-instance NFData ListStreams
+instance NFData ListStreams where
instance ToHeaders ListStreams where
toHeaders
@@ -141,10 +140,11 @@ instance ToQuery ListStreams where
--
-- /See:/ 'listStreamsResponse' smart constructor.
data ListStreamsResponse = ListStreamsResponse'
- { _lsrsResponseStatus :: !Int
- , _lsrsStreamNames :: ![Text]
- , _lsrsHasMoreStreams :: !Bool
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _lsrsResponseStatus :: !Int
+ , _lsrsStreamNames :: ![Text]
+ , _lsrsHasMoreStreams :: !Bool
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'ListStreamsResponse' with the minimum fields required to make a request.
--
@@ -160,11 +160,12 @@ listStreamsResponse
-> Bool -- ^ 'lsrsHasMoreStreams'
-> ListStreamsResponse
listStreamsResponse pResponseStatus_ pHasMoreStreams_ =
- ListStreamsResponse'
- { _lsrsResponseStatus = pResponseStatus_
- , _lsrsStreamNames = mempty
- , _lsrsHasMoreStreams = pHasMoreStreams_
- }
+ ListStreamsResponse'
+ { _lsrsResponseStatus = pResponseStatus_
+ , _lsrsStreamNames = mempty
+ , _lsrsHasMoreStreams = pHasMoreStreams_
+ }
+
-- | -- | The response status code.
lsrsResponseStatus :: Lens' ListStreamsResponse Int
@@ -178,4 +179,4 @@ lsrsStreamNames = lens _lsrsStreamNames (\ s a -> s{_lsrsStreamNames = a}) . _Co
lsrsHasMoreStreams :: Lens' ListStreamsResponse Bool
lsrsHasMoreStreams = lens _lsrsHasMoreStreams (\ s a -> s{_lsrsHasMoreStreams = a});
-instance NFData ListStreamsResponse
+instance NFData ListStreamsResponse where
diff --git a/gen/Network/AWS/Kinesis/ListTagsForStream.hs b/gen/Network/AWS/Kinesis/ListTagsForStream.hs
index 72c0c0a..82e726a 100644
--- a/gen/Network/AWS/Kinesis/ListTagsForStream.hs
+++ b/gen/Network/AWS/Kinesis/ListTagsForStream.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.ListTagsForStream
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -40,12 +40,12 @@ module Network.AWS.Kinesis.ListTagsForStream
, ltfsrsHasMoreTags
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @ListTagsForStream@ .
--
@@ -53,10 +53,11 @@ import Network.AWS.Response
--
-- /See:/ 'listTagsForStream' smart constructor.
data ListTagsForStream = ListTagsForStream'
- { _ltfsLimit :: !(Maybe Nat)
- , _ltfsExclusiveStartTagKey :: !(Maybe Text)
- , _ltfsStreamName :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _ltfsLimit :: !(Maybe Nat)
+ , _ltfsExclusiveStartTagKey :: !(Maybe Text)
+ , _ltfsStreamName :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'ListTagsForStream' with the minimum fields required to make a request.
--
@@ -71,11 +72,12 @@ listTagsForStream
:: Text -- ^ 'ltfsStreamName'
-> ListTagsForStream
listTagsForStream pStreamName_ =
- ListTagsForStream'
- { _ltfsLimit = Nothing
- , _ltfsExclusiveStartTagKey = Nothing
- , _ltfsStreamName = pStreamName_
- }
+ ListTagsForStream'
+ { _ltfsLimit = Nothing
+ , _ltfsExclusiveStartTagKey = Nothing
+ , _ltfsStreamName = pStreamName_
+ }
+
-- | The number of tags to return. If this number is less than the total number of tags associated with the stream, @HasMoreTags@ is set to @true@ . To list additional tags, set @ExclusiveStartTagKey@ to the last key in the response.
ltfsLimit :: Lens' ListTagsForStream (Maybe Natural)
@@ -99,9 +101,9 @@ instance AWSRequest ListTagsForStream where
(pure (fromEnum s)) <*> (x .?> "Tags" .!@ mempty) <*>
(x .:> "HasMoreTags"))
-instance Hashable ListTagsForStream
+instance Hashable ListTagsForStream where
-instance NFData ListTagsForStream
+instance NFData ListTagsForStream where
instance ToHeaders ListTagsForStream where
toHeaders
@@ -133,10 +135,11 @@ instance ToQuery ListTagsForStream where
--
-- /See:/ 'listTagsForStreamResponse' smart constructor.
data ListTagsForStreamResponse = ListTagsForStreamResponse'
- { _ltfsrsResponseStatus :: !Int
- , _ltfsrsTags :: ![Tag]
- , _ltfsrsHasMoreTags :: !Bool
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _ltfsrsResponseStatus :: !Int
+ , _ltfsrsTags :: ![Tag]
+ , _ltfsrsHasMoreTags :: !Bool
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'ListTagsForStreamResponse' with the minimum fields required to make a request.
--
@@ -152,11 +155,12 @@ listTagsForStreamResponse
-> Bool -- ^ 'ltfsrsHasMoreTags'
-> ListTagsForStreamResponse
listTagsForStreamResponse pResponseStatus_ pHasMoreTags_ =
- ListTagsForStreamResponse'
- { _ltfsrsResponseStatus = pResponseStatus_
- , _ltfsrsTags = mempty
- , _ltfsrsHasMoreTags = pHasMoreTags_
- }
+ ListTagsForStreamResponse'
+ { _ltfsrsResponseStatus = pResponseStatus_
+ , _ltfsrsTags = mempty
+ , _ltfsrsHasMoreTags = pHasMoreTags_
+ }
+
-- | -- | The response status code.
ltfsrsResponseStatus :: Lens' ListTagsForStreamResponse Int
@@ -170,4 +174,4 @@ ltfsrsTags = lens _ltfsrsTags (\ s a -> s{_ltfsrsTags = a}) . _Coerce;
ltfsrsHasMoreTags :: Lens' ListTagsForStreamResponse Bool
ltfsrsHasMoreTags = lens _ltfsrsHasMoreTags (\ s a -> s{_ltfsrsHasMoreTags = a});
-instance NFData ListTagsForStreamResponse
+instance NFData ListTagsForStreamResponse where
diff --git a/gen/Network/AWS/Kinesis/MergeShards.hs b/gen/Network/AWS/Kinesis/MergeShards.hs
index d2c1e02..a518f03 100644
--- a/gen/Network/AWS/Kinesis/MergeShards.hs
+++ b/gen/Network/AWS/Kinesis/MergeShards.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.MergeShards
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -50,12 +50,12 @@ module Network.AWS.Kinesis.MergeShards
, MergeShardsResponse
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @MergeShards@ .
--
@@ -63,10 +63,11 @@ import Network.AWS.Response
--
-- /See:/ 'mergeShards' smart constructor.
data MergeShards = MergeShards'
- { _msStreamName :: !Text
- , _msShardToMerge :: !Text
- , _msAdjacentShardToMerge :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _msStreamName :: !Text
+ , _msShardToMerge :: !Text
+ , _msAdjacentShardToMerge :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'MergeShards' with the minimum fields required to make a request.
--
@@ -83,11 +84,12 @@ mergeShards
-> Text -- ^ 'msAdjacentShardToMerge'
-> MergeShards
mergeShards pStreamName_ pShardToMerge_ pAdjacentShardToMerge_ =
- MergeShards'
- { _msStreamName = pStreamName_
- , _msShardToMerge = pShardToMerge_
- , _msAdjacentShardToMerge = pAdjacentShardToMerge_
- }
+ MergeShards'
+ { _msStreamName = pStreamName_
+ , _msShardToMerge = pShardToMerge_
+ , _msAdjacentShardToMerge = pAdjacentShardToMerge_
+ }
+
-- | The name of the stream for the merge.
msStreamName :: Lens' MergeShards Text
@@ -106,9 +108,9 @@ instance AWSRequest MergeShards where
request = postJSON kinesis
response = receiveNull MergeShardsResponse'
-instance Hashable MergeShards
+instance Hashable MergeShards where
-instance NFData MergeShards
+instance NFData MergeShards where
instance ToHeaders MergeShards where
toHeaders
@@ -136,8 +138,9 @@ instance ToQuery MergeShards where
-- | /See:/ 'mergeShardsResponse' smart constructor.
data MergeShardsResponse =
- MergeShardsResponse'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ MergeShardsResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'MergeShardsResponse' with the minimum fields required to make a request.
--
@@ -145,4 +148,5 @@ mergeShardsResponse
:: MergeShardsResponse
mergeShardsResponse = MergeShardsResponse'
-instance NFData MergeShardsResponse
+
+instance NFData MergeShardsResponse where
diff --git a/gen/Network/AWS/Kinesis/PutRecord.hs b/gen/Network/AWS/Kinesis/PutRecord.hs
index 38c062a..b75d537 100644
--- a/gen/Network/AWS/Kinesis/PutRecord.hs
+++ b/gen/Network/AWS/Kinesis/PutRecord.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.PutRecord
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -35,7 +35,7 @@
--
-- If a @PutRecord@ request cannot be processed because of insufficient provisioned throughput on the shard involved in the request, @PutRecord@ throws @ProvisionedThroughputExceededException@ .
--
--- Data records are accessible for only 24 hours from the time that they are added to a stream.
+-- By default, data records are accessible for 24 hours from the time that they are added to a stream. You can use 'IncreaseStreamRetentionPeriod' or 'DecreaseStreamRetentionPeriod' to modify this retention period.
--
module Network.AWS.Kinesis.PutRecord
(
@@ -53,17 +53,18 @@ module Network.AWS.Kinesis.PutRecord
, putRecordResponse
, PutRecordResponse
-- * Response Lenses
+ , prrsEncryptionType
, prrsResponseStatus
, prrsShardId
, prrsSequenceNumber
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @PutRecord@ .
--
@@ -71,12 +72,13 @@ import Network.AWS.Response
--
-- /See:/ 'putRecord' smart constructor.
data PutRecord = PutRecord'
- { _prExplicitHashKey :: !(Maybe Text)
- , _prSequenceNumberForOrdering :: !(Maybe Text)
- , _prStreamName :: !Text
- , _prData :: !Base64
- , _prPartitionKey :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _prExplicitHashKey :: !(Maybe Text)
+ , _prSequenceNumberForOrdering :: !(Maybe Text)
+ , _prStreamName :: !Text
+ , _prData :: !Base64
+ , _prPartitionKey :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'PutRecord' with the minimum fields required to make a request.
--
@@ -97,13 +99,14 @@ putRecord
-> Text -- ^ 'prPartitionKey'
-> PutRecord
putRecord pStreamName_ pData_ pPartitionKey_ =
- PutRecord'
- { _prExplicitHashKey = Nothing
- , _prSequenceNumberForOrdering = Nothing
- , _prStreamName = pStreamName_
- , _prData = _Base64 # pData_
- , _prPartitionKey = pPartitionKey_
- }
+ PutRecord'
+ { _prExplicitHashKey = Nothing
+ , _prSequenceNumberForOrdering = Nothing
+ , _prStreamName = pStreamName_
+ , _prData = _Base64 # pData_
+ , _prPartitionKey = pPartitionKey_
+ }
+
-- | The hash value used to explicitly determine the shard the data record is assigned to by overriding the partition key hash.
prExplicitHashKey :: Lens' PutRecord (Maybe Text)
@@ -132,12 +135,13 @@ instance AWSRequest PutRecord where
= receiveJSON
(\ s h x ->
PutRecordResponse' <$>
- (pure (fromEnum s)) <*> (x .:> "ShardId") <*>
- (x .:> "SequenceNumber"))
+ (x .?> "EncryptionType") <*> (pure (fromEnum s)) <*>
+ (x .:> "ShardId")
+ <*> (x .:> "SequenceNumber"))
-instance Hashable PutRecord
+instance Hashable PutRecord where
-instance NFData PutRecord
+instance NFData PutRecord where
instance ToHeaders PutRecord where
toHeaders
@@ -171,15 +175,19 @@ instance ToQuery PutRecord where
--
-- /See:/ 'putRecordResponse' smart constructor.
data PutRecordResponse = PutRecordResponse'
- { _prrsResponseStatus :: !Int
- , _prrsShardId :: !Text
- , _prrsSequenceNumber :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _prrsEncryptionType :: !(Maybe EncryptionType)
+ , _prrsResponseStatus :: !Int
+ , _prrsShardId :: !Text
+ , _prrsSequenceNumber :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'PutRecordResponse' with the minimum fields required to make a request.
--
-- Use one of the following lenses to modify other fields as desired:
--
+-- * 'prrsEncryptionType' - The encryption type to use on the record. This parameter can be one of the following values: * @NONE@ : Do not encrypt the records in the stream. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+--
-- * 'prrsResponseStatus' - -- | The response status code.
--
-- * 'prrsShardId' - The shard ID of the shard where the data record was placed.
@@ -191,11 +199,17 @@ putRecordResponse
-> Text -- ^ 'prrsSequenceNumber'
-> PutRecordResponse
putRecordResponse pResponseStatus_ pShardId_ pSequenceNumber_ =
- PutRecordResponse'
- { _prrsResponseStatus = pResponseStatus_
- , _prrsShardId = pShardId_
- , _prrsSequenceNumber = pSequenceNumber_
- }
+ PutRecordResponse'
+ { _prrsEncryptionType = Nothing
+ , _prrsResponseStatus = pResponseStatus_
+ , _prrsShardId = pShardId_
+ , _prrsSequenceNumber = pSequenceNumber_
+ }
+
+
+-- | The encryption type to use on the record. This parameter can be one of the following values: * @NONE@ : Do not encrypt the records in the stream. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+prrsEncryptionType :: Lens' PutRecordResponse (Maybe EncryptionType)
+prrsEncryptionType = lens _prrsEncryptionType (\ s a -> s{_prrsEncryptionType = a});
-- | -- | The response status code.
prrsResponseStatus :: Lens' PutRecordResponse Int
@@ -209,4 +223,4 @@ prrsShardId = lens _prrsShardId (\ s a -> s{_prrsShardId = a});
prrsSequenceNumber :: Lens' PutRecordResponse Text
prrsSequenceNumber = lens _prrsSequenceNumber (\ s a -> s{_prrsSequenceNumber = a});
-instance NFData PutRecordResponse
+instance NFData PutRecordResponse where
diff --git a/gen/Network/AWS/Kinesis/PutRecords.hs b/gen/Network/AWS/Kinesis/PutRecords.hs
index 40385ac..ad4918c 100644
--- a/gen/Network/AWS/Kinesis/PutRecords.hs
+++ b/gen/Network/AWS/Kinesis/PutRecords.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.PutRecords
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -39,7 +39,7 @@
--
-- An unsuccessfully-processed record includes @ErrorCode@ and @ErrorMessage@ values. @ErrorCode@ reflects the type of error and can be one of the following values: @ProvisionedThroughputExceededException@ or @InternalFailure@ . @ErrorMessage@ provides more detailed information about the @ProvisionedThroughputExceededException@ exception including the account ID, stream name, and shard ID of the record that was throttled. For more information about partially successful responses, see <http://docs.aws.amazon.com/kinesis/latest/dev/kinesis-using-sdk-java-add-data-to-stream.html#kinesis-using-sdk-java-putrecords Adding Multiple Records with PutRecords> in the /Amazon Kinesis Streams Developer Guide/ .
--
--- By default, data records are accessible for only 24 hours from the time that they are added to an Amazon Kinesis stream. This retention period can be modified using the 'DecreaseStreamRetentionPeriod' and 'IncreaseStreamRetentionPeriod' operations.
+-- By default, data records are accessible for 24 hours from the time that they are added to a stream. You can use 'IncreaseStreamRetentionPeriod' or 'DecreaseStreamRetentionPeriod' to modify this retention period.
--
module Network.AWS.Kinesis.PutRecords
(
@@ -54,17 +54,18 @@ module Network.AWS.Kinesis.PutRecords
, putRecordsResponse
, PutRecordsResponse
-- * Response Lenses
+ , prsEncryptionType
, prsFailedRecordCount
, prsResponseStatus
, prsRecords
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | A @PutRecords@ request.
--
@@ -72,9 +73,10 @@ import Network.AWS.Response
--
-- /See:/ 'putRecords' smart constructor.
data PutRecords = PutRecords'
- { _pRecordEntries :: !(List1 PutRecordsRequestEntry)
- , _pStreamName :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _pRecordEntries :: !(List1 PutRecordsRequestEntry)
+ , _pStreamName :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'PutRecords' with the minimum fields required to make a request.
--
@@ -88,10 +90,9 @@ putRecords
-> Text -- ^ 'pStreamName'
-> PutRecords
putRecords pRecordEntries_ pStreamName_ =
- PutRecords'
- { _pRecordEntries = _List1 # pRecordEntries_
- , _pStreamName = pStreamName_
- }
+ PutRecords'
+ {_pRecordEntries = _List1 # pRecordEntries_, _pStreamName = pStreamName_}
+
-- | The records associated with the request.
pRecordEntries :: Lens' PutRecords (NonEmpty PutRecordsRequestEntry)
@@ -108,12 +109,14 @@ instance AWSRequest PutRecords where
= receiveJSON
(\ s h x ->
PutRecordsResponse' <$>
- (x .?> "FailedRecordCount") <*> (pure (fromEnum s))
+ (x .?> "EncryptionType") <*>
+ (x .?> "FailedRecordCount")
+ <*> (pure (fromEnum s))
<*> (x .:> "Records"))
-instance Hashable PutRecords
+instance Hashable PutRecords where
-instance NFData PutRecords
+instance NFData PutRecords where
instance ToHeaders PutRecords where
toHeaders
@@ -143,15 +146,19 @@ instance ToQuery PutRecords where
--
-- /See:/ 'putRecordsResponse' smart constructor.
data PutRecordsResponse = PutRecordsResponse'
- { _prsFailedRecordCount :: !(Maybe Nat)
- , _prsResponseStatus :: !Int
- , _prsRecords :: !(List1 PutRecordsResultEntry)
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _prsEncryptionType :: !(Maybe EncryptionType)
+ , _prsFailedRecordCount :: !(Maybe Nat)
+ , _prsResponseStatus :: !Int
+ , _prsRecords :: !(List1 PutRecordsResultEntry)
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'PutRecordsResponse' with the minimum fields required to make a request.
--
-- Use one of the following lenses to modify other fields as desired:
--
+-- * 'prsEncryptionType' - The encryption type used on the records. This parameter can be one of the following values: * @NONE@ : Do not encrypt the records. * @KMS@ : Use server-side encryption on the records using a customer-managed KMS key.
+--
-- * 'prsFailedRecordCount' - The number of unsuccessfully processed records in a @PutRecords@ request.
--
-- * 'prsResponseStatus' - -- | The response status code.
@@ -162,11 +169,17 @@ putRecordsResponse
-> NonEmpty PutRecordsResultEntry -- ^ 'prsRecords'
-> PutRecordsResponse
putRecordsResponse pResponseStatus_ pRecords_ =
- PutRecordsResponse'
- { _prsFailedRecordCount = Nothing
- , _prsResponseStatus = pResponseStatus_
- , _prsRecords = _List1 # pRecords_
- }
+ PutRecordsResponse'
+ { _prsEncryptionType = Nothing
+ , _prsFailedRecordCount = Nothing
+ , _prsResponseStatus = pResponseStatus_
+ , _prsRecords = _List1 # pRecords_
+ }
+
+
+-- | The encryption type used on the records. This parameter can be one of the following values: * @NONE@ : Do not encrypt the records. * @KMS@ : Use server-side encryption on the records using a customer-managed KMS key.
+prsEncryptionType :: Lens' PutRecordsResponse (Maybe EncryptionType)
+prsEncryptionType = lens _prsEncryptionType (\ s a -> s{_prsEncryptionType = a});
-- | The number of unsuccessfully processed records in a @PutRecords@ request.
prsFailedRecordCount :: Lens' PutRecordsResponse (Maybe Natural)
@@ -180,4 +193,4 @@ prsResponseStatus = lens _prsResponseStatus (\ s a -> s{_prsResponseStatus = a})
prsRecords :: Lens' PutRecordsResponse (NonEmpty PutRecordsResultEntry)
prsRecords = lens _prsRecords (\ s a -> s{_prsRecords = a}) . _List1;
-instance NFData PutRecordsResponse
+instance NFData PutRecordsResponse where
diff --git a/gen/Network/AWS/Kinesis/RemoveTagsFromStream.hs b/gen/Network/AWS/Kinesis/RemoveTagsFromStream.hs
index 033e531..47dd0b9 100644
--- a/gen/Network/AWS/Kinesis/RemoveTagsFromStream.hs
+++ b/gen/Network/AWS/Kinesis/RemoveTagsFromStream.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.RemoveTagsFromStream
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -37,12 +37,12 @@ module Network.AWS.Kinesis.RemoveTagsFromStream
, RemoveTagsFromStreamResponse
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @RemoveTagsFromStream@ .
--
@@ -50,9 +50,10 @@ import Network.AWS.Response
--
-- /See:/ 'removeTagsFromStream' smart constructor.
data RemoveTagsFromStream = RemoveTagsFromStream'
- { _rtfsStreamName :: !Text
- , _rtfsTagKeys :: !(List1 Text)
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _rtfsStreamName :: !Text
+ , _rtfsTagKeys :: !(List1 Text)
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'RemoveTagsFromStream' with the minimum fields required to make a request.
--
@@ -66,10 +67,9 @@ removeTagsFromStream
-> NonEmpty Text -- ^ 'rtfsTagKeys'
-> RemoveTagsFromStream
removeTagsFromStream pStreamName_ pTagKeys_ =
- RemoveTagsFromStream'
- { _rtfsStreamName = pStreamName_
- , _rtfsTagKeys = _List1 # pTagKeys_
- }
+ RemoveTagsFromStream'
+ {_rtfsStreamName = pStreamName_, _rtfsTagKeys = _List1 # pTagKeys_}
+
-- | The name of the stream.
rtfsStreamName :: Lens' RemoveTagsFromStream Text
@@ -85,9 +85,9 @@ instance AWSRequest RemoveTagsFromStream where
request = postJSON kinesis
response = receiveNull RemoveTagsFromStreamResponse'
-instance Hashable RemoveTagsFromStream
+instance Hashable RemoveTagsFromStream where
-instance NFData RemoveTagsFromStream
+instance NFData RemoveTagsFromStream where
instance ToHeaders RemoveTagsFromStream where
toHeaders
@@ -114,8 +114,9 @@ instance ToQuery RemoveTagsFromStream where
-- | /See:/ 'removeTagsFromStreamResponse' smart constructor.
data RemoveTagsFromStreamResponse =
- RemoveTagsFromStreamResponse'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ RemoveTagsFromStreamResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'RemoveTagsFromStreamResponse' with the minimum fields required to make a request.
--
@@ -123,4 +124,5 @@ removeTagsFromStreamResponse
:: RemoveTagsFromStreamResponse
removeTagsFromStreamResponse = RemoveTagsFromStreamResponse'
-instance NFData RemoveTagsFromStreamResponse
+
+instance NFData RemoveTagsFromStreamResponse where
diff --git a/gen/Network/AWS/Kinesis/SplitShard.hs b/gen/Network/AWS/Kinesis/SplitShard.hs
index 6eb8289..7f2f370 100644
--- a/gen/Network/AWS/Kinesis/SplitShard.hs
+++ b/gen/Network/AWS/Kinesis/SplitShard.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.SplitShard
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -54,12 +54,12 @@ module Network.AWS.Kinesis.SplitShard
, SplitShardResponse
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | Represents the input for @SplitShard@ .
--
@@ -67,10 +67,11 @@ import Network.AWS.Response
--
-- /See:/ 'splitShard' smart constructor.
data SplitShard = SplitShard'
- { _ssStreamName :: !Text
- , _ssShardToSplit :: !Text
- , _ssNewStartingHashKey :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _ssStreamName :: !Text
+ , _ssShardToSplit :: !Text
+ , _ssNewStartingHashKey :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'SplitShard' with the minimum fields required to make a request.
--
@@ -87,11 +88,12 @@ splitShard
-> Text -- ^ 'ssNewStartingHashKey'
-> SplitShard
splitShard pStreamName_ pShardToSplit_ pNewStartingHashKey_ =
- SplitShard'
- { _ssStreamName = pStreamName_
- , _ssShardToSplit = pShardToSplit_
- , _ssNewStartingHashKey = pNewStartingHashKey_
- }
+ SplitShard'
+ { _ssStreamName = pStreamName_
+ , _ssShardToSplit = pShardToSplit_
+ , _ssNewStartingHashKey = pNewStartingHashKey_
+ }
+
-- | The name of the stream for the shard split.
ssStreamName :: Lens' SplitShard Text
@@ -110,9 +112,9 @@ instance AWSRequest SplitShard where
request = postJSON kinesis
response = receiveNull SplitShardResponse'
-instance Hashable SplitShard
+instance Hashable SplitShard where
-instance NFData SplitShard
+instance NFData SplitShard where
instance ToHeaders SplitShard where
toHeaders
@@ -140,8 +142,9 @@ instance ToQuery SplitShard where
-- | /See:/ 'splitShardResponse' smart constructor.
data SplitShardResponse =
- SplitShardResponse'
- deriving (Eq,Read,Show,Data,Typeable,Generic)
+ SplitShardResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'SplitShardResponse' with the minimum fields required to make a request.
--
@@ -149,4 +152,5 @@ splitShardResponse
:: SplitShardResponse
splitShardResponse = SplitShardResponse'
-instance NFData SplitShardResponse
+
+instance NFData SplitShardResponse where
diff --git a/gen/Network/AWS/Kinesis/StartStreamEncryption.hs b/gen/Network/AWS/Kinesis/StartStreamEncryption.hs
new file mode 100644
index 0000000..7c1a2b6
--- /dev/null
+++ b/gen/Network/AWS/Kinesis/StartStreamEncryption.hs
@@ -0,0 +1,141 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE DeriveGeneric #-}
+{-# LANGUAGE OverloadedStrings #-}
+{-# LANGUAGE RecordWildCards #-}
+{-# LANGUAGE TypeFamilies #-}
+
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# OPTIONS_GHC -fno-warn-unused-binds #-}
+{-# OPTIONS_GHC -fno-warn-unused-matches #-}
+
+-- Derived from AWS service descriptions, licensed under Apache 2.0.
+
+-- |
+-- Module : Network.AWS.Kinesis.StartStreamEncryption
+-- Copyright : (c) 2013-2017 Brendan Hay
+-- License : Mozilla Public License, v. 2.0.
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
+-- Stability : auto-generated
+-- Portability : non-portable (GHC extensions)
+--
+-- Enables or updates server-side encryption using an AWS KMS key for a specified stream.
+--
+--
+-- Starting encryption is an asynchronous operation. Upon receiving the request, Amazon Kinesis returns immediately and sets the status of the stream to @UPDATING@ . After the update is complete, Amazon Kinesis sets the status of the stream back to @ACTIVE@ . Updating or applying encryption normally takes a few seconds to complete but it can take minutes. You can continue to read and write data to your stream while its status is @UPDATING@ . Once the status of the stream is @ACTIVE@ , records written to the stream will begin to be encrypted.
+--
+-- API Limits: You can successfully apply a new AWS KMS key for server-side encryption 25 times in a rolling 24 hour period.
+--
+-- Note: It can take up to 5 seconds after the stream is in an @ACTIVE@ status before all records written to the stream are encrypted. After you’ve enabled encryption, you can verify encryption was applied by inspecting the API response from @PutRecord@ or @PutRecords@ .
+--
+module Network.AWS.Kinesis.StartStreamEncryption
+ (
+ -- * Creating a Request
+ startStreamEncryption
+ , StartStreamEncryption
+ -- * Request Lenses
+ , sStreamName
+ , sEncryptionType
+ , sKeyId
+
+ -- * Destructuring the Response
+ , startStreamEncryptionResponse
+ , StartStreamEncryptionResponse
+ ) where
+
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
+
+-- | /See:/ 'startStreamEncryption' smart constructor.
+data StartStreamEncryption = StartStreamEncryption'
+ { _sStreamName :: !Text
+ , _sEncryptionType :: !EncryptionType
+ , _sKeyId :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
+
+-- | Creates a value of 'StartStreamEncryption' with the minimum fields required to make a request.
+--
+-- Use one of the following lenses to modify other fields as desired:
+--
+-- * 'sStreamName' - The name of the stream for which to start encrypting records.
+--
+-- * 'sEncryptionType' - The encryption type to use. This parameter can be one of the following values: * @NONE@ : Not valid for this operation. An @InvalidOperationException@ will be thrown. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+--
+-- * 'sKeyId' - The GUID for the customer-managed KMS key to use for encryption. You can also use a Kinesis-owned master key by specifying the alias @aws/kinesis@ .
+startStreamEncryption
+ :: Text -- ^ 'sStreamName'
+ -> EncryptionType -- ^ 'sEncryptionType'
+ -> Text -- ^ 'sKeyId'
+ -> StartStreamEncryption
+startStreamEncryption pStreamName_ pEncryptionType_ pKeyId_ =
+ StartStreamEncryption'
+ { _sStreamName = pStreamName_
+ , _sEncryptionType = pEncryptionType_
+ , _sKeyId = pKeyId_
+ }
+
+
+-- | The name of the stream for which to start encrypting records.
+sStreamName :: Lens' StartStreamEncryption Text
+sStreamName = lens _sStreamName (\ s a -> s{_sStreamName = a});
+
+-- | The encryption type to use. This parameter can be one of the following values: * @NONE@ : Not valid for this operation. An @InvalidOperationException@ will be thrown. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+sEncryptionType :: Lens' StartStreamEncryption EncryptionType
+sEncryptionType = lens _sEncryptionType (\ s a -> s{_sEncryptionType = a});
+
+-- | The GUID for the customer-managed KMS key to use for encryption. You can also use a Kinesis-owned master key by specifying the alias @aws/kinesis@ .
+sKeyId :: Lens' StartStreamEncryption Text
+sKeyId = lens _sKeyId (\ s a -> s{_sKeyId = a});
+
+instance AWSRequest StartStreamEncryption where
+ type Rs StartStreamEncryption =
+ StartStreamEncryptionResponse
+ request = postJSON kinesis
+ response = receiveNull StartStreamEncryptionResponse'
+
+instance Hashable StartStreamEncryption where
+
+instance NFData StartStreamEncryption where
+
+instance ToHeaders StartStreamEncryption where
+ toHeaders
+ = const
+ (mconcat
+ ["X-Amz-Target" =#
+ ("Kinesis_20131202.StartStreamEncryption" ::
+ ByteString),
+ "Content-Type" =#
+ ("application/x-amz-json-1.1" :: ByteString)])
+
+instance ToJSON StartStreamEncryption where
+ toJSON StartStreamEncryption'{..}
+ = object
+ (catMaybes
+ [Just ("StreamName" .= _sStreamName),
+ Just ("EncryptionType" .= _sEncryptionType),
+ Just ("KeyId" .= _sKeyId)])
+
+instance ToPath StartStreamEncryption where
+ toPath = const "/"
+
+instance ToQuery StartStreamEncryption where
+ toQuery = const mempty
+
+-- | /See:/ 'startStreamEncryptionResponse' smart constructor.
+data StartStreamEncryptionResponse =
+ StartStreamEncryptionResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
+
+-- | Creates a value of 'StartStreamEncryptionResponse' with the minimum fields required to make a request.
+--
+startStreamEncryptionResponse
+ :: StartStreamEncryptionResponse
+startStreamEncryptionResponse = StartStreamEncryptionResponse'
+
+
+instance NFData StartStreamEncryptionResponse where
diff --git a/gen/Network/AWS/Kinesis/StopStreamEncryption.hs b/gen/Network/AWS/Kinesis/StopStreamEncryption.hs
new file mode 100644
index 0000000..15849c8
--- /dev/null
+++ b/gen/Network/AWS/Kinesis/StopStreamEncryption.hs
@@ -0,0 +1,141 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE DeriveGeneric #-}
+{-# LANGUAGE OverloadedStrings #-}
+{-# LANGUAGE RecordWildCards #-}
+{-# LANGUAGE TypeFamilies #-}
+
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+{-# OPTIONS_GHC -fno-warn-unused-binds #-}
+{-# OPTIONS_GHC -fno-warn-unused-matches #-}
+
+-- Derived from AWS service descriptions, licensed under Apache 2.0.
+
+-- |
+-- Module : Network.AWS.Kinesis.StopStreamEncryption
+-- Copyright : (c) 2013-2017 Brendan Hay
+-- License : Mozilla Public License, v. 2.0.
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
+-- Stability : auto-generated
+-- Portability : non-portable (GHC extensions)
+--
+-- Disables server-side encryption for a specified stream.
+--
+--
+-- Stopping encryption is an asynchronous operation. Upon receiving the request, Amazon Kinesis returns immediately and sets the status of the stream to @UPDATING@ . After the update is complete, Amazon Kinesis sets the status of the stream back to @ACTIVE@ . Stopping encryption normally takes a few seconds to complete but it can take minutes. You can continue to read and write data to your stream while its status is @UPDATING@ . Once the status of the stream is @ACTIVE@ records written to the stream will no longer be encrypted by the Amazon Kinesis Streams service.
+--
+-- API Limits: You can successfully disable server-side encryption 25 times in a rolling 24 hour period.
+--
+-- Note: It can take up to 5 seconds after the stream is in an @ACTIVE@ status before all records written to the stream are no longer subject to encryption. After you’ve disabled encryption, you can verify encryption was not applied by inspecting the API response from @PutRecord@ or @PutRecords@ .
+--
+module Network.AWS.Kinesis.StopStreamEncryption
+ (
+ -- * Creating a Request
+ stopStreamEncryption
+ , StopStreamEncryption
+ -- * Request Lenses
+ , sseStreamName
+ , sseEncryptionType
+ , sseKeyId
+
+ -- * Destructuring the Response
+ , stopStreamEncryptionResponse
+ , StopStreamEncryptionResponse
+ ) where
+
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
+
+-- | /See:/ 'stopStreamEncryption' smart constructor.
+data StopStreamEncryption = StopStreamEncryption'
+ { _sseStreamName :: !Text
+ , _sseEncryptionType :: !EncryptionType
+ , _sseKeyId :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
+
+-- | Creates a value of 'StopStreamEncryption' with the minimum fields required to make a request.
+--
+-- Use one of the following lenses to modify other fields as desired:
+--
+-- * 'sseStreamName' - The name of the stream on which to stop encrypting records.
+--
+-- * 'sseEncryptionType' - The encryption type. This parameter can be one of the following values: * @NONE@ : Not valid for this operation. An @InvalidOperationException@ will be thrown. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+--
+-- * 'sseKeyId' - The GUID for the customer-managed key that was used for encryption.
+stopStreamEncryption
+ :: Text -- ^ 'sseStreamName'
+ -> EncryptionType -- ^ 'sseEncryptionType'
+ -> Text -- ^ 'sseKeyId'
+ -> StopStreamEncryption
+stopStreamEncryption pStreamName_ pEncryptionType_ pKeyId_ =
+ StopStreamEncryption'
+ { _sseStreamName = pStreamName_
+ , _sseEncryptionType = pEncryptionType_
+ , _sseKeyId = pKeyId_
+ }
+
+
+-- | The name of the stream on which to stop encrypting records.
+sseStreamName :: Lens' StopStreamEncryption Text
+sseStreamName = lens _sseStreamName (\ s a -> s{_sseStreamName = a});
+
+-- | The encryption type. This parameter can be one of the following values: * @NONE@ : Not valid for this operation. An @InvalidOperationException@ will be thrown. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+sseEncryptionType :: Lens' StopStreamEncryption EncryptionType
+sseEncryptionType = lens _sseEncryptionType (\ s a -> s{_sseEncryptionType = a});
+
+-- | The GUID for the customer-managed key that was used for encryption.
+sseKeyId :: Lens' StopStreamEncryption Text
+sseKeyId = lens _sseKeyId (\ s a -> s{_sseKeyId = a});
+
+instance AWSRequest StopStreamEncryption where
+ type Rs StopStreamEncryption =
+ StopStreamEncryptionResponse
+ request = postJSON kinesis
+ response = receiveNull StopStreamEncryptionResponse'
+
+instance Hashable StopStreamEncryption where
+
+instance NFData StopStreamEncryption where
+
+instance ToHeaders StopStreamEncryption where
+ toHeaders
+ = const
+ (mconcat
+ ["X-Amz-Target" =#
+ ("Kinesis_20131202.StopStreamEncryption" ::
+ ByteString),
+ "Content-Type" =#
+ ("application/x-amz-json-1.1" :: ByteString)])
+
+instance ToJSON StopStreamEncryption where
+ toJSON StopStreamEncryption'{..}
+ = object
+ (catMaybes
+ [Just ("StreamName" .= _sseStreamName),
+ Just ("EncryptionType" .= _sseEncryptionType),
+ Just ("KeyId" .= _sseKeyId)])
+
+instance ToPath StopStreamEncryption where
+ toPath = const "/"
+
+instance ToQuery StopStreamEncryption where
+ toQuery = const mempty
+
+-- | /See:/ 'stopStreamEncryptionResponse' smart constructor.
+data StopStreamEncryptionResponse =
+ StopStreamEncryptionResponse'
+ deriving (Eq, Read, Show, Data, Typeable, Generic)
+
+
+-- | Creates a value of 'StopStreamEncryptionResponse' with the minimum fields required to make a request.
+--
+stopStreamEncryptionResponse
+ :: StopStreamEncryptionResponse
+stopStreamEncryptionResponse = StopStreamEncryptionResponse'
+
+
+instance NFData StopStreamEncryptionResponse where
diff --git a/gen/Network/AWS/Kinesis/Types.hs b/gen/Network/AWS/Kinesis/Types.hs
index adb700a..d18c1f2 100644
--- a/gen/Network/AWS/Kinesis/Types.hs
+++ b/gen/Network/AWS/Kinesis/Types.hs
@@ -4,9 +4,9 @@
-- |
-- Module : Network.AWS.Kinesis.Types
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -16,13 +16,22 @@ module Network.AWS.Kinesis.Types
kinesis
-- * Errors
+ , _KMSInvalidStateException
+ , _KMSThrottlingException
, _ExpiredIteratorException
, _InvalidArgumentException
+ , _KMSOptInRequired
, _ProvisionedThroughputExceededException
+ , _KMSNotFoundException
+ , _KMSDisabledException
, _ResourceNotFoundException
+ , _KMSAccessDeniedException
, _LimitExceededException
, _ResourceInUseException
+ -- * EncryptionType
+ , EncryptionType (..)
+
-- * MetricsName
, MetricsName (..)
@@ -71,6 +80,7 @@ module Network.AWS.Kinesis.Types
-- * Record
, Record
, record
+ , rEncryptionType
, rApproximateArrivalTimestamp
, rSequenceNumber
, rData
@@ -94,6 +104,8 @@ module Network.AWS.Kinesis.Types
-- * StreamDescription
, StreamDescription
, streamDescription
+ , sdEncryptionType
+ , sdKeyId
, sdStreamName
, sdStreamARN
, sdStreamStatus
@@ -110,38 +122,40 @@ module Network.AWS.Kinesis.Types
, tagKey
) where
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Kinesis.Types.Sum
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Sign.V4
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Kinesis.Types.Sum
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Sign.V4
-- | API version @2013-12-02@ of the Amazon Kinesis SDK configuration.
kinesis :: Service
kinesis =
- Service
- { _svcAbbrev = "Kinesis"
- , _svcSigner = v4
- , _svcPrefix = "kinesis"
- , _svcVersion = "2013-12-02"
- , _svcEndpoint = defaultEndpoint kinesis
- , _svcTimeout = Just 70
- , _svcCheck = statusSuccess
- , _svcError = parseJSONError "Kinesis"
- , _svcRetry = retry
- }
+ Service
+ { _svcAbbrev = "Kinesis"
+ , _svcSigner = v4
+ , _svcPrefix = "kinesis"
+ , _svcVersion = "2013-12-02"
+ , _svcEndpoint = defaultEndpoint kinesis
+ , _svcTimeout = Just 70
+ , _svcCheck = statusSuccess
+ , _svcError = parseJSONError "Kinesis"
+ , _svcRetry = retry
+ }
where
retry =
- Exponential
- { _retryBase = 5.0e-2
- , _retryGrowth = 2
- , _retryAttempts = 5
- , _retryCheck = check
- }
+ Exponential
+ { _retryBase = 5.0e-2
+ , _retryGrowth = 2
+ , _retryAttempts = 5
+ , _retryCheck = check
+ }
check e
+ | has (hasCode "ThrottledException" . hasStatus 400) e =
+ Just "throttled_exception"
| has (hasStatus 429) e = Just "too_many_requests"
| has (hasCode "ThrottlingException" . hasStatus 400) e =
- Just "throttling_exception"
+ Just "throttling_exception"
| has (hasCode "Throttling" . hasStatus 400) e = Just "throttling"
| has (hasStatus 504) e = Just "gateway_timeout"
| has (hasStatus 502) e = Just "bad_gateway"
@@ -150,40 +164,93 @@ kinesis =
| has (hasStatus 509) e = Just "limit_exceeded"
| otherwise = Nothing
+
+-- | The request was rejected because the state of the specified resource isn't valid for this request. For more information, see <http://docs.aws.amazon.com/kms/latest/developerguide/key-state.html How Key State Affects Use of a Customer Master Key> in the /AWS Key Management Service Developer Guide/ .
+--
+--
+_KMSInvalidStateException :: AsError a => Getting (First ServiceError) a ServiceError
+_KMSInvalidStateException =
+ _MatchServiceError kinesis "KMSInvalidStateException"
+
+
+-- | The request was denied due to request throttling. For more information about throttling, see <http://docs.aws.amazon.com/kms/latest/developerguide/limits.html#requests-per-second Limits> in the /AWS Key Management Service Developer Guide/ .
+--
+--
+_KMSThrottlingException :: AsError a => Getting (First ServiceError) a ServiceError
+_KMSThrottlingException = _MatchServiceError kinesis "KMSThrottlingException"
+
+
-- | The provided iterator exceeds the maximum age allowed.
--
--
_ExpiredIteratorException :: AsError a => Getting (First ServiceError) a ServiceError
-_ExpiredIteratorException = _ServiceError . hasCode "ExpiredIteratorException"
+_ExpiredIteratorException =
+ _MatchServiceError kinesis "ExpiredIteratorException"
+
-- | A specified parameter exceeds its restrictions, is not supported, or can't be used. For more information, see the returned message.
--
--
_InvalidArgumentException :: AsError a => Getting (First ServiceError) a ServiceError
-_InvalidArgumentException = _ServiceError . hasCode "InvalidArgumentException"
+_InvalidArgumentException =
+ _MatchServiceError kinesis "InvalidArgumentException"
+
+
+-- | The AWS access key ID needs a subscription for the service.
+--
+--
+_KMSOptInRequired :: AsError a => Getting (First ServiceError) a ServiceError
+_KMSOptInRequired = _MatchServiceError kinesis "KMSOptInRequired"
+
-- | The request rate for the stream is too high, or the requested data is too large for the available throughput. Reduce the frequency or size of your requests. For more information, see <http://docs.aws.amazon.com/kinesis/latest/dev/service-sizes-and-limits.html Streams Limits> in the /Amazon Kinesis Streams Developer Guide/ , and <http://docs.aws.amazon.com/general/latest/gr/api-retries.html Error Retries and Exponential Backoff in AWS> in the /AWS General Reference/ .
--
--
_ProvisionedThroughputExceededException :: AsError a => Getting (First ServiceError) a ServiceError
_ProvisionedThroughputExceededException =
- _ServiceError . hasCode "ProvisionedThroughputExceededException"
+ _MatchServiceError kinesis "ProvisionedThroughputExceededException"
+
+
+-- | The request was rejected because the specified entity or resource couldn't be found.
+--
+--
+_KMSNotFoundException :: AsError a => Getting (First ServiceError) a ServiceError
+_KMSNotFoundException = _MatchServiceError kinesis "KMSNotFoundException"
+
+
+-- | The request was rejected because the specified CMK isn't enabled.
+--
+--
+_KMSDisabledException :: AsError a => Getting (First ServiceError) a ServiceError
+_KMSDisabledException = _MatchServiceError kinesis "KMSDisabledException"
+
-- | The requested resource could not be found. The stream might not be specified correctly.
--
--
_ResourceNotFoundException :: AsError a => Getting (First ServiceError) a ServiceError
_ResourceNotFoundException =
- _ServiceError . hasCode "ResourceNotFoundException"
+ _MatchServiceError kinesis "ResourceNotFoundException"
+
+
+-- | The ciphertext references a key that doesn't exist or that you don't have access to.
+--
+--
+_KMSAccessDeniedException :: AsError a => Getting (First ServiceError) a ServiceError
+_KMSAccessDeniedException =
+ _MatchServiceError kinesis "KMSAccessDeniedException"
+
-- | The requested resource exceeds the maximum number allowed, or the number of concurrent stream requests exceeds the maximum number allowed (5).
--
--
_LimitExceededException :: AsError a => Getting (First ServiceError) a ServiceError
-_LimitExceededException = _ServiceError . hasCode "LimitExceededException"
+_LimitExceededException = _MatchServiceError kinesis "LimitExceededException"
+
-- | The resource is not available for this operation. For successful operation, the resource needs to be in the @ACTIVE@ state.
--
--
_ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError
-_ResourceInUseException = _ServiceError . hasCode "ResourceInUseException"
+_ResourceInUseException = _MatchServiceError kinesis "ResourceInUseException"
+
diff --git a/gen/Network/AWS/Kinesis/Types/Product.hs b/gen/Network/AWS/Kinesis/Types/Product.hs
index 66e8227..0b366df 100644
--- a/gen/Network/AWS/Kinesis/Types/Product.hs
+++ b/gen/Network/AWS/Kinesis/Types/Product.hs
@@ -9,17 +9,17 @@
-- |
-- Module : Network.AWS.Kinesis.Types.Product
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
module Network.AWS.Kinesis.Types.Product where
-import Network.AWS.Kinesis.Types.Sum
-import Network.AWS.Lens
-import Network.AWS.Prelude
+import Network.AWS.Kinesis.Types.Sum
+import Network.AWS.Lens
+import Network.AWS.Prelude
-- | Represents enhanced metrics types.
--
@@ -27,8 +27,9 @@ import Network.AWS.Prelude
--
-- /See:/ 'enhancedMetrics' smart constructor.
newtype EnhancedMetrics = EnhancedMetrics'
- { _emShardLevelMetrics :: Maybe [MetricsName]
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _emShardLevelMetrics :: Maybe [MetricsName]
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'EnhancedMetrics' with the minimum fields required to make a request.
--
@@ -37,10 +38,8 @@ newtype EnhancedMetrics = EnhancedMetrics'
-- * 'emShardLevelMetrics' - List of shard-level metrics. The following are the valid shard-level metrics. The value "@ALL@ " enhances every metric. * @IncomingBytes@ * @IncomingRecords@ * @OutgoingBytes@ * @OutgoingRecords@ * @WriteProvisionedThroughputExceeded@ * @ReadProvisionedThroughputExceeded@ * @IteratorAgeMilliseconds@ * @ALL@ For more information, see <http://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html Monitoring the Amazon Kinesis Streams Service with Amazon CloudWatch> in the /Amazon Kinesis Streams Developer Guide/ .
enhancedMetrics
:: EnhancedMetrics
-enhancedMetrics =
- EnhancedMetrics'
- { _emShardLevelMetrics = Nothing
- }
+enhancedMetrics = EnhancedMetrics' {_emShardLevelMetrics = Nothing}
+
-- | List of shard-level metrics. The following are the valid shard-level metrics. The value "@ALL@ " enhances every metric. * @IncomingBytes@ * @IncomingRecords@ * @OutgoingBytes@ * @OutgoingRecords@ * @WriteProvisionedThroughputExceeded@ * @ReadProvisionedThroughputExceeded@ * @IteratorAgeMilliseconds@ * @ALL@ For more information, see <http://docs.aws.amazon.com/kinesis/latest/dev/monitoring-with-cloudwatch.html Monitoring the Amazon Kinesis Streams Service with Amazon CloudWatch> in the /Amazon Kinesis Streams Developer Guide/ .
emShardLevelMetrics :: Lens' EnhancedMetrics [MetricsName]
@@ -53,9 +52,9 @@ instance FromJSON EnhancedMetrics where
EnhancedMetrics' <$>
(x .:? "ShardLevelMetrics" .!= mempty))
-instance Hashable EnhancedMetrics
+instance Hashable EnhancedMetrics where
-instance NFData EnhancedMetrics
+instance NFData EnhancedMetrics where
-- | Represents the output for 'EnableEnhancedMonitoring' and 'DisableEnhancedMonitoring' .
--
@@ -63,10 +62,11 @@ instance NFData EnhancedMetrics
--
-- /See:/ 'enhancedMonitoringOutput' smart constructor.
data EnhancedMonitoringOutput = EnhancedMonitoringOutput'
- { _emoDesiredShardLevelMetrics :: !(Maybe [MetricsName])
- , _emoCurrentShardLevelMetrics :: !(Maybe [MetricsName])
- , _emoStreamName :: !(Maybe Text)
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _emoDesiredShardLevelMetrics :: !(Maybe [MetricsName])
+ , _emoCurrentShardLevelMetrics :: !(Maybe [MetricsName])
+ , _emoStreamName :: !(Maybe Text)
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'EnhancedMonitoringOutput' with the minimum fields required to make a request.
--
@@ -80,11 +80,12 @@ data EnhancedMonitoringOutput = EnhancedMonitoringOutput'
enhancedMonitoringOutput
:: EnhancedMonitoringOutput
enhancedMonitoringOutput =
- EnhancedMonitoringOutput'
- { _emoDesiredShardLevelMetrics = Nothing
- , _emoCurrentShardLevelMetrics = Nothing
- , _emoStreamName = Nothing
- }
+ EnhancedMonitoringOutput'
+ { _emoDesiredShardLevelMetrics = Nothing
+ , _emoCurrentShardLevelMetrics = Nothing
+ , _emoStreamName = Nothing
+ }
+
-- | Represents the list of all the metrics that would be in the enhanced state after the operation.
emoDesiredShardLevelMetrics :: Lens' EnhancedMonitoringOutput [MetricsName]
@@ -107,9 +108,9 @@ instance FromJSON EnhancedMonitoringOutput where
(x .:? "CurrentShardLevelMetrics" .!= mempty)
<*> (x .:? "StreamName"))
-instance Hashable EnhancedMonitoringOutput
+instance Hashable EnhancedMonitoringOutput where
-instance NFData EnhancedMonitoringOutput
+instance NFData EnhancedMonitoringOutput where
-- | The range of possible hash key values for the shard, which is a set of ordered contiguous positive integers.
--
@@ -117,9 +118,10 @@ instance NFData EnhancedMonitoringOutput
--
-- /See:/ 'hashKeyRange' smart constructor.
data HashKeyRange = HashKeyRange'
- { _hkrStartingHashKey :: !Text
- , _hkrEndingHashKey :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _hkrStartingHashKey :: !Text
+ , _hkrEndingHashKey :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'HashKeyRange' with the minimum fields required to make a request.
--
@@ -133,10 +135,9 @@ hashKeyRange
-> Text -- ^ 'hkrEndingHashKey'
-> HashKeyRange
hashKeyRange pStartingHashKey_ pEndingHashKey_ =
- HashKeyRange'
- { _hkrStartingHashKey = pStartingHashKey_
- , _hkrEndingHashKey = pEndingHashKey_
- }
+ HashKeyRange'
+ {_hkrStartingHashKey = pStartingHashKey_, _hkrEndingHashKey = pEndingHashKey_}
+
-- | The starting hash key of the hash key range.
hkrStartingHashKey :: Lens' HashKeyRange Text
@@ -153,9 +154,9 @@ instance FromJSON HashKeyRange where
HashKeyRange' <$>
(x .: "StartingHashKey") <*> (x .: "EndingHashKey"))
-instance Hashable HashKeyRange
+instance Hashable HashKeyRange where
-instance NFData HashKeyRange
+instance NFData HashKeyRange where
-- | Represents the output for @PutRecords@ .
--
@@ -163,10 +164,11 @@ instance NFData HashKeyRange
--
-- /See:/ 'putRecordsRequestEntry' smart constructor.
data PutRecordsRequestEntry = PutRecordsRequestEntry'
- { _prreExplicitHashKey :: !(Maybe Text)
- , _prreData :: !Base64
- , _prrePartitionKey :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _prreExplicitHashKey :: !(Maybe Text)
+ , _prreData :: !Base64
+ , _prrePartitionKey :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'PutRecordsRequestEntry' with the minimum fields required to make a request.
--
@@ -182,11 +184,12 @@ putRecordsRequestEntry
-> Text -- ^ 'prrePartitionKey'
-> PutRecordsRequestEntry
putRecordsRequestEntry pData_ pPartitionKey_ =
- PutRecordsRequestEntry'
- { _prreExplicitHashKey = Nothing
- , _prreData = _Base64 # pData_
- , _prrePartitionKey = pPartitionKey_
- }
+ PutRecordsRequestEntry'
+ { _prreExplicitHashKey = Nothing
+ , _prreData = _Base64 # pData_
+ , _prrePartitionKey = pPartitionKey_
+ }
+
-- | The hash value used to determine explicitly the shard that the data record is assigned to by overriding the partition key hash.
prreExplicitHashKey :: Lens' PutRecordsRequestEntry (Maybe Text)
@@ -200,9 +203,9 @@ prreData = lens _prreData (\ s a -> s{_prreData = a}) . _Base64;
prrePartitionKey :: Lens' PutRecordsRequestEntry Text
prrePartitionKey = lens _prrePartitionKey (\ s a -> s{_prrePartitionKey = a});
-instance Hashable PutRecordsRequestEntry
+instance Hashable PutRecordsRequestEntry where
-instance NFData PutRecordsRequestEntry
+instance NFData PutRecordsRequestEntry where
instance ToJSON PutRecordsRequestEntry where
toJSON PutRecordsRequestEntry'{..}
@@ -218,11 +221,12 @@ instance ToJSON PutRecordsRequestEntry where
--
-- /See:/ 'putRecordsResultEntry' smart constructor.
data PutRecordsResultEntry = PutRecordsResultEntry'
- { _prreSequenceNumber :: !(Maybe Text)
- , _prreErrorCode :: !(Maybe Text)
- , _prreErrorMessage :: !(Maybe Text)
- , _prreShardId :: !(Maybe Text)
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _prreSequenceNumber :: !(Maybe Text)
+ , _prreErrorCode :: !(Maybe Text)
+ , _prreErrorMessage :: !(Maybe Text)
+ , _prreShardId :: !(Maybe Text)
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'PutRecordsResultEntry' with the minimum fields required to make a request.
--
@@ -238,12 +242,13 @@ data PutRecordsResultEntry = PutRecordsResultEntry'
putRecordsResultEntry
:: PutRecordsResultEntry
putRecordsResultEntry =
- PutRecordsResultEntry'
- { _prreSequenceNumber = Nothing
- , _prreErrorCode = Nothing
- , _prreErrorMessage = Nothing
- , _prreShardId = Nothing
- }
+ PutRecordsResultEntry'
+ { _prreSequenceNumber = Nothing
+ , _prreErrorCode = Nothing
+ , _prreErrorMessage = Nothing
+ , _prreShardId = Nothing
+ }
+
-- | The sequence number for an individual record result.
prreSequenceNumber :: Lens' PutRecordsResultEntry (Maybe Text)
@@ -270,9 +275,9 @@ instance FromJSON PutRecordsResultEntry where
(x .:? "ErrorMessage")
<*> (x .:? "ShardId"))
-instance Hashable PutRecordsResultEntry
+instance Hashable PutRecordsResultEntry where
-instance NFData PutRecordsResultEntry
+instance NFData PutRecordsResultEntry where
-- | The unit of data of the Amazon Kinesis stream, which is composed of a sequence number, a partition key, and a data blob.
--
@@ -280,19 +285,23 @@ instance NFData PutRecordsResultEntry
--
-- /See:/ 'record' smart constructor.
data Record = Record'
- { _rApproximateArrivalTimestamp :: !(Maybe POSIX)
- , _rSequenceNumber :: !Text
- , _rData :: !Base64
- , _rPartitionKey :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _rEncryptionType :: !(Maybe EncryptionType)
+ , _rApproximateArrivalTimestamp :: !(Maybe POSIX)
+ , _rSequenceNumber :: !Text
+ , _rData :: !Base64
+ , _rPartitionKey :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'Record' with the minimum fields required to make a request.
--
-- Use one of the following lenses to modify other fields as desired:
--
+-- * 'rEncryptionType' - The encryption type used on the record. This parameter can be one of the following values: * @NONE@ : Do not encrypt the records in the stream. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+--
-- * 'rApproximateArrivalTimestamp' - The approximate time that the record was inserted into the stream.
--
--- * 'rSequenceNumber' - The unique identifier of the record in the stream.
+-- * 'rSequenceNumber' - The unique identifier of the record within its shard.
--
-- * 'rData' - The data blob. The data in the blob is both opaque and immutable to the Amazon Kinesis service, which does not inspect, interpret, or change the data in the blob in any way. When the data blob (the payload before base64-encoding) is added to the partition key size, the total size must not exceed the maximum record size (1 MB).-- /Note:/ This 'Lens' automatically encodes and decodes Base64 data. The underlying isomorphism will encode to Base64 representation during serialisation, and decode from Base64 representation during deserialisation. This 'Lens' accepts and returns only raw unencoded data.
--
@@ -303,18 +312,24 @@ record
-> Text -- ^ 'rPartitionKey'
-> Record
record pSequenceNumber_ pData_ pPartitionKey_ =
- Record'
- { _rApproximateArrivalTimestamp = Nothing
- , _rSequenceNumber = pSequenceNumber_
- , _rData = _Base64 # pData_
- , _rPartitionKey = pPartitionKey_
- }
+ Record'
+ { _rEncryptionType = Nothing
+ , _rApproximateArrivalTimestamp = Nothing
+ , _rSequenceNumber = pSequenceNumber_
+ , _rData = _Base64 # pData_
+ , _rPartitionKey = pPartitionKey_
+ }
+
+
+-- | The encryption type used on the record. This parameter can be one of the following values: * @NONE@ : Do not encrypt the records in the stream. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+rEncryptionType :: Lens' Record (Maybe EncryptionType)
+rEncryptionType = lens _rEncryptionType (\ s a -> s{_rEncryptionType = a});
-- | The approximate time that the record was inserted into the stream.
rApproximateArrivalTimestamp :: Lens' Record (Maybe UTCTime)
rApproximateArrivalTimestamp = lens _rApproximateArrivalTimestamp (\ s a -> s{_rApproximateArrivalTimestamp = a}) . mapping _Time;
--- | The unique identifier of the record in the stream.
+-- | The unique identifier of the record within its shard.
rSequenceNumber :: Lens' Record Text
rSequenceNumber = lens _rSequenceNumber (\ s a -> s{_rSequenceNumber = a});
@@ -331,14 +346,15 @@ instance FromJSON Record where
= withObject "Record"
(\ x ->
Record' <$>
- (x .:? "ApproximateArrivalTimestamp") <*>
- (x .: "SequenceNumber")
+ (x .:? "EncryptionType") <*>
+ (x .:? "ApproximateArrivalTimestamp")
+ <*> (x .: "SequenceNumber")
<*> (x .: "Data")
<*> (x .: "PartitionKey"))
-instance Hashable Record
+instance Hashable Record where
-instance NFData Record
+instance NFData Record where
-- | The range of possible sequence numbers for the shard.
--
@@ -346,9 +362,10 @@ instance NFData Record
--
-- /See:/ 'sequenceNumberRange' smart constructor.
data SequenceNumberRange = SequenceNumberRange'
- { _snrEndingSequenceNumber :: !(Maybe Text)
- , _snrStartingSequenceNumber :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _snrEndingSequenceNumber :: !(Maybe Text)
+ , _snrStartingSequenceNumber :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'SequenceNumberRange' with the minimum fields required to make a request.
--
@@ -361,10 +378,11 @@ sequenceNumberRange
:: Text -- ^ 'snrStartingSequenceNumber'
-> SequenceNumberRange
sequenceNumberRange pStartingSequenceNumber_ =
- SequenceNumberRange'
- { _snrEndingSequenceNumber = Nothing
- , _snrStartingSequenceNumber = pStartingSequenceNumber_
- }
+ SequenceNumberRange'
+ { _snrEndingSequenceNumber = Nothing
+ , _snrStartingSequenceNumber = pStartingSequenceNumber_
+ }
+
-- | The ending sequence number for the range. Shards that are in the OPEN state have an ending sequence number of @null@ .
snrEndingSequenceNumber :: Lens' SequenceNumberRange (Maybe Text)
@@ -382,9 +400,9 @@ instance FromJSON SequenceNumberRange where
(x .:? "EndingSequenceNumber") <*>
(x .: "StartingSequenceNumber"))
-instance Hashable SequenceNumberRange
+instance Hashable SequenceNumberRange where
-instance NFData SequenceNumberRange
+instance NFData SequenceNumberRange where
-- | A uniquely identified group of data records in an Amazon Kinesis stream.
--
@@ -392,12 +410,13 @@ instance NFData SequenceNumberRange
--
-- /See:/ 'shard' smart constructor.
data Shard = Shard'
- { _sAdjacentParentShardId :: !(Maybe Text)
- , _sParentShardId :: !(Maybe Text)
- , _sShardId :: !Text
- , _sHashKeyRange :: !HashKeyRange
- , _sSequenceNumberRange :: !SequenceNumberRange
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _sAdjacentParentShardId :: !(Maybe Text)
+ , _sParentShardId :: !(Maybe Text)
+ , _sShardId :: !Text
+ , _sHashKeyRange :: !HashKeyRange
+ , _sSequenceNumberRange :: !SequenceNumberRange
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'Shard' with the minimum fields required to make a request.
--
@@ -418,13 +437,14 @@ shard
-> SequenceNumberRange -- ^ 'sSequenceNumberRange'
-> Shard
shard pShardId_ pHashKeyRange_ pSequenceNumberRange_ =
- Shard'
- { _sAdjacentParentShardId = Nothing
- , _sParentShardId = Nothing
- , _sShardId = pShardId_
- , _sHashKeyRange = pHashKeyRange_
- , _sSequenceNumberRange = pSequenceNumberRange_
- }
+ Shard'
+ { _sAdjacentParentShardId = Nothing
+ , _sParentShardId = Nothing
+ , _sShardId = pShardId_
+ , _sHashKeyRange = pHashKeyRange_
+ , _sSequenceNumberRange = pSequenceNumberRange_
+ }
+
-- | The shard ID of the shard adjacent to the shard's parent.
sAdjacentParentShardId :: Lens' Shard (Maybe Text)
@@ -457,9 +477,9 @@ instance FromJSON Shard where
<*> (x .: "HashKeyRange")
<*> (x .: "SequenceNumberRange"))
-instance Hashable Shard
+instance Hashable Shard where
-instance NFData Shard
+instance NFData Shard where
-- | Represents the output for 'DescribeStream' .
--
@@ -467,20 +487,27 @@ instance NFData Shard
--
-- /See:/ 'streamDescription' smart constructor.
data StreamDescription = StreamDescription'
- { _sdStreamName :: !Text
- , _sdStreamARN :: !Text
- , _sdStreamStatus :: !StreamStatus
- , _sdShards :: ![Shard]
- , _sdHasMoreShards :: !Bool
- , _sdRetentionPeriodHours :: !Nat
- , _sdStreamCreationTimestamp :: !POSIX
- , _sdEnhancedMonitoring :: ![EnhancedMetrics]
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _sdEncryptionType :: !(Maybe EncryptionType)
+ , _sdKeyId :: !(Maybe Text)
+ , _sdStreamName :: !Text
+ , _sdStreamARN :: !Text
+ , _sdStreamStatus :: !StreamStatus
+ , _sdShards :: ![Shard]
+ , _sdHasMoreShards :: !Bool
+ , _sdRetentionPeriodHours :: !Nat
+ , _sdStreamCreationTimestamp :: !POSIX
+ , _sdEnhancedMonitoring :: ![EnhancedMetrics]
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'StreamDescription' with the minimum fields required to make a request.
--
-- Use one of the following lenses to modify other fields as desired:
--
+-- * 'sdEncryptionType' - The server-side encryption type used on the stream. This parameter can be one of the following values: * @NONE@ : Do not encrypt the records in the stream. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+--
+-- * 'sdKeyId' - The GUID for the customer-managed KMS key used for encryption on the stream.
+--
-- * 'sdStreamName' - The name of the stream being described.
--
-- * 'sdStreamARN' - The Amazon Resource Name (ARN) for the stream being described.
@@ -505,16 +532,27 @@ streamDescription
-> UTCTime -- ^ 'sdStreamCreationTimestamp'
-> StreamDescription
streamDescription pStreamName_ pStreamARN_ pStreamStatus_ pHasMoreShards_ pRetentionPeriodHours_ pStreamCreationTimestamp_ =
- StreamDescription'
- { _sdStreamName = pStreamName_
- , _sdStreamARN = pStreamARN_
- , _sdStreamStatus = pStreamStatus_
- , _sdShards = mempty
- , _sdHasMoreShards = pHasMoreShards_
- , _sdRetentionPeriodHours = _Nat # pRetentionPeriodHours_
- , _sdStreamCreationTimestamp = _Time # pStreamCreationTimestamp_
- , _sdEnhancedMonitoring = mempty
- }
+ StreamDescription'
+ { _sdEncryptionType = Nothing
+ , _sdKeyId = Nothing
+ , _sdStreamName = pStreamName_
+ , _sdStreamARN = pStreamARN_
+ , _sdStreamStatus = pStreamStatus_
+ , _sdShards = mempty
+ , _sdHasMoreShards = pHasMoreShards_
+ , _sdRetentionPeriodHours = _Nat # pRetentionPeriodHours_
+ , _sdStreamCreationTimestamp = _Time # pStreamCreationTimestamp_
+ , _sdEnhancedMonitoring = mempty
+ }
+
+
+-- | The server-side encryption type used on the stream. This parameter can be one of the following values: * @NONE@ : Do not encrypt the records in the stream. * @KMS@ : Use server-side encryption on the records in the stream using a customer-managed KMS key.
+sdEncryptionType :: Lens' StreamDescription (Maybe EncryptionType)
+sdEncryptionType = lens _sdEncryptionType (\ s a -> s{_sdEncryptionType = a});
+
+-- | The GUID for the customer-managed KMS key used for encryption on the stream.
+sdKeyId :: Lens' StreamDescription (Maybe Text)
+sdKeyId = lens _sdKeyId (\ s a -> s{_sdKeyId = a});
-- | The name of the stream being described.
sdStreamName :: Lens' StreamDescription Text
@@ -553,17 +591,19 @@ instance FromJSON StreamDescription where
= withObject "StreamDescription"
(\ x ->
StreamDescription' <$>
- (x .: "StreamName") <*> (x .: "StreamARN") <*>
- (x .: "StreamStatus")
+ (x .:? "EncryptionType") <*> (x .:? "KeyId") <*>
+ (x .: "StreamName")
+ <*> (x .: "StreamARN")
+ <*> (x .: "StreamStatus")
<*> (x .:? "Shards" .!= mempty)
<*> (x .: "HasMoreShards")
<*> (x .: "RetentionPeriodHours")
<*> (x .: "StreamCreationTimestamp")
<*> (x .:? "EnhancedMonitoring" .!= mempty))
-instance Hashable StreamDescription
+instance Hashable StreamDescription where
-instance NFData StreamDescription
+instance NFData StreamDescription where
-- | Metadata assigned to the stream, consisting of a key-value pair.
--
@@ -571,9 +611,10 @@ instance NFData StreamDescription
--
-- /See:/ 'tag' smart constructor.
data Tag = Tag'
- { _tagValue :: !(Maybe Text)
- , _tagKey :: !Text
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _tagValue :: !(Maybe Text)
+ , _tagKey :: !Text
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'Tag' with the minimum fields required to make a request.
--
@@ -585,11 +626,8 @@ data Tag = Tag'
tag
:: Text -- ^ 'tagKey'
-> Tag
-tag pKey_ =
- Tag'
- { _tagValue = Nothing
- , _tagKey = pKey_
- }
+tag pKey_ = Tag' {_tagValue = Nothing, _tagKey = pKey_}
+
-- | An optional string, typically used to describe or define the tag. Maximum length: 256 characters. Valid characters: Unicode letters, digits, white space, _ . / = + - % @
tagValue :: Lens' Tag (Maybe Text)
@@ -604,6 +642,6 @@ instance FromJSON Tag where
= withObject "Tag"
(\ x -> Tag' <$> (x .:? "Value") <*> (x .: "Key"))
-instance Hashable Tag
+instance Hashable Tag where
-instance NFData Tag
+instance NFData Tag where
diff --git a/gen/Network/AWS/Kinesis/Types/Sum.hs b/gen/Network/AWS/Kinesis/Types/Sum.hs
index 7563961..ef2ebb0 100644
--- a/gen/Network/AWS/Kinesis/Types/Sum.hs
+++ b/gen/Network/AWS/Kinesis/Types/Sum.hs
@@ -9,26 +9,57 @@
-- |
-- Module : Network.AWS.Kinesis.Types.Sum
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
module Network.AWS.Kinesis.Types.Sum where
-import Network.AWS.Prelude
+import Network.AWS.Prelude
+
+data EncryptionType
+ = KMS
+ | None
+ deriving (Eq, Ord, Read, Show, Enum, Bounded, Data, Typeable, Generic)
+
+
+instance FromText EncryptionType where
+ parser = takeLowerText >>= \case
+ "kms" -> pure KMS
+ "none" -> pure None
+ e -> fromTextError $ "Failure parsing EncryptionType from value: '" <> e
+ <> "'. Accepted values: kms, none"
+
+instance ToText EncryptionType where
+ toText = \case
+ KMS -> "KMS"
+ None -> "NONE"
+
+instance Hashable EncryptionType
+instance NFData EncryptionType
+instance ToByteString EncryptionType
+instance ToQuery EncryptionType
+instance ToHeader EncryptionType
+
+instance ToJSON EncryptionType where
+ toJSON = toJSONText
+
+instance FromJSON EncryptionType where
+ parseJSON = parseJSONText "EncryptionType"
data MetricsName
- = All
- | IncomingBytes
- | IncomingRecords
- | IteratorAgeMilliseconds
- | OutgoingBytes
- | OutgoingRecords
- | ReadProvisionedThroughputExceeded
- | WriteProvisionedThroughputExceeded
- deriving (Eq,Ord,Read,Show,Enum,Bounded,Data,Typeable,Generic)
+ = All
+ | IncomingBytes
+ | IncomingRecords
+ | IteratorAgeMilliseconds
+ | OutgoingBytes
+ | OutgoingRecords
+ | ReadProvisionedThroughputExceeded
+ | WriteProvisionedThroughputExceeded
+ deriving (Eq, Ord, Read, Show, Enum, Bounded, Data, Typeable, Generic)
+
instance FromText MetricsName where
parser = takeLowerText >>= \case
@@ -67,8 +98,9 @@ instance FromJSON MetricsName where
parseJSON = parseJSONText "MetricsName"
data ScalingType =
- UniformScaling
- deriving (Eq,Ord,Read,Show,Enum,Bounded,Data,Typeable,Generic)
+ UniformScaling
+ deriving (Eq, Ord, Read, Show, Enum, Bounded, Data, Typeable, Generic)
+
instance FromText ScalingType where
parser = takeLowerText >>= \case
@@ -90,12 +122,13 @@ instance ToJSON ScalingType where
toJSON = toJSONText
data ShardIteratorType
- = AfterSequenceNumber
- | AtSequenceNumber
- | AtTimestamp
- | Latest
- | TrimHorizon
- deriving (Eq,Ord,Read,Show,Enum,Bounded,Data,Typeable,Generic)
+ = AfterSequenceNumber
+ | AtSequenceNumber
+ | AtTimestamp
+ | Latest
+ | TrimHorizon
+ deriving (Eq, Ord, Read, Show, Enum, Bounded, Data, Typeable, Generic)
+
instance FromText ShardIteratorType where
parser = takeLowerText >>= \case
@@ -125,11 +158,12 @@ instance ToJSON ShardIteratorType where
toJSON = toJSONText
data StreamStatus
- = Active
- | Creating
- | Deleting
- | Updating
- deriving (Eq,Ord,Read,Show,Enum,Bounded,Data,Typeable,Generic)
+ = Active
+ | Creating
+ | Deleting
+ | Updating
+ deriving (Eq, Ord, Read, Show, Enum, Bounded, Data, Typeable, Generic)
+
instance FromText StreamStatus where
parser = takeLowerText >>= \case
diff --git a/gen/Network/AWS/Kinesis/UpdateShardCount.hs b/gen/Network/AWS/Kinesis/UpdateShardCount.hs
index 4790a84..34df0cc 100644
--- a/gen/Network/AWS/Kinesis/UpdateShardCount.hs
+++ b/gen/Network/AWS/Kinesis/UpdateShardCount.hs
@@ -12,9 +12,9 @@
-- |
-- Module : Network.AWS.Kinesis.UpdateShardCount
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
@@ -23,9 +23,25 @@
--
-- Updating the shard count is an asynchronous operation. Upon receiving the request, Amazon Kinesis returns immediately and sets the status of the stream to @UPDATING@ . After the update is complete, Amazon Kinesis sets the status of the stream back to @ACTIVE@ . Depending on the size of the stream, the scaling action could take a few minutes to complete. You can continue to read and write data to your stream while its status is @UPDATING@ .
--
--- To update the shard count, Amazon Kinesis performs splits and merges and individual shards. This can cause short-lived shards to be created, in addition to the final shards. We recommend that you double or halve the shard count, as this results in the fewest number of splits or merges.
+-- To update the shard count, Amazon Kinesis performs splits or merges on individual shards. This can cause short-lived shards to be created, in addition to the final shards. We recommend that you double or halve the shard count, as this results in the fewest number of splits or merges.
+--
+-- This operation has the following limits, which are per region per account unless otherwise noted:
+--
+-- * scale more than twice per rolling 24 hour period
+--
+-- * scale up above double your current shard count
+--
+-- * scale down below half your current shard count
+--
+-- * scale up above 200 shards in a stream
+--
+-- * scale a stream with more than 200 shards down unless the result is less than 200 shards
+--
+-- * scale up above the shard limits for your account
+--
+-- *
+--
--
--- This operation has a rate limit of twice per rolling 24 hour period. You cannot scale above double your current shard count, scale below half your current shard count, or exceed the shard limits for your account.
--
-- For the default limits for an AWS account, see <http://docs.aws.amazon.com/kinesis/latest/dev/service-sizes-and-limits.html Streams Limits> in the /Amazon Kinesis Streams Developer Guide/ . If you need to increase a limit, <http://docs.aws.amazon.com/general/latest/gr/aws_service_limits.html contact AWS Support> .
--
@@ -49,19 +65,20 @@ module Network.AWS.Kinesis.UpdateShardCount
, uscrsResponseStatus
) where
-import Network.AWS.Kinesis.Types
-import Network.AWS.Kinesis.Types.Product
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Request
-import Network.AWS.Response
+import Network.AWS.Kinesis.Types
+import Network.AWS.Kinesis.Types.Product
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Request
+import Network.AWS.Response
-- | /See:/ 'updateShardCount' smart constructor.
data UpdateShardCount = UpdateShardCount'
- { _uscStreamName :: !Text
- , _uscTargetShardCount :: !Nat
- , _uscScalingType :: !ScalingType
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _uscStreamName :: !Text
+ , _uscTargetShardCount :: !Nat
+ , _uscScalingType :: !ScalingType
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'UpdateShardCount' with the minimum fields required to make a request.
--
@@ -78,11 +95,12 @@ updateShardCount
-> ScalingType -- ^ 'uscScalingType'
-> UpdateShardCount
updateShardCount pStreamName_ pTargetShardCount_ pScalingType_ =
- UpdateShardCount'
- { _uscStreamName = pStreamName_
- , _uscTargetShardCount = _Nat # pTargetShardCount_
- , _uscScalingType = pScalingType_
- }
+ UpdateShardCount'
+ { _uscStreamName = pStreamName_
+ , _uscTargetShardCount = _Nat # pTargetShardCount_
+ , _uscScalingType = pScalingType_
+ }
+
-- | The name of the stream.
uscStreamName :: Lens' UpdateShardCount Text
@@ -107,9 +125,9 @@ instance AWSRequest UpdateShardCount where
<*> (x .?> "CurrentShardCount")
<*> (pure (fromEnum s)))
-instance Hashable UpdateShardCount
+instance Hashable UpdateShardCount where
-instance NFData UpdateShardCount
+instance NFData UpdateShardCount where
instance ToHeaders UpdateShardCount where
toHeaders
@@ -136,11 +154,12 @@ instance ToQuery UpdateShardCount where
-- | /See:/ 'updateShardCountResponse' smart constructor.
data UpdateShardCountResponse = UpdateShardCountResponse'
- { _uscrsTargetShardCount :: !(Maybe Nat)
- , _uscrsStreamName :: !(Maybe Text)
- , _uscrsCurrentShardCount :: !(Maybe Nat)
- , _uscrsResponseStatus :: !Int
- } deriving (Eq,Read,Show,Data,Typeable,Generic)
+ { _uscrsTargetShardCount :: !(Maybe Nat)
+ , _uscrsStreamName :: !(Maybe Text)
+ , _uscrsCurrentShardCount :: !(Maybe Nat)
+ , _uscrsResponseStatus :: !Int
+ } deriving (Eq, Read, Show, Data, Typeable, Generic)
+
-- | Creates a value of 'UpdateShardCountResponse' with the minimum fields required to make a request.
--
@@ -157,12 +176,13 @@ updateShardCountResponse
:: Int -- ^ 'uscrsResponseStatus'
-> UpdateShardCountResponse
updateShardCountResponse pResponseStatus_ =
- UpdateShardCountResponse'
- { _uscrsTargetShardCount = Nothing
- , _uscrsStreamName = Nothing
- , _uscrsCurrentShardCount = Nothing
- , _uscrsResponseStatus = pResponseStatus_
- }
+ UpdateShardCountResponse'
+ { _uscrsTargetShardCount = Nothing
+ , _uscrsStreamName = Nothing
+ , _uscrsCurrentShardCount = Nothing
+ , _uscrsResponseStatus = pResponseStatus_
+ }
+
-- | The updated number of shards.
uscrsTargetShardCount :: Lens' UpdateShardCountResponse (Maybe Natural)
@@ -180,4 +200,4 @@ uscrsCurrentShardCount = lens _uscrsCurrentShardCount (\ s a -> s{_uscrsCurrentS
uscrsResponseStatus :: Lens' UpdateShardCountResponse Int
uscrsResponseStatus = lens _uscrsResponseStatus (\ s a -> s{_uscrsResponseStatus = a});
-instance NFData UpdateShardCountResponse
+instance NFData UpdateShardCountResponse where
diff --git a/gen/Network/AWS/Kinesis/Waiters.hs b/gen/Network/AWS/Kinesis/Waiters.hs
index b7cf8ee..0bdec28 100644
--- a/gen/Network/AWS/Kinesis/Waiters.hs
+++ b/gen/Network/AWS/Kinesis/Waiters.hs
@@ -7,41 +7,44 @@
-- |
-- Module : Network.AWS.Kinesis.Waiters
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
module Network.AWS.Kinesis.Waiters where
-import Network.AWS.Kinesis.DescribeStream
-import Network.AWS.Kinesis.DescribeStream
-import Network.AWS.Kinesis.Types
-import Network.AWS.Lens
-import Network.AWS.Prelude
-import Network.AWS.Waiter
+import Network.AWS.Kinesis.DescribeStream
+import Network.AWS.Kinesis.DescribeStream
+import Network.AWS.Kinesis.Types
+import Network.AWS.Lens
+import Network.AWS.Prelude
+import Network.AWS.Waiter
-- | Polls 'Network.AWS.Kinesis.DescribeStream' every 10 seconds until a successful state is reached. An error is returned after 18 failed checks.
streamExists :: Wait DescribeStream
streamExists =
- Wait
- { _waitName = "StreamExists"
- , _waitAttempts = 18
- , _waitDelay = 10
- , _waitAcceptors = [ matchAll
- "ACTIVE"
- AcceptSuccess
- (dsrsStreamDescription .
- sdStreamStatus . to toTextCI)]
- }
+ Wait
+ { _waitName = "StreamExists"
+ , _waitAttempts = 18
+ , _waitDelay = 10
+ , _waitAcceptors =
+ [ matchAll
+ "ACTIVE"
+ AcceptSuccess
+ (dsrsStreamDescription . sdStreamStatus . to toTextCI)
+ ]
+ }
+
-- | Polls 'Network.AWS.Kinesis.DescribeStream' every 10 seconds until a successful state is reached. An error is returned after 18 failed checks.
streamNotExists :: Wait DescribeStream
streamNotExists =
- Wait
- { _waitName = "StreamNotExists"
- , _waitAttempts = 18
- , _waitDelay = 10
- , _waitAcceptors = [matchError "ResourceNotFoundException" AcceptSuccess]
- }
+ Wait
+ { _waitName = "StreamNotExists"
+ , _waitAttempts = 18
+ , _waitDelay = 10
+ , _waitAcceptors = [matchError "ResourceNotFoundException" AcceptSuccess]
+ }
+
diff --git a/test/Main.hs b/test/Main.hs
index 6782551..1554cb7 100644
--- a/test/Main.hs
+++ b/test/Main.hs
@@ -2,9 +2,9 @@
-- |
-- Module : Main
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
diff --git a/test/Test/AWS/Gen/Kinesis.hs b/test/Test/AWS/Gen/Kinesis.hs
index 656932e..a45adaa 100644
--- a/test/Test/AWS/Gen/Kinesis.hs
+++ b/test/Test/AWS/Gen/Kinesis.hs
@@ -5,20 +5,20 @@
-- |
-- Module : Test.AWS.Gen.Kinesis
--- Copyright : (c) 2013-2016 Brendan Hay
+-- Copyright : (c) 2013-2017 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
--- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
+-- Maintainer : Brendan Hay <brendan.g.hay+amazonka@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
module Test.AWS.Gen.Kinesis where
import Data.Proxy
+import Network.AWS.Kinesis
import Test.AWS.Fixture
+import Test.AWS.Kinesis.Internal
import Test.AWS.Prelude
import Test.Tasty
-import Network.AWS.Kinesis
-import Test.AWS.Kinesis.Internal
-- Auto-generated: the actual test selection needs to be manually placed into
-- the top-level so that real test data can be incrementally added.
@@ -43,6 +43,9 @@ import Test.AWS.Kinesis.Internal
-- , requestGetRecords $
-- getRecords
--
+-- , requestStopStreamEncryption $
+-- stopStreamEncryption
+--
-- , requestEnableEnhancedMonitoring $
-- enableEnhancedMonitoring
--
@@ -76,6 +79,9 @@ import Test.AWS.Kinesis.Internal
-- , requestCreateStream $
-- createStream
--
+-- , requestStartStreamEncryption $
+-- startStreamEncryption
+--
-- , requestSplitShard $
-- splitShard
--
@@ -103,6 +109,9 @@ import Test.AWS.Kinesis.Internal
-- , responseGetRecords $
-- getRecordsResponse
--
+-- , responseStopStreamEncryption $
+-- stopStreamEncryptionResponse
+--
-- , responseEnableEnhancedMonitoring $
-- enhancedMonitoringOutput
--
@@ -136,6 +145,9 @@ import Test.AWS.Kinesis.Internal
-- , responseCreateStream $
-- createStreamResponse
--
+-- , responseStartStreamEncryption $
+-- startStreamEncryptionResponse
+--
-- , responseSplitShard $
-- splitShardResponse
--
@@ -175,6 +187,11 @@ requestGetRecords = req
"GetRecords"
"fixture/GetRecords.yaml"
+requestStopStreamEncryption :: StopStreamEncryption -> TestTree
+requestStopStreamEncryption = req
+ "StopStreamEncryption"
+ "fixture/StopStreamEncryption.yaml"
+
requestEnableEnhancedMonitoring :: EnableEnhancedMonitoring -> TestTree
requestEnableEnhancedMonitoring = req
"EnableEnhancedMonitoring"
@@ -230,6 +247,11 @@ requestCreateStream = req
"CreateStream"
"fixture/CreateStream.yaml"
+requestStartStreamEncryption :: StartStreamEncryption -> TestTree
+requestStartStreamEncryption = req
+ "StartStreamEncryption"
+ "fixture/StartStreamEncryption.yaml"
+
requestSplitShard :: SplitShard -> TestTree
requestSplitShard = req
"SplitShard"
@@ -282,6 +304,13 @@ responseGetRecords = res
kinesis
(Proxy :: Proxy GetRecords)
+responseStopStreamEncryption :: StopStreamEncryptionResponse -> TestTree
+responseStopStreamEncryption = res
+ "StopStreamEncryptionResponse"
+ "fixture/StopStreamEncryptionResponse.proto"
+ kinesis
+ (Proxy :: Proxy StopStreamEncryption)
+
responseEnableEnhancedMonitoring :: EnhancedMonitoringOutput -> TestTree
responseEnableEnhancedMonitoring = res
"EnableEnhancedMonitoringResponse"
@@ -359,6 +388,13 @@ responseCreateStream = res
kinesis
(Proxy :: Proxy CreateStream)
+responseStartStreamEncryption :: StartStreamEncryptionResponse -> TestTree
+responseStartStreamEncryption = res
+ "StartStreamEncryptionResponse"
+ "fixture/StartStreamEncryptionResponse.proto"
+ kinesis
+ (Proxy :: Proxy StartStreamEncryption)
+
responseSplitShard :: SplitShardResponse -> TestTree
responseSplitShard = res
"SplitShardResponse"