/** * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ #pragma once #include <aws/pipes/Pipes_EXPORTS.h> #include <aws/pipes/model/DeadLetterConfig.h> #include <aws/pipes/model/OnPartialBatchItemFailureStreams.h> #include <utility> namespace Aws { namespace Utils { namespace Json { class JsonValue; class JsonView; } // namespace Json } // namespace Utils namespace Pipes { namespace Model { /** * <p>The parameters for using a Kinesis stream as a source.</p><p><h3>See * Also:</h3> <a * href="http://docs.aws.amazon.com/goto/WebAPI/pipes-2015-10-07/UpdatePipeSourceKinesisStreamParameters">AWS * API Reference</a></p> */ class UpdatePipeSourceKinesisStreamParameters { public: AWS_PIPES_API UpdatePipeSourceKinesisStreamParameters(); AWS_PIPES_API UpdatePipeSourceKinesisStreamParameters(Aws::Utils::Json::JsonView jsonValue); AWS_PIPES_API UpdatePipeSourceKinesisStreamParameters& operator=(Aws::Utils::Json::JsonView jsonValue); AWS_PIPES_API Aws::Utils::Json::JsonValue Jsonize() const; /** * <p>The maximum number of records to include in each batch.</p> */ inline int GetBatchSize() const{ return m_batchSize; } /** * <p>The maximum number of records to include in each batch.</p> */ inline bool BatchSizeHasBeenSet() const { return m_batchSizeHasBeenSet; } /** * <p>The maximum number of records to include in each batch.</p> */ inline void SetBatchSize(int value) { m_batchSizeHasBeenSet = true; m_batchSize = value; } /** * <p>The maximum number of records to include in each batch.</p> */ inline UpdatePipeSourceKinesisStreamParameters& WithBatchSize(int value) { SetBatchSize(value); return *this;} /** * <p>Define the target queue to send dead-letter queue events to.</p> */ inline const DeadLetterConfig& GetDeadLetterConfig() const{ return m_deadLetterConfig; } /** * <p>Define the target queue to send dead-letter queue events to.</p> */ inline bool DeadLetterConfigHasBeenSet() const { return m_deadLetterConfigHasBeenSet; } /** * <p>Define the target queue to send dead-letter queue events to.</p> */ inline void SetDeadLetterConfig(const DeadLetterConfig& value) { m_deadLetterConfigHasBeenSet = true; m_deadLetterConfig = value; } /** * <p>Define the target queue to send dead-letter queue events to.</p> */ inline void SetDeadLetterConfig(DeadLetterConfig&& value) { m_deadLetterConfigHasBeenSet = true; m_deadLetterConfig = std::move(value); } /** * <p>Define the target queue to send dead-letter queue events to.</p> */ inline UpdatePipeSourceKinesisStreamParameters& WithDeadLetterConfig(const DeadLetterConfig& value) { SetDeadLetterConfig(value); return *this;} /** * <p>Define the target queue to send dead-letter queue events to.</p> */ inline UpdatePipeSourceKinesisStreamParameters& WithDeadLetterConfig(DeadLetterConfig&& value) { SetDeadLetterConfig(std::move(value)); return *this;} /** * <p>The maximum length of a time to wait for events.</p> */ inline int GetMaximumBatchingWindowInSeconds() const{ return m_maximumBatchingWindowInSeconds; } /** * <p>The maximum length of a time to wait for events.</p> */ inline bool MaximumBatchingWindowInSecondsHasBeenSet() const { return m_maximumBatchingWindowInSecondsHasBeenSet; } /** * <p>The maximum length of a time to wait for events.</p> */ inline void SetMaximumBatchingWindowInSeconds(int value) { m_maximumBatchingWindowInSecondsHasBeenSet = true; m_maximumBatchingWindowInSeconds = value; } /** * <p>The maximum length of a time to wait for events.</p> */ inline UpdatePipeSourceKinesisStreamParameters& WithMaximumBatchingWindowInSeconds(int value) { SetMaximumBatchingWindowInSeconds(value); return *this;} /** * <p>(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. </p> */ inline int GetMaximumRecordAgeInSeconds() const{ return m_maximumRecordAgeInSeconds; } /** * <p>(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. </p> */ inline bool MaximumRecordAgeInSecondsHasBeenSet() const { return m_maximumRecordAgeInSecondsHasBeenSet; } /** * <p>(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. </p> */ inline void SetMaximumRecordAgeInSeconds(int value) { m_maximumRecordAgeInSecondsHasBeenSet = true; m_maximumRecordAgeInSeconds = value; } /** * <p>(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. </p> */ inline UpdatePipeSourceKinesisStreamParameters& WithMaximumRecordAgeInSeconds(int value) { SetMaximumRecordAgeInSeconds(value); return *this;} /** * <p>(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.</p> */ inline int GetMaximumRetryAttempts() const{ return m_maximumRetryAttempts; } /** * <p>(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.</p> */ inline bool MaximumRetryAttemptsHasBeenSet() const { return m_maximumRetryAttemptsHasBeenSet; } /** * <p>(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.</p> */ inline void SetMaximumRetryAttempts(int value) { m_maximumRetryAttemptsHasBeenSet = true; m_maximumRetryAttempts = value; } /** * <p>(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.</p> */ inline UpdatePipeSourceKinesisStreamParameters& WithMaximumRetryAttempts(int value) { SetMaximumRetryAttempts(value); return *this;} /** * <p>(Streams only) Define how to handle item process failures. * <code>AUTOMATIC_BISECT</code> halves each batch and retry each half until all * the records are processed or there is one failed message left in the batch.</p> */ inline const OnPartialBatchItemFailureStreams& GetOnPartialBatchItemFailure() const{ return m_onPartialBatchItemFailure; } /** * <p>(Streams only) Define how to handle item process failures. * <code>AUTOMATIC_BISECT</code> halves each batch and retry each half until all * the records are processed or there is one failed message left in the batch.</p> */ inline bool OnPartialBatchItemFailureHasBeenSet() const { return m_onPartialBatchItemFailureHasBeenSet; } /** * <p>(Streams only) Define how to handle item process failures. * <code>AUTOMATIC_BISECT</code> halves each batch and retry each half until all * the records are processed or there is one failed message left in the batch.</p> */ inline void SetOnPartialBatchItemFailure(const OnPartialBatchItemFailureStreams& value) { m_onPartialBatchItemFailureHasBeenSet = true; m_onPartialBatchItemFailure = value; } /** * <p>(Streams only) Define how to handle item process failures. * <code>AUTOMATIC_BISECT</code> halves each batch and retry each half until all * the records are processed or there is one failed message left in the batch.</p> */ inline void SetOnPartialBatchItemFailure(OnPartialBatchItemFailureStreams&& value) { m_onPartialBatchItemFailureHasBeenSet = true; m_onPartialBatchItemFailure = std::move(value); } /** * <p>(Streams only) Define how to handle item process failures. * <code>AUTOMATIC_BISECT</code> halves each batch and retry each half until all * the records are processed or there is one failed message left in the batch.</p> */ inline UpdatePipeSourceKinesisStreamParameters& WithOnPartialBatchItemFailure(const OnPartialBatchItemFailureStreams& value) { SetOnPartialBatchItemFailure(value); return *this;} /** * <p>(Streams only) Define how to handle item process failures. * <code>AUTOMATIC_BISECT</code> halves each batch and retry each half until all * the records are processed or there is one failed message left in the batch.</p> */ inline UpdatePipeSourceKinesisStreamParameters& WithOnPartialBatchItemFailure(OnPartialBatchItemFailureStreams&& value) { SetOnPartialBatchItemFailure(std::move(value)); return *this;} /** * <p>(Streams only) The number of batches to process concurrently from each shard. * The default value is 1.</p> */ inline int GetParallelizationFactor() const{ return m_parallelizationFactor; } /** * <p>(Streams only) The number of batches to process concurrently from each shard. * The default value is 1.</p> */ inline bool ParallelizationFactorHasBeenSet() const { return m_parallelizationFactorHasBeenSet; } /** * <p>(Streams only) The number of batches to process concurrently from each shard. * The default value is 1.</p> */ inline void SetParallelizationFactor(int value) { m_parallelizationFactorHasBeenSet = true; m_parallelizationFactor = value; } /** * <p>(Streams only) The number of batches to process concurrently from each shard. * The default value is 1.</p> */ inline UpdatePipeSourceKinesisStreamParameters& WithParallelizationFactor(int value) { SetParallelizationFactor(value); return *this;} private: int m_batchSize; bool m_batchSizeHasBeenSet = false; DeadLetterConfig m_deadLetterConfig; bool m_deadLetterConfigHasBeenSet = false; int m_maximumBatchingWindowInSeconds; bool m_maximumBatchingWindowInSecondsHasBeenSet = false; int m_maximumRecordAgeInSeconds; bool m_maximumRecordAgeInSecondsHasBeenSet = false; int m_maximumRetryAttempts; bool m_maximumRetryAttemptsHasBeenSet = false; OnPartialBatchItemFailureStreams m_onPartialBatchItemFailure; bool m_onPartialBatchItemFailureHasBeenSet = false; int m_parallelizationFactor; bool m_parallelizationFactorHasBeenSet = false; }; } // namespace Model } // namespace Pipes } // namespace Aws