amazonka-kinesis 1.2.0.2 → 1.3.0

raw patch · 12 files changed

+114/−115 lines, 12 filesdep ~amazonka-coredep ~amazonka-kinesisdep ~amazonka-testPVP ok

version bump matches the API change (PVP)

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

API changes (from Hackage documentation)

Files

• README.md +1/−1
• amazonka-kinesis.cabal +5/−5
• gen/Network/AWS/Kinesis.hs +6/−6
• gen/Network/AWS/Kinesis/DescribeStream.hs +10/−11
• gen/Network/AWS/Kinesis/GetRecords.hs +23/−23
• gen/Network/AWS/Kinesis/GetShardIterator.hs +9/−9
• gen/Network/AWS/Kinesis/ListStreams.hs +10/−10
• gen/Network/AWS/Kinesis/ListTagsForStream.hs +10/−10
• gen/Network/AWS/Kinesis/PutRecord.hs +8/−8
• gen/Network/AWS/Kinesis/PutRecords.hs +8/−8
• gen/Network/AWS/Kinesis/Types.hs +6/−6
• test/Test/AWS/Gen/Kinesis.hs +18/−18

@@ -8,7 +8,7 @@  ## Version -`1.2.0.2`+`1.3.0`   ## Description

@@ -1,5 +1,5 @@ name:                  amazonka-kinesis-version:               1.2.0.2+version:               1.3.0 synopsis:              Amazon Kinesis SDK. homepage:              https://github.com/brendanhay/amazonka bug-reports:           https://github.com/brendanhay/amazonka/issues@@ -65,7 +65,7 @@         , Network.AWS.Kinesis.Types.Sum      build-depends:-          amazonka-core == 1.2.0.*+          amazonka-core == 1.3.0.*         , base          >= 4.7     && < 5  test-suite amazonka-kinesis-test@@ -85,9 +85,9 @@         , Test.AWS.Kinesis.Internal      build-depends:-          amazonka-core == 1.2.0.*-        , amazonka-test == 1.2.0.*-        , amazonka-kinesis == 1.2.0.*+          amazonka-core == 1.3.0.*+        , amazonka-test == 1.3.0.*+        , amazonka-kinesis == 1.3.0.*         , base         , bytestring         , lens

@@ -37,12 +37,12 @@     -- ** ResourceNotFoundException     , _ResourceNotFoundException -    -- ** ResourceInUseException-    , _ResourceInUseException-     -- ** LimitExceededException     , _LimitExceededException +    -- ** ResourceInUseException+    , _ResourceInUseException+     -- * Waiters     -- $waiters @@ -58,11 +58,11 @@     -- ** MergeShards     , module Network.AWS.Kinesis.MergeShards -    -- ** GetRecords-    , module Network.AWS.Kinesis.GetRecords-     -- ** GetShardIterator     , module Network.AWS.Kinesis.GetShardIterator++    -- ** GetRecords+    , module Network.AWS.Kinesis.GetRecords      -- ** ListTagsForStream     , module Network.AWS.Kinesis.ListTagsForStream

