Permalink
Browse files

Regenerating Kineses from latest service definition

  • Loading branch information...
brendanhay committed May 4, 2016
1 parent a29dbb5 commit e2a1c4eb6ca503b4f39f3e40ea4905d981a063e1
Showing with 690 additions and 157 deletions.
  1. +3 −3 amazonka-kinesis/README.md
  2. +5 −3 amazonka-kinesis/amazonka-kinesis.cabal
  3. 0 amazonka-kinesis/fixture/DisableEnhancedMonitoring.yaml
  4. 0 amazonka-kinesis/fixture/DisableEnhancedMonitoringResponse.proto
  5. 0 amazonka-kinesis/fixture/EnableEnhancedMonitoring.yaml
  6. 0 amazonka-kinesis/fixture/EnableEnhancedMonitoringResponse.proto
  7. +27 −3 amazonka-kinesis/gen/Network/AWS/Kinesis.hs
  8. +9 −8 amazonka-kinesis/gen/Network/AWS/Kinesis/CreateStream.hs
  9. +3 −3 amazonka-kinesis/gen/Network/AWS/Kinesis/DecreaseStreamRetentionPeriod.hs
  10. +4 −4 amazonka-kinesis/gen/Network/AWS/Kinesis/DeleteStream.hs
  11. +7 −4 amazonka-kinesis/gen/Network/AWS/Kinesis/DescribeStream.hs
  12. +128 −0 amazonka-kinesis/gen/Network/AWS/Kinesis/DisableEnhancedMonitoring.hs
  13. +128 −0 amazonka-kinesis/gen/Network/AWS/Kinesis/EnableEnhancedMonitoring.hs
  14. +25 −21 amazonka-kinesis/gen/Network/AWS/Kinesis/GetRecords.hs
  15. +56 −33 amazonka-kinesis/gen/Network/AWS/Kinesis/GetShardIterator.hs
  16. +6 −5 amazonka-kinesis/gen/Network/AWS/Kinesis/IncreaseStreamRetentionPeriod.hs
  17. +1 −1 amazonka-kinesis/gen/Network/AWS/Kinesis/ListStreams.hs
  18. +10 −10 amazonka-kinesis/gen/Network/AWS/Kinesis/MergeShards.hs
  19. +16 −17 amazonka-kinesis/gen/Network/AWS/Kinesis/PutRecord.hs
  20. +9 −11 amazonka-kinesis/gen/Network/AWS/Kinesis/PutRecords.hs
  21. +3 −1 amazonka-kinesis/gen/Network/AWS/Kinesis/RemoveTagsFromStream.hs
  22. +17 −15 amazonka-kinesis/gen/Network/AWS/Kinesis/SplitShard.hs
  23. +23 −3 amazonka-kinesis/gen/Network/AWS/Kinesis/Types.hs
  24. +123 −11 amazonka-kinesis/gen/Network/AWS/Kinesis/Types/Product.hs
  25. +51 −1 amazonka-kinesis/gen/Network/AWS/Kinesis/Types/Sum.hs
  26. +36 −0 amazonka-kinesis/test/Test/AWS/Gen/Kinesis.hs
