{-# LANGUAGE DisambiguateRecordFields #-}
{-# LANGUAGE OverloadedStrings #-}
{-# LANGUAGE StrictData #-}
{-# LANGUAGE NoImplicitPrelude #-}
{-# OPTIONS_GHC -fno-warn-unused-matches #-}
module Amazonka.Pipes.Types
(
defaultService,
_ConflictException,
_InternalException,
_NotFoundException,
_ServiceQuotaExceededException,
_ThrottlingException,
_ValidationException,
AssignPublicIp (..),
BatchJobDependencyType (..),
BatchResourceRequirementType (..),
DynamoDBStreamStartPosition (..),
EcsEnvironmentFileType (..),
EcsResourceRequirementType (..),
KinesisStreamStartPosition (..),
LaunchType (..),
MSKStartPosition (..),
OnPartialBatchItemFailureStreams (..),
PipeState (..),
PipeTargetInvocationType (..),
PlacementConstraintType (..),
PlacementStrategyType (..),
PropagateTags (..),
RequestedPipeState (..),
RequestedPipeStateDescribeResponse (..),
SelfManagedKafkaStartPosition (..),
AwsVpcConfiguration (..),
newAwsVpcConfiguration,
awsVpcConfiguration_assignPublicIp,
awsVpcConfiguration_securityGroups,
awsVpcConfiguration_subnets,
BatchArrayProperties (..),
newBatchArrayProperties,
batchArrayProperties_size,
BatchContainerOverrides (..),
newBatchContainerOverrides,
batchContainerOverrides_command,
batchContainerOverrides_environment,
batchContainerOverrides_instanceType,
batchContainerOverrides_resourceRequirements,
BatchEnvironmentVariable (..),
newBatchEnvironmentVariable,
batchEnvironmentVariable_name,
batchEnvironmentVariable_value,
BatchJobDependency (..),
newBatchJobDependency,
batchJobDependency_jobId,
batchJobDependency_type,
BatchResourceRequirement (..),
newBatchResourceRequirement,
batchResourceRequirement_type,
batchResourceRequirement_value,
BatchRetryStrategy (..),
newBatchRetryStrategy,
batchRetryStrategy_attempts,
CapacityProviderStrategyItem (..),
newCapacityProviderStrategyItem,
capacityProviderStrategyItem_base,
capacityProviderStrategyItem_weight,
capacityProviderStrategyItem_capacityProvider,
DeadLetterConfig (..),
newDeadLetterConfig,
deadLetterConfig_arn,
EcsContainerOverride (..),
newEcsContainerOverride,
ecsContainerOverride_command,
ecsContainerOverride_cpu,
ecsContainerOverride_environment,
ecsContainerOverride_environmentFiles,
ecsContainerOverride_memory,
ecsContainerOverride_memoryReservation,
ecsContainerOverride_name,
ecsContainerOverride_resourceRequirements,
EcsEnvironmentFile (..),
newEcsEnvironmentFile,
ecsEnvironmentFile_type,
ecsEnvironmentFile_value,
EcsEnvironmentVariable (..),
newEcsEnvironmentVariable,
ecsEnvironmentVariable_name,
ecsEnvironmentVariable_value,
EcsEphemeralStorage (..),
newEcsEphemeralStorage,
ecsEphemeralStorage_sizeInGiB,
EcsInferenceAcceleratorOverride (..),
newEcsInferenceAcceleratorOverride,
ecsInferenceAcceleratorOverride_deviceName,
ecsInferenceAcceleratorOverride_deviceType,
EcsResourceRequirement (..),
newEcsResourceRequirement,
ecsResourceRequirement_type,
ecsResourceRequirement_value,
EcsTaskOverride (..),
newEcsTaskOverride,
ecsTaskOverride_containerOverrides,
ecsTaskOverride_cpu,
ecsTaskOverride_ephemeralStorage,
ecsTaskOverride_executionRoleArn,
ecsTaskOverride_inferenceAcceleratorOverrides,
ecsTaskOverride_memory,
ecsTaskOverride_taskRoleArn,
Filter (..),
newFilter,
filter_pattern,
FilterCriteria (..),
newFilterCriteria,
filterCriteria_filters,
MQBrokerAccessCredentials (..),
newMQBrokerAccessCredentials,
mQBrokerAccessCredentials_basicAuth,
MSKAccessCredentials (..),
newMSKAccessCredentials,
mSKAccessCredentials_clientCertificateTlsAuth,
mSKAccessCredentials_saslScram512Auth,
NetworkConfiguration (..),
newNetworkConfiguration,
networkConfiguration_awsvpcConfiguration,
Pipe (..),
newPipe,
pipe_arn,
pipe_creationTime,
pipe_currentState,
pipe_desiredState,
pipe_enrichment,
pipe_lastModifiedTime,
pipe_name,
pipe_source,
pipe_stateReason,
pipe_target,
PipeEnrichmentHttpParameters (..),
newPipeEnrichmentHttpParameters,
pipeEnrichmentHttpParameters_headerParameters,
pipeEnrichmentHttpParameters_pathParameterValues,
pipeEnrichmentHttpParameters_queryStringParameters,
PipeEnrichmentParameters (..),
newPipeEnrichmentParameters,
pipeEnrichmentParameters_httpParameters,
pipeEnrichmentParameters_inputTemplate,
PipeSourceActiveMQBrokerParameters (..),
newPipeSourceActiveMQBrokerParameters,
pipeSourceActiveMQBrokerParameters_batchSize,
pipeSourceActiveMQBrokerParameters_maximumBatchingWindowInSeconds,
pipeSourceActiveMQBrokerParameters_credentials,
pipeSourceActiveMQBrokerParameters_queueName,
PipeSourceDynamoDBStreamParameters (..),
newPipeSourceDynamoDBStreamParameters,
pipeSourceDynamoDBStreamParameters_batchSize,
pipeSourceDynamoDBStreamParameters_deadLetterConfig,
pipeSourceDynamoDBStreamParameters_maximumBatchingWindowInSeconds,
pipeSourceDynamoDBStreamParameters_maximumRecordAgeInSeconds,
pipeSourceDynamoDBStreamParameters_maximumRetryAttempts,
pipeSourceDynamoDBStreamParameters_onPartialBatchItemFailure,
pipeSourceDynamoDBStreamParameters_parallelizationFactor,
pipeSourceDynamoDBStreamParameters_startingPosition,
PipeSourceKinesisStreamParameters (..),
newPipeSourceKinesisStreamParameters,
pipeSourceKinesisStreamParameters_batchSize,
pipeSourceKinesisStreamParameters_deadLetterConfig,
pipeSourceKinesisStreamParameters_maximumBatchingWindowInSeconds,
pipeSourceKinesisStreamParameters_maximumRecordAgeInSeconds,
pipeSourceKinesisStreamParameters_maximumRetryAttempts,
pipeSourceKinesisStreamParameters_onPartialBatchItemFailure,
pipeSourceKinesisStreamParameters_parallelizationFactor,
pipeSourceKinesisStreamParameters_startingPositionTimestamp,
pipeSourceKinesisStreamParameters_startingPosition,
PipeSourceManagedStreamingKafkaParameters (..),
newPipeSourceManagedStreamingKafkaParameters,
pipeSourceManagedStreamingKafkaParameters_batchSize,
pipeSourceManagedStreamingKafkaParameters_consumerGroupID,
pipeSourceManagedStreamingKafkaParameters_credentials,
pipeSourceManagedStreamingKafkaParameters_maximumBatchingWindowInSeconds,
pipeSourceManagedStreamingKafkaParameters_startingPosition,
pipeSourceManagedStreamingKafkaParameters_topicName,
PipeSourceParameters (..),
newPipeSourceParameters,
pipeSourceParameters_activeMQBrokerParameters,
pipeSourceParameters_dynamoDBStreamParameters,
pipeSourceParameters_filterCriteria,
pipeSourceParameters_kinesisStreamParameters,
pipeSourceParameters_managedStreamingKafkaParameters,
pipeSourceParameters_rabbitMQBrokerParameters,
pipeSourceParameters_selfManagedKafkaParameters,
pipeSourceParameters_sqsQueueParameters,
PipeSourceRabbitMQBrokerParameters (..),
newPipeSourceRabbitMQBrokerParameters,
pipeSourceRabbitMQBrokerParameters_batchSize,
pipeSourceRabbitMQBrokerParameters_maximumBatchingWindowInSeconds,
pipeSourceRabbitMQBrokerParameters_virtualHost,
pipeSourceRabbitMQBrokerParameters_credentials,
pipeSourceRabbitMQBrokerParameters_queueName,
PipeSourceSelfManagedKafkaParameters (..),
newPipeSourceSelfManagedKafkaParameters,
pipeSourceSelfManagedKafkaParameters_additionalBootstrapServers,
pipeSourceSelfManagedKafkaParameters_batchSize,
pipeSourceSelfManagedKafkaParameters_consumerGroupID,
pipeSourceSelfManagedKafkaParameters_credentials,
pipeSourceSelfManagedKafkaParameters_maximumBatchingWindowInSeconds,
pipeSourceSelfManagedKafkaParameters_serverRootCaCertificate,
pipeSourceSelfManagedKafkaParameters_startingPosition,
pipeSourceSelfManagedKafkaParameters_vpc,
pipeSourceSelfManagedKafkaParameters_topicName,
PipeSourceSqsQueueParameters (..),
newPipeSourceSqsQueueParameters,
pipeSourceSqsQueueParameters_batchSize,
pipeSourceSqsQueueParameters_maximumBatchingWindowInSeconds,
PipeTargetBatchJobParameters (..),
newPipeTargetBatchJobParameters,
pipeTargetBatchJobParameters_arrayProperties,
pipeTargetBatchJobParameters_containerOverrides,
pipeTargetBatchJobParameters_dependsOn,
pipeTargetBatchJobParameters_parameters,
pipeTargetBatchJobParameters_retryStrategy,
pipeTargetBatchJobParameters_jobDefinition,
pipeTargetBatchJobParameters_jobName,
PipeTargetCloudWatchLogsParameters (..),
newPipeTargetCloudWatchLogsParameters,
pipeTargetCloudWatchLogsParameters_logStreamName,
pipeTargetCloudWatchLogsParameters_timestamp,
PipeTargetEcsTaskParameters (..),
newPipeTargetEcsTaskParameters,
pipeTargetEcsTaskParameters_capacityProviderStrategy,
pipeTargetEcsTaskParameters_enableECSManagedTags,
pipeTargetEcsTaskParameters_enableExecuteCommand,
pipeTargetEcsTaskParameters_group,
pipeTargetEcsTaskParameters_launchType,
pipeTargetEcsTaskParameters_networkConfiguration,
pipeTargetEcsTaskParameters_overrides,
pipeTargetEcsTaskParameters_placementConstraints,
pipeTargetEcsTaskParameters_placementStrategy,
pipeTargetEcsTaskParameters_platformVersion,
pipeTargetEcsTaskParameters_propagateTags,
pipeTargetEcsTaskParameters_referenceId,
pipeTargetEcsTaskParameters_tags,
pipeTargetEcsTaskParameters_taskCount,
pipeTargetEcsTaskParameters_taskDefinitionArn,
PipeTargetEventBridgeEventBusParameters (..),
newPipeTargetEventBridgeEventBusParameters,
pipeTargetEventBridgeEventBusParameters_detailType,
pipeTargetEventBridgeEventBusParameters_endpointId,
pipeTargetEventBridgeEventBusParameters_resources,
pipeTargetEventBridgeEventBusParameters_source,
pipeTargetEventBridgeEventBusParameters_time,
PipeTargetHttpParameters (..),
newPipeTargetHttpParameters,
pipeTargetHttpParameters_headerParameters,
pipeTargetHttpParameters_pathParameterValues,
pipeTargetHttpParameters_queryStringParameters,
PipeTargetKinesisStreamParameters (..),
newPipeTargetKinesisStreamParameters,
pipeTargetKinesisStreamParameters_partitionKey,
PipeTargetLambdaFunctionParameters (..),
newPipeTargetLambdaFunctionParameters,
pipeTargetLambdaFunctionParameters_invocationType,
PipeTargetParameters (..),
newPipeTargetParameters,
pipeTargetParameters_batchJobParameters,
pipeTargetParameters_cloudWatchLogsParameters,
pipeTargetParameters_ecsTaskParameters,
pipeTargetParameters_eventBridgeEventBusParameters,
pipeTargetParameters_httpParameters,
pipeTargetParameters_inputTemplate,
pipeTargetParameters_kinesisStreamParameters,
pipeTargetParameters_lambdaFunctionParameters,
pipeTargetParameters_redshiftDataParameters,
pipeTargetParameters_sageMakerPipelineParameters,
pipeTargetParameters_sqsQueueParameters,
pipeTargetParameters_stepFunctionStateMachineParameters,
PipeTargetRedshiftDataParameters (..),
newPipeTargetRedshiftDataParameters,
pipeTargetRedshiftDataParameters_dbUser,
pipeTargetRedshiftDataParameters_secretManagerArn,
pipeTargetRedshiftDataParameters_statementName,
pipeTargetRedshiftDataParameters_withEvent,
pipeTargetRedshiftDataParameters_database,
pipeTargetRedshiftDataParameters_sqls,
PipeTargetSageMakerPipelineParameters (..),
newPipeTargetSageMakerPipelineParameters,
pipeTargetSageMakerPipelineParameters_pipelineParameterList,
PipeTargetSqsQueueParameters (..),
newPipeTargetSqsQueueParameters,
pipeTargetSqsQueueParameters_messageDeduplicationId,
pipeTargetSqsQueueParameters_messageGroupId,
PipeTargetStateMachineParameters (..),
newPipeTargetStateMachineParameters,
pipeTargetStateMachineParameters_invocationType,
PlacementConstraint (..),
newPlacementConstraint,
placementConstraint_expression,
placementConstraint_type,
PlacementStrategy (..),
newPlacementStrategy,
placementStrategy_field,
placementStrategy_type,
SageMakerPipelineParameter (..),
newSageMakerPipelineParameter,
sageMakerPipelineParameter_name,
sageMakerPipelineParameter_value,
SelfManagedKafkaAccessConfigurationCredentials (..),
newSelfManagedKafkaAccessConfigurationCredentials,
selfManagedKafkaAccessConfigurationCredentials_basicAuth,
selfManagedKafkaAccessConfigurationCredentials_clientCertificateTlsAuth,
selfManagedKafkaAccessConfigurationCredentials_saslScram256Auth,
selfManagedKafkaAccessConfigurationCredentials_saslScram512Auth,
SelfManagedKafkaAccessConfigurationVpc (..),
newSelfManagedKafkaAccessConfigurationVpc,
selfManagedKafkaAccessConfigurationVpc_securityGroup,
selfManagedKafkaAccessConfigurationVpc_subnets,
Tag (..),
newTag,
tag_key,
tag_value,
UpdatePipeSourceActiveMQBrokerParameters (..),
newUpdatePipeSourceActiveMQBrokerParameters,
updatePipeSourceActiveMQBrokerParameters_batchSize,
updatePipeSourceActiveMQBrokerParameters_maximumBatchingWindowInSeconds,
updatePipeSourceActiveMQBrokerParameters_credentials,
UpdatePipeSourceDynamoDBStreamParameters (..),
newUpdatePipeSourceDynamoDBStreamParameters,
updatePipeSourceDynamoDBStreamParameters_batchSize,
updatePipeSourceDynamoDBStreamParameters_deadLetterConfig,
updatePipeSourceDynamoDBStreamParameters_maximumBatchingWindowInSeconds,
updatePipeSourceDynamoDBStreamParameters_maximumRecordAgeInSeconds,
updatePipeSourceDynamoDBStreamParameters_maximumRetryAttempts,
updatePipeSourceDynamoDBStreamParameters_onPartialBatchItemFailure,
updatePipeSourceDynamoDBStreamParameters_parallelizationFactor,
UpdatePipeSourceKinesisStreamParameters (..),
newUpdatePipeSourceKinesisStreamParameters,
updatePipeSourceKinesisStreamParameters_batchSize,
updatePipeSourceKinesisStreamParameters_deadLetterConfig,
updatePipeSourceKinesisStreamParameters_maximumBatchingWindowInSeconds,
updatePipeSourceKinesisStreamParameters_maximumRecordAgeInSeconds,
updatePipeSourceKinesisStreamParameters_maximumRetryAttempts,
updatePipeSourceKinesisStreamParameters_onPartialBatchItemFailure,
updatePipeSourceKinesisStreamParameters_parallelizationFactor,
UpdatePipeSourceManagedStreamingKafkaParameters (..),
newUpdatePipeSourceManagedStreamingKafkaParameters,
updatePipeSourceManagedStreamingKafkaParameters_batchSize,
updatePipeSourceManagedStreamingKafkaParameters_credentials,
updatePipeSourceManagedStreamingKafkaParameters_maximumBatchingWindowInSeconds,
UpdatePipeSourceParameters (..),
newUpdatePipeSourceParameters,
updatePipeSourceParameters_activeMQBrokerParameters,
updatePipeSourceParameters_dynamoDBStreamParameters,
updatePipeSourceParameters_filterCriteria,
updatePipeSourceParameters_kinesisStreamParameters,
updatePipeSourceParameters_managedStreamingKafkaParameters,
updatePipeSourceParameters_rabbitMQBrokerParameters,
updatePipeSourceParameters_selfManagedKafkaParameters,
updatePipeSourceParameters_sqsQueueParameters,
UpdatePipeSourceRabbitMQBrokerParameters (..),
newUpdatePipeSourceRabbitMQBrokerParameters,
updatePipeSourceRabbitMQBrokerParameters_batchSize,
updatePipeSourceRabbitMQBrokerParameters_maximumBatchingWindowInSeconds,
updatePipeSourceRabbitMQBrokerParameters_credentials,
UpdatePipeSourceSelfManagedKafkaParameters (..),
newUpdatePipeSourceSelfManagedKafkaParameters,
updatePipeSourceSelfManagedKafkaParameters_batchSize,
updatePipeSourceSelfManagedKafkaParameters_credentials,
updatePipeSourceSelfManagedKafkaParameters_maximumBatchingWindowInSeconds,
updatePipeSourceSelfManagedKafkaParameters_serverRootCaCertificate,
updatePipeSourceSelfManagedKafkaParameters_vpc,
UpdatePipeSourceSqsQueueParameters (..),
newUpdatePipeSourceSqsQueueParameters,
updatePipeSourceSqsQueueParameters_batchSize,
updatePipeSourceSqsQueueParameters_maximumBatchingWindowInSeconds,
)
where
import qualified Amazonka.Core as Core
import qualified Amazonka.Core.Lens.Internal as Lens
import Amazonka.Pipes.Types.AssignPublicIp
import Amazonka.Pipes.Types.AwsVpcConfiguration
import Amazonka.Pipes.Types.BatchArrayProperties
import Amazonka.Pipes.Types.BatchContainerOverrides
import Amazonka.Pipes.Types.BatchEnvironmentVariable
import Amazonka.Pipes.Types.BatchJobDependency
import Amazonka.Pipes.Types.BatchJobDependencyType
import Amazonka.Pipes.Types.BatchResourceRequirement
import Amazonka.Pipes.Types.BatchResourceRequirementType
import Amazonka.Pipes.Types.BatchRetryStrategy
import Amazonka.Pipes.Types.CapacityProviderStrategyItem
import Amazonka.Pipes.Types.DeadLetterConfig
import Amazonka.Pipes.Types.DynamoDBStreamStartPosition
import Amazonka.Pipes.Types.EcsContainerOverride
import Amazonka.Pipes.Types.EcsEnvironmentFile
import Amazonka.Pipes.Types.EcsEnvironmentFileType
import Amazonka.Pipes.Types.EcsEnvironmentVariable
import Amazonka.Pipes.Types.EcsEphemeralStorage
import Amazonka.Pipes.Types.EcsInferenceAcceleratorOverride
import Amazonka.Pipes.Types.EcsResourceRequirement
import Amazonka.Pipes.Types.EcsResourceRequirementType
import Amazonka.Pipes.Types.EcsTaskOverride
import Amazonka.Pipes.Types.Filter
import Amazonka.Pipes.Types.FilterCriteria
import Amazonka.Pipes.Types.KinesisStreamStartPosition
import Amazonka.Pipes.Types.LaunchType
import Amazonka.Pipes.Types.MQBrokerAccessCredentials
import Amazonka.Pipes.Types.MSKAccessCredentials
import Amazonka.Pipes.Types.MSKStartPosition
import Amazonka.Pipes.Types.NetworkConfiguration
import Amazonka.Pipes.Types.OnPartialBatchItemFailureStreams
import Amazonka.Pipes.Types.Pipe
import Amazonka.Pipes.Types.PipeEnrichmentHttpParameters
import Amazonka.Pipes.Types.PipeEnrichmentParameters
import Amazonka.Pipes.Types.PipeSourceActiveMQBrokerParameters
import Amazonka.Pipes.Types.PipeSourceDynamoDBStreamParameters
import Amazonka.Pipes.Types.PipeSourceKinesisStreamParameters
import Amazonka.Pipes.Types.PipeSourceManagedStreamingKafkaParameters
import Amazonka.Pipes.Types.PipeSourceParameters
import Amazonka.Pipes.Types.PipeSourceRabbitMQBrokerParameters
import Amazonka.Pipes.Types.PipeSourceSelfManagedKafkaParameters
import Amazonka.Pipes.Types.PipeSourceSqsQueueParameters
import Amazonka.Pipes.Types.PipeState
import Amazonka.Pipes.Types.PipeTargetBatchJobParameters
import Amazonka.Pipes.Types.PipeTargetCloudWatchLogsParameters
import Amazonka.Pipes.Types.PipeTargetEcsTaskParameters
import Amazonka.Pipes.Types.PipeTargetEventBridgeEventBusParameters
import Amazonka.Pipes.Types.PipeTargetHttpParameters
import Amazonka.Pipes.Types.PipeTargetInvocationType
import Amazonka.Pipes.Types.PipeTargetKinesisStreamParameters
import Amazonka.Pipes.Types.PipeTargetLambdaFunctionParameters
import Amazonka.Pipes.Types.PipeTargetParameters
import Amazonka.Pipes.Types.PipeTargetRedshiftDataParameters
import Amazonka.Pipes.Types.PipeTargetSageMakerPipelineParameters
import Amazonka.Pipes.Types.PipeTargetSqsQueueParameters
import Amazonka.Pipes.Types.PipeTargetStateMachineParameters
import Amazonka.Pipes.Types.PlacementConstraint
import Amazonka.Pipes.Types.PlacementConstraintType
import Amazonka.Pipes.Types.PlacementStrategy
import Amazonka.Pipes.Types.PlacementStrategyType
import Amazonka.Pipes.Types.PropagateTags
import Amazonka.Pipes.Types.RequestedPipeState
import Amazonka.Pipes.Types.RequestedPipeStateDescribeResponse
import Amazonka.Pipes.Types.SageMakerPipelineParameter
import Amazonka.Pipes.Types.SelfManagedKafkaAccessConfigurationCredentials
import Amazonka.Pipes.Types.SelfManagedKafkaAccessConfigurationVpc
import Amazonka.Pipes.Types.SelfManagedKafkaStartPosition
import Amazonka.Pipes.Types.Tag
import Amazonka.Pipes.Types.UpdatePipeSourceActiveMQBrokerParameters
import Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters
import Amazonka.Pipes.Types.UpdatePipeSourceKinesisStreamParameters
import Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters
import Amazonka.Pipes.Types.UpdatePipeSourceParameters
import Amazonka.Pipes.Types.UpdatePipeSourceRabbitMQBrokerParameters
import Amazonka.Pipes.Types.UpdatePipeSourceSelfManagedKafkaParameters
import Amazonka.Pipes.Types.UpdatePipeSourceSqsQueueParameters
import qualified Amazonka.Prelude as Prelude
import qualified Amazonka.Sign.V4 as Sign
defaultService :: Core.Service
defaultService :: Service
defaultService =
Core.Service
{ $sel:abbrev:Service :: Abbrev
Core.abbrev = Abbrev
"Pipes",
$sel:signer:Service :: Signer
Core.signer = Signer
Sign.v4,
$sel:endpointPrefix:Service :: ByteString
Core.endpointPrefix = ByteString
"pipes",
$sel:signingName:Service :: ByteString
Core.signingName = ByteString
"pipes",
$sel:version:Service :: ByteString
Core.version = ByteString
"2015-10-07",
$sel:s3AddressingStyle:Service :: S3AddressingStyle
Core.s3AddressingStyle = S3AddressingStyle
Core.S3AddressingStyleAuto,
$sel:endpoint:Service :: Region -> Endpoint
Core.endpoint = Service -> Region -> Endpoint
Core.defaultEndpoint Service
defaultService,
$sel:timeout:Service :: Maybe Seconds
Core.timeout = forall a. a -> Maybe a
Prelude.Just Seconds
70,
$sel:check:Service :: Status -> Bool
Core.check = Status -> Bool
Core.statusSuccess,
$sel:error:Service :: Status -> [Header] -> ByteStringLazy -> Error
Core.error = Abbrev -> Status -> [Header] -> ByteStringLazy -> Error
Core.parseJSONError Abbrev
"Pipes",
$sel:retry:Service :: Retry
Core.retry = Retry
retry
}
where
retry :: Retry
retry =
Core.Exponential
{ $sel:base:Exponential :: Double
Core.base = Double
5.0e-2,
$sel:growth:Exponential :: Int
Core.growth = Int
2,
$sel:attempts:Exponential :: Int
Core.attempts = Int
5,
$sel:check:Exponential :: ServiceError -> Maybe Text
Core.check = forall {a}. IsString a => ServiceError -> Maybe a
check
}
check :: ServiceError -> Maybe a
check ServiceError
e
| forall s a. Getting Any s a -> s -> Bool
Lens.has (forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
502) ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"bad_gateway"
| forall s a. Getting Any s a -> s -> Bool
Lens.has (forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
504) ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"gateway_timeout"
| forall s a. Getting Any s a -> s -> Bool
Lens.has (forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
500) ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"general_server_error"
| forall s a. Getting Any s a -> s -> Bool
Lens.has (forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
509) ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"limit_exceeded"
| forall s a. Getting Any s a -> s -> Bool
Lens.has
( forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
ErrorCode -> Optic' p f ServiceError ServiceError
Core.hasCode ErrorCode
"RequestThrottledException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
400
)
ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"request_throttled_exception"
| forall s a. Getting Any s a -> s -> Bool
Lens.has (forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
503) ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"service_unavailable"
| forall s a. Getting Any s a -> s -> Bool
Lens.has
( forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
ErrorCode -> Optic' p f ServiceError ServiceError
Core.hasCode ErrorCode
"ThrottledException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
400
)
ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"throttled_exception"
| forall s a. Getting Any s a -> s -> Bool
Lens.has
( forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
ErrorCode -> Optic' p f ServiceError ServiceError
Core.hasCode ErrorCode
"Throttling"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
400
)
ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"throttling"
| forall s a. Getting Any s a -> s -> Bool
Lens.has
( forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
ErrorCode -> Optic' p f ServiceError ServiceError
Core.hasCode ErrorCode
"ThrottlingException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
400
)
ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"throttling_exception"
| forall s a. Getting Any s a -> s -> Bool
Lens.has
( forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
ErrorCode -> Optic' p f ServiceError ServiceError
Core.hasCode
ErrorCode
"ProvisionedThroughputExceededException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
400
)
ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"throughput_exceeded"
| forall s a. Getting Any s a -> s -> Bool
Lens.has (forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
429) ServiceError
e =
forall a. a -> Maybe a
Prelude.Just a
"too_many_requests"
| Bool
Prelude.otherwise = forall a. Maybe a
Prelude.Nothing
_ConflictException :: (Core.AsError a) => Lens.Fold a Core.ServiceError
_ConflictException :: forall a. AsError a => Fold a ServiceError
_ConflictException =
forall a. AsError a => Service -> ErrorCode -> Fold a ServiceError
Core._MatchServiceError
Service
defaultService
ErrorCode
"ConflictException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
409
_InternalException :: (Core.AsError a) => Lens.Fold a Core.ServiceError
_InternalException :: forall a. AsError a => Fold a ServiceError
_InternalException =
forall a. AsError a => Service -> ErrorCode -> Fold a ServiceError
Core._MatchServiceError
Service
defaultService
ErrorCode
"InternalException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
500
_NotFoundException :: (Core.AsError a) => Lens.Fold a Core.ServiceError
_NotFoundException :: forall a. AsError a => Fold a ServiceError
_NotFoundException =
forall a. AsError a => Service -> ErrorCode -> Fold a ServiceError
Core._MatchServiceError
Service
defaultService
ErrorCode
"NotFoundException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
404
_ServiceQuotaExceededException :: (Core.AsError a) => Lens.Fold a Core.ServiceError
_ServiceQuotaExceededException :: forall a. AsError a => Fold a ServiceError
_ServiceQuotaExceededException =
forall a. AsError a => Service -> ErrorCode -> Fold a ServiceError
Core._MatchServiceError
Service
defaultService
ErrorCode
"ServiceQuotaExceededException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
402
_ThrottlingException :: (Core.AsError a) => Lens.Fold a Core.ServiceError
_ThrottlingException :: forall a. AsError a => Fold a ServiceError
_ThrottlingException =
forall a. AsError a => Service -> ErrorCode -> Fold a ServiceError
Core._MatchServiceError
Service
defaultService
ErrorCode
"ThrottlingException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
429
_ValidationException :: (Core.AsError a) => Lens.Fold a Core.ServiceError
_ValidationException :: forall a. AsError a => Fold a ServiceError
_ValidationException =
forall a. AsError a => Service -> ErrorCode -> Fold a ServiceError
Core._MatchServiceError
Service
defaultService
ErrorCode
"ValidationException"
forall b c a. (b -> c) -> (a -> b) -> a -> c
Prelude.. forall (f :: * -> *) (p :: * -> * -> *).
(Applicative f, Choice p) =>
Int -> Optic' p f ServiceError ServiceError
Core.hasStatus Int
400