@@ -59,7 +59,7 @@     , describeStreamResponse     , DescribeStreamResponse     -- * Response Lenses-    , dsrsStatus+    , dsrsResponseStatus     , dsrsStreamDescription     ) where @@ -113,12 +113,11 @@ instance AWSPager DescribeStream where         page rq rs           | stop-              (rs ^. dsrsStreamDescription . sdHasMoreShards)-            = Nothing-          | isNothing               (rs ^?                  dsrsStreamDescription . sdShards . _last . sShardId)             = Nothing+          | stop (rs ^. dsrsStreamDescription . sdShards) =+            Nothing           | otherwise =             Just $ rq &               dExclusiveStartShardId .~@@ -162,7 +161,7 @@ -- -- /See:/ 'describeStreamResponse' smart constructor. data DescribeStreamResponse = DescribeStreamResponse'-    { _dsrsStatus            :: !Int+    { _dsrsResponseStatus    :: !Int     , _dsrsStreamDescription :: !StreamDescription     } deriving (Eq,Read,Show,Data,Typeable,Generic) @@ -170,22 +169,22 @@ -- -- Use one of the following lenses to modify other fields as desired: ----- * 'dsrsStatus'+-- * 'dsrsResponseStatus' -- -- * 'dsrsStreamDescription' describeStreamResponse-    :: Int -- ^ 'dsrsStatus'+    :: Int -- ^ 'dsrsResponseStatus'     -> StreamDescription -- ^ 'dsrsStreamDescription'     -> DescribeStreamResponse-describeStreamResponse pStatus_ pStreamDescription_ =+describeStreamResponse pResponseStatus_ pStreamDescription_ =     DescribeStreamResponse'-    { _dsrsStatus = pStatus_+    { _dsrsResponseStatus = pResponseStatus_     , _dsrsStreamDescription = pStreamDescription_     }  -- | The response status code.-dsrsStatus :: Lens' DescribeStreamResponse Int-dsrsStatus = lens _dsrsStatus (\ s a -> s{_dsrsStatus = a});+dsrsResponseStatus :: Lens' DescribeStreamResponse Int+dsrsResponseStatus = lens _dsrsResponseStatus (\ s a -> s{_dsrsResponseStatus = a});  -- | The current status of the stream, the stream ARN, an array of shard -- objects that comprise the stream, and states whether there are more

@@ -81,9 +81,9 @@     , getRecordsResponse     , GetRecordsResponse     -- * Response Lenses-    , grrsMillisBehindLatest     , grrsNextShardIterator-    , grrsStatus+    , grrsMillisBehindLatest+    , grrsResponseStatus     , grrsRecords     ) where @@ -136,8 +136,8 @@           = receiveJSON               (\ s h x ->                  GetRecordsResponse' <$>-                   (x .?> "MillisBehindLatest") <*>-                     (x .?> "NextShardIterator")+                   (x .?> "NextShardIterator") <*>+                     (x .?> "MillisBehindLatest")                      <*> (pure (fromEnum s))                      <*> (x .?> "Records" .!@ mempty)) @@ -167,9 +167,9 @@ -- -- /See:/ 'getRecordsResponse' smart constructor. data GetRecordsResponse = GetRecordsResponse'-    { _grrsMillisBehindLatest :: !(Maybe Nat)-    , _grrsNextShardIterator  :: !(Maybe Text)-    , _grrsStatus             :: !Int+    { _grrsNextShardIterator  :: !(Maybe Text)+    , _grrsMillisBehindLatest :: !(Maybe Nat)+    , _grrsResponseStatus     :: !Int     , _grrsRecords            :: ![Record]     } deriving (Eq,Read,Show,Data,Typeable,Generic) @@ -177,24 +177,30 @@ -- -- Use one of the following lenses to modify other fields as desired: ----- * 'grrsMillisBehindLatest'--- -- * 'grrsNextShardIterator' ----- * 'grrsStatus'+-- * 'grrsMillisBehindLatest' --+-- * 'grrsResponseStatus'+-- -- * 'grrsRecords' getRecordsResponse-    :: Int -- ^ 'grrsStatus'+    :: Int -- ^ 'grrsResponseStatus'     -> GetRecordsResponse-getRecordsResponse pStatus_ =+getRecordsResponse pResponseStatus_ =     GetRecordsResponse'-    { _grrsMillisBehindLatest = Nothing-    , _grrsNextShardIterator = Nothing-    , _grrsStatus = pStatus_+    { _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)+grrsNextShardIterator = lens _grrsNextShardIterator (\ s a -> s{_grrsNextShardIterator = a});+ -- | The number of milliseconds the GetRecords response is from the tip of -- the stream, indicating how far behind current time the consumer is. A -- value of zero indicates record processing is caught up, and there are no@@ -202,15 +208,9 @@ grrsMillisBehindLatest :: Lens' GetRecordsResponse (Maybe Natural) grrsMillisBehindLatest = lens _grrsMillisBehindLatest (\ s a -> s{_grrsMillisBehindLatest = a}) . mapping _Nat; --- | 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)-grrsNextShardIterator = lens _grrsNextShardIterator (\ s a -> s{_grrsNextShardIterator = a});- -- | The response status code.-grrsStatus :: Lens' GetRecordsResponse Int-grrsStatus = lens _grrsStatus (\ s a -> s{_grrsStatus = a});+grrsResponseStatus :: Lens' GetRecordsResponse Int+grrsResponseStatus = lens _grrsResponseStatus (\ s a -> s{_grrsResponseStatus = a});  -- | The data records retrieved from the shard. grrsRecords :: Lens' GetRecordsResponse [Record]

@@ -77,7 +77,7 @@     , GetShardIteratorResponse     -- * Response Lenses     , gsirsShardIterator-    , gsirsStatus+    , gsirsResponseStatus     ) where  import           Network.AWS.Kinesis.Types@@ -187,8 +187,8 @@ -- -- /See:/ 'getShardIteratorResponse' smart constructor. data GetShardIteratorResponse = GetShardIteratorResponse'-    { _gsirsShardIterator :: !(Maybe Text)-    , _gsirsStatus        :: !Int+    { _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.@@ -197,14 +197,14 @@ -- -- * 'gsirsShardIterator' ----- * 'gsirsStatus'+-- * 'gsirsResponseStatus' getShardIteratorResponse-    :: Int -- ^ 'gsirsStatus'+    :: Int -- ^ 'gsirsResponseStatus'     -> GetShardIteratorResponse-getShardIteratorResponse pStatus_ =+getShardIteratorResponse pResponseStatus_ =     GetShardIteratorResponse'     { _gsirsShardIterator = Nothing-    , _gsirsStatus = pStatus_+    , _gsirsResponseStatus = pResponseStatus_     }  -- | The position in the shard from which to start reading data records@@ -214,5 +214,5 @@ gsirsShardIterator = lens _gsirsShardIterator (\ s a -> s{_gsirsShardIterator = a});  -- | The response status code.-gsirsStatus :: Lens' GetShardIteratorResponse Int-gsirsStatus = lens _gsirsStatus (\ s a -> s{_gsirsStatus = a});+gsirsResponseStatus :: Lens' GetShardIteratorResponse Int+gsirsResponseStatus = lens _gsirsResponseStatus (\ s a -> s{_gsirsResponseStatus = a});

