{-# LANGUAGE OverloadedStrings #-}
module Network.AWS.KinesisAnalytics.Types
(
kinesisAnalytics
, _InvalidApplicationConfigurationException
, _ResourceProvisionedThroughputExceededException
, _InvalidArgumentException
, _CodeValidationException
, _ConcurrentModificationException
, _ServiceUnavailableException
, _UnableToDetectSchemaException
, _ResourceNotFoundException
, _LimitExceededException
, _ResourceInUseException
, ApplicationStatus (..)
, InputStartingPosition (..)
, RecordFormatType (..)
, ApplicationDetail
, applicationDetail
, adApplicationDescription
, adOutputDescriptions
, adCloudWatchLoggingOptionDescriptions
, adReferenceDataSourceDescriptions
, adInputDescriptions
, adApplicationCode
, adCreateTimestamp
, adLastUpdateTimestamp
, adApplicationName
, adApplicationARN
, adApplicationStatus
, adApplicationVersionId
, ApplicationSummary
, applicationSummary
, asApplicationName
, asApplicationARN
, asApplicationStatus
, ApplicationUpdate
, applicationUpdate
, auReferenceDataSourceUpdates
, auInputUpdates
, auCloudWatchLoggingOptionUpdates
, auOutputUpdates
, auApplicationCodeUpdate
, CSVMappingParameters
, csvMappingParameters
, cmpRecordRowDelimiter
, cmpRecordColumnDelimiter
, CloudWatchLoggingOption
, cloudWatchLoggingOption
, cwloLogStreamARN
, cwloRoleARN
, CloudWatchLoggingOptionDescription
, cloudWatchLoggingOptionDescription
, cwlodCloudWatchLoggingOptionId
, cwlodLogStreamARN
, cwlodRoleARN
, CloudWatchLoggingOptionUpdate
, cloudWatchLoggingOptionUpdate
, cwlouRoleARNUpdate
, cwlouLogStreamARNUpdate
, cwlouCloudWatchLoggingOptionId
, DestinationSchema
, destinationSchema
, dsRecordFormatType
, Input
, input
, iInputParallelism
, iInputProcessingConfiguration
, iKinesisStreamsInput
, iKinesisFirehoseInput
, iNamePrefix
, iInputSchema
, InputConfiguration
, inputConfiguration
, icId
, icInputStartingPositionConfiguration
, InputDescription
, inputDescription
, idInputStartingPositionConfiguration
, idInputParallelism
, idInputId
, idInAppStreamNames
, idKinesisFirehoseInputDescription
, idInputSchema
, idKinesisStreamsInputDescription
, idNamePrefix
, idInputProcessingConfigurationDescription
, InputLambdaProcessor
, inputLambdaProcessor
, ilpResourceARN
, ilpRoleARN
, InputLambdaProcessorDescription
, inputLambdaProcessorDescription
, ilpdResourceARN
, ilpdRoleARN
, InputLambdaProcessorUpdate
, inputLambdaProcessorUpdate
, ilpuRoleARNUpdate
, ilpuResourceARNUpdate
, InputParallelism
, inputParallelism
, ipCount
, InputParallelismUpdate
, inputParallelismUpdate
, ipuCountUpdate
, InputProcessingConfiguration
, inputProcessingConfiguration
, ipcInputLambdaProcessor
, InputProcessingConfigurationDescription
, inputProcessingConfigurationDescription
, ipcdInputLambdaProcessorDescription
, InputProcessingConfigurationUpdate
, inputProcessingConfigurationUpdate
, ipcuInputLambdaProcessorUpdate
, InputSchemaUpdate
, inputSchemaUpdate
, isuRecordFormatUpdate
, isuRecordEncodingUpdate
, isuRecordColumnUpdates
, InputStartingPositionConfiguration
, inputStartingPositionConfiguration
, ispcInputStartingPosition
, InputUpdate
, inputUpdate
, iuInputProcessingConfigurationUpdate
, iuKinesisStreamsInputUpdate
, iuInputParallelismUpdate
, iuNamePrefixUpdate
, iuInputSchemaUpdate
, iuKinesisFirehoseInputUpdate
, iuInputId
, JSONMappingParameters
, jsonMappingParameters
, jmpRecordRowPath
, KinesisFirehoseInput
, kinesisFirehoseInput
, kfiResourceARN
, kfiRoleARN
, KinesisFirehoseInputDescription
, kinesisFirehoseInputDescription
, kfidResourceARN
, kfidRoleARN
, KinesisFirehoseInputUpdate
, kinesisFirehoseInputUpdate
, kfiuRoleARNUpdate
, kfiuResourceARNUpdate
, KinesisFirehoseOutput
, kinesisFirehoseOutput
, kfoResourceARN
, kfoRoleARN
, KinesisFirehoseOutputDescription
, kinesisFirehoseOutputDescription
, kfodResourceARN
, kfodRoleARN
, KinesisFirehoseOutputUpdate
, kinesisFirehoseOutputUpdate
, kfouRoleARNUpdate
, kfouResourceARNUpdate
, KinesisStreamsInput
, kinesisStreamsInput
, ksiResourceARN
, ksiRoleARN
, KinesisStreamsInputDescription
, kinesisStreamsInputDescription
, ksidResourceARN
, ksidRoleARN
, KinesisStreamsInputUpdate
, kinesisStreamsInputUpdate
, ksiuRoleARNUpdate
, ksiuResourceARNUpdate
, KinesisStreamsOutput
, kinesisStreamsOutput
, ksoResourceARN
, ksoRoleARN
, KinesisStreamsOutputDescription
, kinesisStreamsOutputDescription
, ksodResourceARN
, ksodRoleARN
, KinesisStreamsOutputUpdate
, kinesisStreamsOutputUpdate
, ksouRoleARNUpdate
, ksouResourceARNUpdate
, LambdaOutput
, lambdaOutput
, loResourceARN
, loRoleARN
, LambdaOutputDescription
, lambdaOutputDescription
, lodResourceARN
, lodRoleARN
, LambdaOutputUpdate
, lambdaOutputUpdate
, louRoleARNUpdate
, louResourceARNUpdate
, MappingParameters
, mappingParameters
, mpCSVMappingParameters
, mpJSONMappingParameters
, Output
, output
, oLambdaOutput
, oKinesisStreamsOutput
, oKinesisFirehoseOutput
, oName
, oDestinationSchema
, OutputDescription
, outputDescription
, odOutputId
, odDestinationSchema
, odKinesisFirehoseOutputDescription
, odKinesisStreamsOutputDescription
, odName
, odLambdaOutputDescription
, OutputUpdate
, outputUpdate
, ouKinesisStreamsOutputUpdate
, ouDestinationSchemaUpdate
, ouKinesisFirehoseOutputUpdate
, ouNameUpdate
, ouLambdaOutputUpdate
, ouOutputId
, RecordColumn
, recordColumn
, rcMapping
, rcName
, rcSqlType
, RecordFormat
, recordFormat
, rfMappingParameters
, rfRecordFormatType
, ReferenceDataSource
, referenceDataSource
, rdsS3ReferenceDataSource
, rdsTableName
, rdsReferenceSchema
, ReferenceDataSourceDescription
, referenceDataSourceDescription
, rdsdReferenceSchema
, rdsdReferenceId
, rdsdTableName
, rdsdS3ReferenceDataSourceDescription
, ReferenceDataSourceUpdate
, referenceDataSourceUpdate
, rdsuTableNameUpdate
, rdsuS3ReferenceDataSourceUpdate
, rdsuReferenceSchemaUpdate
, rdsuReferenceId
, S3Configuration
, s3Configuration
, scRoleARN
, scBucketARN
, scFileKey
, S3ReferenceDataSource
, s3ReferenceDataSource
, srdsBucketARN
, srdsFileKey
, srdsReferenceRoleARN
, S3ReferenceDataSourceDescription
, s3ReferenceDataSourceDescription
, srdsdBucketARN
, srdsdFileKey
, srdsdReferenceRoleARN
, S3ReferenceDataSourceUpdate
, s3ReferenceDataSourceUpdate
, srdsuBucketARNUpdate
, srdsuFileKeyUpdate
, srdsuReferenceRoleARNUpdate
, SourceSchema
, sourceSchema
, ssRecordEncoding
, ssRecordFormat
, ssRecordColumns
) where
import Network.AWS.KinesisAnalytics.Types.Product
import Network.AWS.KinesisAnalytics.Types.Sum
import Network.AWS.Lens
import Network.AWS.Prelude
import Network.AWS.Sign.V4
kinesisAnalytics :: Service
kinesisAnalytics =
Service
{ _svcAbbrev = "KinesisAnalytics"
, _svcSigner = v4
, _svcPrefix = "kinesisanalytics"
, _svcVersion = "2015-08-14"
, _svcEndpoint = defaultEndpoint kinesisAnalytics
, _svcTimeout = Just 70
, _svcCheck = statusSuccess
, _svcError = parseJSONError "KinesisAnalytics"
, _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
_InvalidApplicationConfigurationException :: AsError a => Getting (First ServiceError) a ServiceError
_InvalidApplicationConfigurationException =
_MatchServiceError kinesisAnalytics "InvalidApplicationConfigurationException"
_ResourceProvisionedThroughputExceededException :: AsError a => Getting (First ServiceError) a ServiceError
_ResourceProvisionedThroughputExceededException =
_MatchServiceError
kinesisAnalytics
"ResourceProvisionedThroughputExceededException"
_InvalidArgumentException :: AsError a => Getting (First ServiceError) a ServiceError
_InvalidArgumentException =
_MatchServiceError kinesisAnalytics "InvalidArgumentException"
_CodeValidationException :: AsError a => Getting (First ServiceError) a ServiceError
_CodeValidationException =
_MatchServiceError kinesisAnalytics "CodeValidationException"
_ConcurrentModificationException :: AsError a => Getting (First ServiceError) a ServiceError
_ConcurrentModificationException =
_MatchServiceError kinesisAnalytics "ConcurrentModificationException"
_ServiceUnavailableException :: AsError a => Getting (First ServiceError) a ServiceError
_ServiceUnavailableException =
_MatchServiceError kinesisAnalytics "ServiceUnavailableException"
_UnableToDetectSchemaException :: AsError a => Getting (First ServiceError) a ServiceError
_UnableToDetectSchemaException =
_MatchServiceError kinesisAnalytics "UnableToDetectSchemaException"
_ResourceNotFoundException :: AsError a => Getting (First ServiceError) a ServiceError
_ResourceNotFoundException =
_MatchServiceError kinesisAnalytics "ResourceNotFoundException"
_LimitExceededException :: AsError a => Getting (First ServiceError) a ServiceError
_LimitExceededException =
_MatchServiceError kinesisAnalytics "LimitExceededException"
_ResourceInUseException :: AsError a => Getting (First ServiceError) a ServiceError
_ResourceInUseException =
_MatchServiceError kinesisAnalytics "ResourceInUseException"