Copyright	(c) 2013-2023 Brendan Hay
License	Mozilla Public License, v. 2.0.
Maintainer	Brendan Hay
Stability	auto-generated
Portability	non-portable (GHC extensions)
Safe Haskell	Safe-Inferred
Language	Haskell2010

Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters

Description

Synopsis

Documentation

data UpdatePipeSourceDynamoDBStreamParameters Source #

The parameters for using a DynamoDB stream as a source.

See: newUpdatePipeSourceDynamoDBStreamParameters smart constructor.

Constructors

UpdatePipeSourceDynamoDBStreamParameters'

Fields

batchSize :: Maybe Natural
The maximum number of records to include in each batch.
deadLetterConfig :: Maybe DeadLetterConfig
Define the target queue to send dead-letter queue events to.
maximumBatchingWindowInSeconds :: Maybe Natural
The maximum length of a time to wait for events.
maximumRecordAgeInSeconds :: Maybe Int
(Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.
maximumRetryAttempts :: Maybe Int
(Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.
onPartialBatchItemFailure :: Maybe OnPartialBatchItemFailureStreams
(Streams only) Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.
parallelizationFactor :: Maybe Natural
(Streams only) The number of batches to process concurrently from each shard. The default value is 1.

Instances

Instances details

ToJSON UpdatePipeSourceDynamoDBStreamParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters Methods toJSON :: UpdatePipeSourceDynamoDBStreamParameters -> Value # toEncoding :: UpdatePipeSourceDynamoDBStreamParameters -> Encoding # toJSONList :: [UpdatePipeSourceDynamoDBStreamParameters] -> Value # toEncodingList :: [UpdatePipeSourceDynamoDBStreamParameters] -> Encoding #
Generic UpdatePipeSourceDynamoDBStreamParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters Associated Types type Rep UpdatePipeSourceDynamoDBStreamParameters :: Type -> Type # Methods from :: UpdatePipeSourceDynamoDBStreamParameters -> Rep UpdatePipeSourceDynamoDBStreamParameters x # to :: Rep UpdatePipeSourceDynamoDBStreamParameters x -> UpdatePipeSourceDynamoDBStreamParameters #
Read UpdatePipeSourceDynamoDBStreamParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters Methods readsPrec :: Int -> ReadS UpdatePipeSourceDynamoDBStreamParameters # readList :: ReadS [UpdatePipeSourceDynamoDBStreamParameters] # readPrec :: ReadPrec UpdatePipeSourceDynamoDBStreamParameters # readListPrec :: ReadPrec [UpdatePipeSourceDynamoDBStreamParameters] #
Show UpdatePipeSourceDynamoDBStreamParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters Methods showsPrec :: Int -> UpdatePipeSourceDynamoDBStreamParameters -> ShowS # show :: UpdatePipeSourceDynamoDBStreamParameters -> String # showList :: [UpdatePipeSourceDynamoDBStreamParameters] -> ShowS #
NFData UpdatePipeSourceDynamoDBStreamParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters Methods rnf :: UpdatePipeSourceDynamoDBStreamParameters -> () #
Eq UpdatePipeSourceDynamoDBStreamParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters Methods (==) :: UpdatePipeSourceDynamoDBStreamParameters -> UpdatePipeSourceDynamoDBStreamParameters -> Bool # (/=) :: UpdatePipeSourceDynamoDBStreamParameters -> UpdatePipeSourceDynamoDBStreamParameters -> Bool #
Hashable UpdatePipeSourceDynamoDBStreamParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters Methods hashWithSalt :: Int -> UpdatePipeSourceDynamoDBStreamParameters -> Int # hash :: UpdatePipeSourceDynamoDBStreamParameters -> Int #
type Rep UpdatePipeSourceDynamoDBStreamParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters type Rep UpdatePipeSourceDynamoDBStreamParameters = D1 ('MetaData "UpdatePipeSourceDynamoDBStreamParameters" "Amazonka.Pipes.Types.UpdatePipeSourceDynamoDBStreamParameters" "amazonka-pipes-2.0-DDuNjbjVfgsJFLlibzr06i" 'False) (C1 ('MetaCons "UpdatePipeSourceDynamoDBStreamParameters'" 'PrefixI 'True) ((S1 ('MetaSel ('Just "batchSize") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Natural)) :: (S1 ('MetaSel ('Just "deadLetterConfig") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe DeadLetterConfig)) :: S1 ('MetaSel ('Just "maximumBatchingWindowInSeconds") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Natural)))) :: ((S1 ('MetaSel ('Just "maximumRecordAgeInSeconds") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Int)) :: S1 ('MetaSel ('Just "maximumRetryAttempts") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Int))) :: (S1 ('MetaSel ('Just "onPartialBatchItemFailure") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe OnPartialBatchItemFailureStreams)) :: S1 ('MetaSel ('Just "parallelizationFactor") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Natural))))))

newUpdatePipeSourceDynamoDBStreamParameters :: UpdatePipeSourceDynamoDBStreamParameters Source #

Create a value of UpdatePipeSourceDynamoDBStreamParameters with all optional fields omitted.

Use generic-lens or optics to modify other optional fields.

The following record fields are available, with the corresponding lenses provided for backwards compatibility:

$sel:batchSize:UpdatePipeSourceDynamoDBStreamParameters', updatePipeSourceDynamoDBStreamParameters_batchSize - The maximum number of records to include in each batch.

$sel:deadLetterConfig:UpdatePipeSourceDynamoDBStreamParameters', updatePipeSourceDynamoDBStreamParameters_deadLetterConfig - Define the target queue to send dead-letter queue events to.

$sel:maximumBatchingWindowInSeconds:UpdatePipeSourceDynamoDBStreamParameters', updatePipeSourceDynamoDBStreamParameters_maximumBatchingWindowInSeconds - The maximum length of a time to wait for events.

$sel:maximumRecordAgeInSeconds:UpdatePipeSourceDynamoDBStreamParameters', updatePipeSourceDynamoDBStreamParameters_maximumRecordAgeInSeconds - (Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.

$sel:maximumRetryAttempts:UpdatePipeSourceDynamoDBStreamParameters', updatePipeSourceDynamoDBStreamParameters_maximumRetryAttempts - (Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.

$sel:onPartialBatchItemFailure:UpdatePipeSourceDynamoDBStreamParameters', updatePipeSourceDynamoDBStreamParameters_onPartialBatchItemFailure - (Streams only) Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.

$sel:parallelizationFactor:UpdatePipeSourceDynamoDBStreamParameters', updatePipeSourceDynamoDBStreamParameters_parallelizationFactor - (Streams only) The number of batches to process concurrently from each shard. The default value is 1.

updatePipeSourceDynamoDBStreamParameters_batchSize :: Lens' UpdatePipeSourceDynamoDBStreamParameters (Maybe Natural) Source #

The maximum number of records to include in each batch.

updatePipeSourceDynamoDBStreamParameters_deadLetterConfig :: Lens' UpdatePipeSourceDynamoDBStreamParameters (Maybe DeadLetterConfig) Source #

Define the target queue to send dead-letter queue events to.

updatePipeSourceDynamoDBStreamParameters_maximumBatchingWindowInSeconds :: Lens' UpdatePipeSourceDynamoDBStreamParameters (Maybe Natural) Source #

The maximum length of a time to wait for events.

updatePipeSourceDynamoDBStreamParameters_maximumRecordAgeInSeconds :: Lens' UpdatePipeSourceDynamoDBStreamParameters (Maybe Int) Source #

(Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.

updatePipeSourceDynamoDBStreamParameters_maximumRetryAttempts :: Lens' UpdatePipeSourceDynamoDBStreamParameters (Maybe Int) Source #

(Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.

updatePipeSourceDynamoDBStreamParameters_onPartialBatchItemFailure :: Lens' UpdatePipeSourceDynamoDBStreamParameters (Maybe OnPartialBatchItemFailureStreams) Source #

(Streams only) Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.

updatePipeSourceDynamoDBStreamParameters_parallelizationFactor :: Lens' UpdatePipeSourceDynamoDBStreamParameters (Maybe Natural) Source #

(Streams only) The number of batches to process concurrently from each shard. The default value is 1.