@@ -52,7 +52,7 @@     , listStreamsResponse     , ListStreamsResponse     -- * Response Lenses-    , lsrsStatus+    , lsrsResponseStatus     , lsrsStreamNames     , lsrsHasMoreStreams     ) where@@ -97,8 +97,8 @@  instance AWSPager ListStreams where         page rq rs-          | stop (rs ^. lsrsHasMoreStreams) = Nothing-          | isNothing (rs ^? lsrsStreamNames . _last) = Nothing+          | stop (rs ^? lsrsStreamNames . _last) = Nothing+          | stop (rs ^. lsrsStreamNames) = Nothing           | otherwise =             Just $ rq &               lsExclusiveStartStreamName .~@@ -142,7 +142,7 @@ -- -- /See:/ 'listStreamsResponse' smart constructor. data ListStreamsResponse = ListStreamsResponse'-    { _lsrsStatus         :: !Int+    { _lsrsResponseStatus :: !Int     , _lsrsStreamNames    :: ![Text]     , _lsrsHasMoreStreams :: !Bool     } deriving (Eq,Read,Show,Data,Typeable,Generic)@@ -151,25 +151,25 @@ -- -- Use one of the following lenses to modify other fields as desired: ----- * 'lsrsStatus'+-- * 'lsrsResponseStatus' -- -- * 'lsrsStreamNames' -- -- * 'lsrsHasMoreStreams' listStreamsResponse-    :: Int -- ^ 'lsrsStatus'+    :: Int -- ^ 'lsrsResponseStatus'     -> Bool -- ^ 'lsrsHasMoreStreams'     -> ListStreamsResponse-listStreamsResponse pStatus_ pHasMoreStreams_ =+listStreamsResponse pResponseStatus_ pHasMoreStreams_ =     ListStreamsResponse'-    { _lsrsStatus = pStatus_+    { _lsrsResponseStatus = pResponseStatus_     , _lsrsStreamNames = mempty     , _lsrsHasMoreStreams = pHasMoreStreams_     }  -- | The response status code.-lsrsStatus :: Lens' ListStreamsResponse Int-lsrsStatus = lens _lsrsStatus (\ s a -> s{_lsrsStatus = a});+lsrsResponseStatus :: Lens' ListStreamsResponse Int+lsrsResponseStatus = lens _lsrsResponseStatus (\ s a -> s{_lsrsResponseStatus = a});  -- | The names of the streams that are associated with the AWS account making -- the 'ListStreams' request.

@@ -35,7 +35,7 @@     , listTagsForStreamResponse     , ListTagsForStreamResponse     -- * Response Lenses-    , ltfsrsStatus+    , ltfsrsResponseStatus     , ltfsrsTags     , ltfsrsHasMoreTags     ) where@@ -129,34 +129,34 @@ -- -- /See:/ 'listTagsForStreamResponse' smart constructor. data ListTagsForStreamResponse = ListTagsForStreamResponse'-    { _ltfsrsStatus      :: !Int-    , _ltfsrsTags        :: ![Tag]-    , _ltfsrsHasMoreTags :: !Bool+    { _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. -- -- Use one of the following lenses to modify other fields as desired: ----- * 'ltfsrsStatus'+-- * 'ltfsrsResponseStatus' -- -- * 'ltfsrsTags' -- -- * 'ltfsrsHasMoreTags' listTagsForStreamResponse-    :: Int -- ^ 'ltfsrsStatus'+    :: Int -- ^ 'ltfsrsResponseStatus'     -> Bool -- ^ 'ltfsrsHasMoreTags'     -> ListTagsForStreamResponse-listTagsForStreamResponse pStatus_ pHasMoreTags_ =+listTagsForStreamResponse pResponseStatus_ pHasMoreTags_ =     ListTagsForStreamResponse'-    { _ltfsrsStatus = pStatus_+    { _ltfsrsResponseStatus = pResponseStatus_     , _ltfsrsTags = mempty     , _ltfsrsHasMoreTags = pHasMoreTags_     }  -- | The response status code.-ltfsrsStatus :: Lens' ListTagsForStreamResponse Int-ltfsrsStatus = lens _ltfsrsStatus (\ s a -> s{_ltfsrsStatus = a});+ltfsrsResponseStatus :: Lens' ListTagsForStreamResponse Int+ltfsrsResponseStatus = lens _ltfsrsResponseStatus (\ s a -> s{_ltfsrsResponseStatus = a});  -- | A list of tags associated with 'StreamName', starting with the first tag -- after 'ExclusiveStartTagKey' and up to the specified 'Limit'.

@@ -78,7 +78,7 @@     , putRecordResponse     , PutRecordResponse     -- * Response Lenses-    , prrsStatus+    , prrsResponseStatus     , prrsShardId     , prrsSequenceNumber     ) where@@ -209,7 +209,7 @@ -- -- /See:/ 'putRecordResponse' smart constructor. data PutRecordResponse = PutRecordResponse'-    { _prrsStatus         :: !Int+    { _prrsResponseStatus :: !Int     , _prrsShardId        :: !Text     , _prrsSequenceNumber :: !Text     } deriving (Eq,Read,Show,Data,Typeable,Generic)@@ -218,26 +218,26 @@ -- -- Use one of the following lenses to modify other fields as desired: ----- * 'prrsStatus'+-- * 'prrsResponseStatus' -- -- * 'prrsShardId' -- -- * 'prrsSequenceNumber' putRecordResponse-    :: Int -- ^ 'prrsStatus'+    :: Int -- ^ 'prrsResponseStatus'     -> Text -- ^ 'prrsShardId'     -> Text -- ^ 'prrsSequenceNumber'     -> PutRecordResponse-putRecordResponse pStatus_ pShardId_ pSequenceNumber_ =+putRecordResponse pResponseStatus_ pShardId_ pSequenceNumber_ =     PutRecordResponse'-    { _prrsStatus = pStatus_+    { _prrsResponseStatus = pResponseStatus_     , _prrsShardId = pShardId_     , _prrsSequenceNumber = pSequenceNumber_     }  -- | The response status code.-prrsStatus :: Lens' PutRecordResponse Int-prrsStatus = lens _prrsStatus (\ s a -> s{_prrsStatus = a});+prrsResponseStatus :: Lens' PutRecordResponse Int+prrsResponseStatus = lens _prrsResponseStatus (\ s a -> s{_prrsResponseStatus = a});  -- | The shard ID of the shard where the data record was placed. prrsShardId :: Lens' PutRecordResponse Text

@@ -93,7 +93,7 @@     , PutRecordsResponse     -- * Response Lenses     , prsFailedRecordCount-    , prsStatus+    , prsResponseStatus     , prsRecords     ) where @@ -173,7 +173,7 @@ -- /See:/ 'putRecordsResponse' smart constructor. data PutRecordsResponse = PutRecordsResponse'     { _prsFailedRecordCount :: !(Maybe Nat)-    , _prsStatus            :: !Int+    , _prsResponseStatus    :: !Int     , _prsRecords           :: !(List1 PutRecordsResultEntry)     } deriving (Eq,Read,Show,Data,Typeable,Generic) @@ -183,17 +183,17 @@ -- -- * 'prsFailedRecordCount' ----- * 'prsStatus'+-- * 'prsResponseStatus' -- -- * 'prsRecords' putRecordsResponse-    :: Int -- ^ 'prsStatus'+    :: Int -- ^ 'prsResponseStatus'     -> NonEmpty PutRecordsResultEntry -- ^ 'prsRecords'     -> PutRecordsResponse-putRecordsResponse pStatus_ pRecords_ =+putRecordsResponse pResponseStatus_ pRecords_ =     PutRecordsResponse'     { _prsFailedRecordCount = Nothing-    , _prsStatus = pStatus_+    , _prsResponseStatus = pResponseStatus_     , _prsRecords = _List1 # pRecords_     } @@ -203,8 +203,8 @@ prsFailedRecordCount = lens _prsFailedRecordCount (\ s a -> s{_prsFailedRecordCount = a}) . mapping _Nat;  -- | The response status code.-prsStatus :: Lens' PutRecordsResponse Int-prsStatus = lens _prsStatus (\ s a -> s{_prsStatus = a});+prsResponseStatus :: Lens' PutRecordsResponse Int+prsResponseStatus = lens _prsResponseStatus (\ s a -> s{_prsResponseStatus = a});  -- | An array of successfully and unsuccessfully processed record results, -- correlated with the request by natural ordering. A record that is

@@ -20,8 +20,8 @@     , _InvalidArgumentException     , _ProvisionedThroughputExceededException     , _ResourceNotFoundException-    , _ResourceInUseException     , _LimitExceededException+    , _ResourceInUseException      -- * ShardIteratorType     , ShardIteratorType (..)@@ -148,12 +148,12 @@ _ResourceNotFoundException =     _ServiceError . hasCode "ResourceNotFoundException" --- | The resource is not available for this operation. For example, you--- attempted to split a shard but the stream is not in the 'ACTIVE' state.-_ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError-_ResourceInUseException = _ServiceError . hasCode "ResourceInUseException"- -- | 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"++-- | The resource is not available for this operation. For example, you+-- attempted to split a shard but the stream is not in the 'ACTIVE' state.+_ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError+_ResourceInUseException = _ServiceError . hasCode "ResourceInUseException"

@@ -34,12 +34,12 @@ --         , testMergeShards $ --             mergeShards -----         , testGetRecords $---             getRecords--- --         , testGetShardIterator $ --             getShardIterator --+--         , testGetRecords $+--             getRecords+-- --         , testListTagsForStream $ --             listTagsForStream --@@ -76,12 +76,12 @@ --         , testMergeShardsResponse $ --             mergeShardsResponse -----         , testGetRecordsResponse $---             getRecordsResponse--- --         , testGetShardIteratorResponse $ --             getShardIteratorResponse --+--         , testGetRecordsResponse $+--             getRecordsResponse+-- --         , testListTagsForStreamResponse $ --             listTagsForStreamResponse --@@ -124,16 +124,16 @@     "MergeShards"     "fixture/MergeShards.yaml" -testGetRecords :: GetRecords -> TestTree-testGetRecords = req-    "GetRecords"-    "fixture/GetRecords.yaml"- testGetShardIterator :: GetShardIterator -> TestTree testGetShardIterator = req     "GetShardIterator"     "fixture/GetShardIterator.yaml" +testGetRecords :: GetRecords -> TestTree+testGetRecords = req+    "GetRecords"+    "fixture/GetRecords.yaml"+ testListTagsForStream :: ListTagsForStream -> TestTree testListTagsForStream = req     "ListTagsForStream"@@ -195,19 +195,19 @@     kinesis     (Proxy :: Proxy MergeShards) -testGetRecordsResponse :: GetRecordsResponse -> TestTree-testGetRecordsResponse = res-    "GetRecordsResponse"-    "fixture/GetRecordsResponse.proto"-    kinesis-    (Proxy :: Proxy GetRecords)- testGetShardIteratorResponse :: GetShardIteratorResponse -> TestTree testGetShardIteratorResponse = res     "GetShardIteratorResponse"     "fixture/GetShardIteratorResponse.proto"     kinesis     (Proxy :: Proxy GetShardIterator)++testGetRecordsResponse :: GetRecordsResponse -> TestTree+testGetRecordsResponse = res+    "GetRecordsResponse"+    "fixture/GetRecordsResponse.proto"+    kinesis+    (Proxy :: Proxy GetRecords)  testListTagsForStreamResponse :: ListTagsForStreamResponse -> TestTree testListTagsForStreamResponse = res