{-# LANGUAGE OverloadedStrings #-} -- Derived from AWS service descriptions, licensed under Apache 2.0. -- | -- Module : Network.AWS.Kinesis.Types -- Copyright : (c) 2013-2018 Brendan Hay -- License : Mozilla Public License, v. 2.0. -- Maintainer : Brendan Hay -- Stability : auto-generated -- Portability : non-portable (GHC extensions) -- module Network.AWS.Kinesis.Types ( -- * Service Configuration kinesis -- * Errors , _KMSInvalidStateException , _KMSThrottlingException , _ExpiredIteratorException , _InvalidArgumentException , _KMSOptInRequired , _ProvisionedThroughputExceededException , _KMSNotFoundException , _ExpiredNextTokenException , _KMSDisabledException , _ResourceNotFoundException , _KMSAccessDeniedException , _LimitExceededException , _ResourceInUseException -- * EncryptionType , EncryptionType (..) -- * MetricsName , MetricsName (..) -- * ScalingType , ScalingType (..) -- * ShardIteratorType , ShardIteratorType (..) -- * StreamStatus , StreamStatus (..) -- * EnhancedMetrics , EnhancedMetrics , enhancedMetrics , emShardLevelMetrics -- * EnhancedMonitoringOutput , EnhancedMonitoringOutput , enhancedMonitoringOutput , emoDesiredShardLevelMetrics , emoCurrentShardLevelMetrics , emoStreamName -- * HashKeyRange , HashKeyRange , hashKeyRange , hkrStartingHashKey , hkrEndingHashKey -- * PutRecordsRequestEntry , PutRecordsRequestEntry , putRecordsRequestEntry , prreExplicitHashKey , prreData , prrePartitionKey -- * PutRecordsResultEntry , PutRecordsResultEntry , putRecordsResultEntry , prreSequenceNumber , prreErrorCode , prreErrorMessage , prreShardId -- * Record , Record , record , rEncryptionType , rApproximateArrivalTimestamp , rSequenceNumber , rData , rPartitionKey -- * SequenceNumberRange , SequenceNumberRange , sequenceNumberRange , snrEndingSequenceNumber , snrStartingSequenceNumber -- * Shard , Shard , shard , sAdjacentParentShardId , sParentShardId , sShardId , sHashKeyRange , sSequenceNumberRange -- * StreamDescription , StreamDescription , streamDescription , sdEncryptionType , sdKeyId , sdStreamName , sdStreamARN , sdStreamStatus , sdShards , sdHasMoreShards , sdRetentionPeriodHours , sdStreamCreationTimestamp , sdEnhancedMonitoring -- * StreamDescriptionSummary , StreamDescriptionSummary , streamDescriptionSummary , sdsEncryptionType , sdsKeyId , sdsStreamName , sdsStreamARN , sdsStreamStatus , sdsRetentionPeriodHours , sdsStreamCreationTimestamp , sdsEnhancedMonitoring , sdsOpenShardCount -- * Tag , Tag , tag , tagValue , 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 -- | 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 } where retry = 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" | has (hasCode "Throttling" . hasStatus 400) e = Just "throttling" | has (hasStatus 504) e = Just "gateway_timeout" | has (hasCode "RequestThrottledException" . hasStatus 400) e = Just "request_throttled_exception" | has (hasStatus 502) e = Just "bad_gateway" | has (hasStatus 503) e = Just "service_unavailable" | has (hasStatus 500) e = Just "general_server_error" | 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 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 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 = _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 = _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 in the /Amazon Kinesis Data Streams Developer Guide/ , and in the /AWS General Reference/ . -- -- _ProvisionedThroughputExceededException :: AsError a => Getting (First ServiceError) a ServiceError _ProvisionedThroughputExceededException = _MatchServiceError kinesis "ProvisionedThroughputExceededException" -- | The request was rejected because the specified entity or resource can't be found. -- -- _KMSNotFoundException :: AsError a => Getting (First ServiceError) a ServiceError _KMSNotFoundException = _MatchServiceError kinesis "KMSNotFoundException" -- | The pagination token passed to the @ListShards@ operation is expired. For more information, see 'ListShardsInput$NextToken' . -- -- _ExpiredNextTokenException :: AsError a => Getting (First ServiceError) a ServiceError _ExpiredNextTokenException = _MatchServiceError kinesis "ExpiredNextTokenException" -- | The request was rejected because the specified customer master key (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 = _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. -- -- _LimitExceededException :: AsError a => Getting (First ServiceError) a ServiceError _LimitExceededException = _MatchServiceError kinesis "LimitExceededException" -- | The resource is not available for this operation. For successful operation, the resource must be in the @ACTIVE@ state. -- -- _ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError _ResourceInUseException = _MatchServiceError kinesis "ResourceInUseException"