@@ -13,10 +13,10 @@
## Description
Amazon Kinesis Service API Reference
Amazon Kinesis Streams Service API Reference
Amazon Kinesis is a managed service that scales elastically for real
time processing of streaming big data.
Amazon Kinesis Streams is a managed service that scales elastically for
real time processing of streaming big data.
Documentation is available via [Hackage](http://hackage.haskell.org/package/amazonka-kinesis)
and the [AWS API Reference](https://aws.amazon.com/documentation/).
@@ -13,10 +13,10 @@ build-type: Simple
cabal-version: >= 1.10
extra-source-files: README.md fixture/*.yaml fixture/*.proto
description:
Amazon Kinesis Service API Reference
Amazon Kinesis Streams Service API Reference
Amazon Kinesis is a managed service that scales elastically for real
time processing of streaming big data.
Amazon Kinesis Streams is a managed service that scales elastically for
real time processing of streaming big data.
.
The types from this library are intended to be used with
<http://hackage.haskell.org/package/amazonka amazonka>, which provides
@@ -49,6 +49,8 @@ library
, Network.AWS.Kinesis.DecreaseStreamRetentionPeriod
, Network.AWS.Kinesis.DeleteStream
, Network.AWS.Kinesis.DescribeStream
, Network.AWS.Kinesis.DisableEnhancedMonitoring
, Network.AWS.Kinesis.EnableEnhancedMonitoring
, Network.AWS.Kinesis.GetRecords
, Network.AWS.Kinesis.GetShardIterator
, Network.AWS.Kinesis.IncreaseStreamRetentionPeriod
@@ -11,10 +11,10 @@
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
-- Amazon Kinesis Service API Reference
-- Amazon Kinesis Streams Service API Reference
--
-- Amazon Kinesis is a managed service that scales elastically for real
-- time processing of streaming big data.
-- Amazon Kinesis Streams is a managed service that scales elastically for
-- real time processing of streaming big data.
module Network.AWS.Kinesis
(
-- * Service Configuration
@@ -68,6 +68,12 @@ module Network.AWS.Kinesis
-- ** GetRecords
, module Network.AWS.Kinesis.GetRecords
-- ** EnableEnhancedMonitoring
, module Network.AWS.Kinesis.EnableEnhancedMonitoring
-- ** DisableEnhancedMonitoring
, module Network.AWS.Kinesis.DisableEnhancedMonitoring
-- ** ListTagsForStream
, module Network.AWS.Kinesis.ListTagsForStream
@@ -100,12 +106,27 @@ module Network.AWS.Kinesis
-- * Types
-- ** MetricsName
, MetricsName (..)
-- ** ShardIteratorType
, ShardIteratorType (..)
-- ** StreamStatus
, StreamStatus (..)
-- ** EnhancedMetrics
, EnhancedMetrics
, enhancedMetrics
, emShardLevelMetrics
-- ** EnhancedMonitoringOutput
, EnhancedMonitoringOutput
, enhancedMonitoringOutput
, emoDesiredShardLevelMetrics
, emoCurrentShardLevelMetrics
, emoStreamName
-- ** HashKeyRange
, HashKeyRange
, hashKeyRange
@@ -159,6 +180,7 @@ module Network.AWS.Kinesis
, sdShards
, sdHasMoreShards
, sdRetentionPeriodHours
, sdEnhancedMonitoring
-- ** Tag
, Tag
@@ -172,6 +194,8 @@ import Network.AWS.Kinesis.CreateStream
import Network.AWS.Kinesis.DecreaseStreamRetentionPeriod
import Network.AWS.Kinesis.DeleteStream
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
@@ -18,11 +18,11 @@
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
-- Creates a Amazon Kinesis stream. A stream captures and transports data
-- Creates an Amazon Kinesis stream. A stream captures and transports data
-- records that are continuously emitted from different data sources or
-- /producers/. Scale-out within an Amazon Kinesis stream is explicitly
-- supported by means of shards, which are uniquely identified groups of
-- data records in an Amazon Kinesis stream.
-- /producers/. Scale-out within a stream is explicitly supported by means
-- of shards, which are uniquely identified groups of data records in a
-- stream.
--
-- You specify and control the number of shards that a stream is composed
-- of. Each shard can support reads up to 5 transactions per second, up to
@@ -52,8 +52,9 @@
-- - Create more shards than are authorized for your account.
--
-- For the default shard limit for an AWS account, see
-- <http://docs.aws.amazon.com/kinesis/latest/dev/service-sizes-and-limits.html Amazon Kinesis Limits>.
-- If you need to increase this limit,
-- <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
-- this limit,
-- <http://docs.aws.amazon.com/general/latest/gr/aws_service_limits.html contact AWS Support>.
--
-- You can use 'DescribeStream' to check the stream status, which is
@@ -109,8 +110,8 @@ createStream pStreamName_ 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.
-- 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
csStreamName = lens _csStreamName (\ s a -> s{_csStreamName = a});
@@ -18,9 +18,9 @@
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
-- Decreases the stream\'s retention period, which is the length of time
-- data records are accessible after they are added to the stream. The
-- minimum value of a streams retention period is 24 hours.
-- Decreases the Amazon Kinesis stream\'s retention period, which is the
-- length of time data records are accessible after they are added to the
-- stream. The minimum value of a stream\'s retention period is 24 hours.
--
-- This operation may result in lost data. For example, if the stream\'s
-- retention period is 48 hours and is decreased to 24 hours, any data
@@ -18,10 +18,10 @@
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
-- Deletes a stream and all its shards and data. You must shut down any
-- applications that are operating on the stream before you delete the
-- stream. If an application attempts to operate on a deleted stream, it
-- will receive the exception 'ResourceNotFoundException'.
-- Deletes an Amazon Kinesis stream and all its shards and data. You must
-- shut down any applications that are operating on the stream before you
-- delete the stream. If an application attempts to operate on a deleted
-- stream, it will receive the exception 'ResourceNotFoundException'.
--
-- If the stream is in the 'ACTIVE' state, you can delete it. After a
-- 'DeleteStream' request, the specified stream is in the 'DELETING' state
@@ -18,16 +18,15 @@
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
-- Describes the specified stream.
-- Describes the specified Amazon Kinesis stream.
--
-- The information about the stream includes its current status, its Amazon
-- Resource Name (ARN), and an array of shard objects. For each shard
-- object, there is information about the hash key and sequence number
-- ranges that the shard spans, and the IDs of any earlier shards that
-- played in a role in creating the shard. A sequence number is the
-- identifier associated with every record ingested in the Amazon Kinesis
-- stream. The sequence number is assigned when a record is put into the
-- stream.
-- identifier associated with every record ingested in the stream. The
-- sequence number is assigned when a record is put into the stream.
--
-- You can limit the number of returned shards using the 'Limit' parameter.
-- The number of shards in a stream may be too large to return from a
@@ -40,6 +39,10 @@
-- returned. Specify this ID in the 'ExclusiveStartShardId' parameter in a
-- subsequent request to 'DescribeStream'.
--
-- There are no guarantees about the chronological order shards returned in
-- 'DescribeStream' results. If you want to process shards in chronological
-- order, use 'ParentShardId' to track lineage to the oldest shard.
--
-- < DescribeStream> has a limit of 10 transactions per second per account.
--
-- This operation returns paginated results.
@@ -0,0 +1,128 @@
{-# 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.DisableEnhancedMonitoring
-- Copyright : (c) 2013-2016 Brendan Hay
-- License : Mozilla Public License, v. 2.0.
-- Maintainer : Brendan Hay <brendan.g.hay@gmail.com>
-- Stability : auto-generated
-- Portability : non-portable (GHC extensions)
--
-- Disables enhanced monitoring.
module Network.AWS.Kinesis.DisableEnhancedMonitoring
(
-- * Creating a Request
disableEnhancedMonitoring
, DisableEnhancedMonitoring
-- * Request Lenses
, demStreamName
, demShardLevelMetrics
-- * Destructuring the Response
, enhancedMonitoringOutput
, EnhancedMonitoringOutput
-- * Response Lenses
, emoDesiredShardLevelMetrics
, emoCurrentShardLevelMetrics
, 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
-- | Represents the input for < DisableEnhancedMonitoring>.
--
-- /See:/ 'disableEnhancedMonitoring' smart constructor.
data DisableEnhancedMonitoring = DisableEnhancedMonitoring'
{ _demStreamName :: !Text
, _demShardLevelMetrics :: !(List1 MetricsName)
} deriving (Eq,Read,Show,Data,Typeable,Generic)
-- | Creates a value of 'DisableEnhancedMonitoring' with the minimum fields required to make a request.
--
-- Use one of the following lenses to modify other fields as desired:
--
-- * 'demStreamName'
--
-- * 'demShardLevelMetrics'
disableEnhancedMonitoring
:: Text -- ^ 'demStreamName'
-> NonEmpty MetricsName -- ^ 'demShardLevelMetrics'
-> DisableEnhancedMonitoring
disableEnhancedMonitoring pStreamName_ pShardLevelMetrics_ =
DisableEnhancedMonitoring'
{ _demStreamName = pStreamName_
, _demShardLevelMetrics = _List1 # pShardLevelMetrics_
}
-- | The name of the Amazon Kinesis stream for which to disable enhanced
-- monitoring.
demStreamName :: Lens' DisableEnhancedMonitoring Text
demStreamName = lens _demStreamName (\ s a -> s{_demStreamName = a});
-- | List of shard-level metrics to disable.
--
-- The following are the valid shard-level metrics. The value \"'ALL'\"
-- disables every metric.
--
-- - 'IncomingBytes'
-- - 'IncomingRecords'
-- - 'OutgoingBytes'
-- - 'OutgoingRecords'
-- - 'WriteProvisionedThroughputExceeded'
-- - 'ReadProvisionedThroughputExceeded'
-- - 'IteratorAgeMilliseconds'
-- - 'ALL'
--
-- For more information, see
-- <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/.
demShardLevelMetrics :: Lens' DisableEnhancedMonitoring (NonEmpty MetricsName)
demShardLevelMetrics = lens _demShardLevelMetrics (\ s a -> s{_demShardLevelMetrics = a}) . _List1;
instance AWSRequest DisableEnhancedMonitoring where
type Rs DisableEnhancedMonitoring =
EnhancedMonitoringOutput
request = postJSON kinesis
response = receiveJSON (\ s h x -> eitherParseJSON x)
instance Hashable DisableEnhancedMonitoring
instance NFData DisableEnhancedMonitoring
instance ToHeaders DisableEnhancedMonitoring where
toHeaders
= const
(mconcat
["X-Amz-Target" =#
("Kinesis_20131202.DisableEnhancedMonitoring" ::
ByteString),
"Content-Type" =#
("application/x-amz-json-1.1" :: ByteString)])
instance ToJSON DisableEnhancedMonitoring where
toJSON DisableEnhancedMonitoring'{..}
= object
(catMaybes
[Just ("StreamName" .= _demStreamName),
Just ("ShardLevelMetrics" .= _demShardLevelMetrics)])
instance ToPath DisableEnhancedMonitoring where
toPath = const "/"
instance ToQuery DisableEnhancedMonitoring where
toQuery = const mempty
Oops, something went wrong.

0 comments on commit e2a1c4e

Please sign in to comment.