PipeSourceKinesisStreamParameters.h

 
#pragma once
#include <aws/core/utils/DateTime.h>
#include <aws/pipes/Pipes_EXPORTS.h>
#include <aws/pipes/model/DeadLetterConfig.h>
#include <aws/pipes/model/KinesisStreamStartPosition.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 {
 
class PipeSourceKinesisStreamParameters {
 public:
  AWS_PIPES_API PipeSourceKinesisStreamParameters() = default;
  AWS_PIPES_API PipeSourceKinesisStreamParameters(Aws::Utils::Json::JsonView jsonValue);
  AWS_PIPES_API PipeSourceKinesisStreamParameters& operator=(Aws::Utils::Json::JsonView jsonValue);
  AWS_PIPES_API Aws::Utils::Json::JsonValue Jsonize() const;
 
 
  inline int GetBatchSize() const { return m_batchSize; }
  inline bool BatchSizeHasBeenSet() const { return m_batchSizeHasBeenSet; }
  inline void SetBatchSize(int value) {
    m_batchSizeHasBeenSet = true;
    m_batchSize = value;
  }
  inline PipeSourceKinesisStreamParameters& WithBatchSize(int value) {
    SetBatchSize(value);
    return *this;
  }
 
 
  inline const DeadLetterConfig& GetDeadLetterConfig() const { return m_deadLetterConfig; }
  inline bool DeadLetterConfigHasBeenSet() const { return m_deadLetterConfigHasBeenSet; }
  template <typename DeadLetterConfigT = DeadLetterConfig>
  void SetDeadLetterConfig(DeadLetterConfigT&& value) {
    m_deadLetterConfigHasBeenSet = true;
    m_deadLetterConfig = std::forward<DeadLetterConfigT>(value);
  }
  template <typename DeadLetterConfigT = DeadLetterConfig>
  PipeSourceKinesisStreamParameters& WithDeadLetterConfig(DeadLetterConfigT&& value) {
    SetDeadLetterConfig(std::forward<DeadLetterConfigT>(value));
    return *this;
  }
 
 
  inline OnPartialBatchItemFailureStreams GetOnPartialBatchItemFailure() const { return m_onPartialBatchItemFailure; }
  inline bool OnPartialBatchItemFailureHasBeenSet() const { return m_onPartialBatchItemFailureHasBeenSet; }
  inline void SetOnPartialBatchItemFailure(OnPartialBatchItemFailureStreams value) {
    m_onPartialBatchItemFailureHasBeenSet = true;
    m_onPartialBatchItemFailure = value;
  }
  inline PipeSourceKinesisStreamParameters& WithOnPartialBatchItemFailure(OnPartialBatchItemFailureStreams value) {
    SetOnPartialBatchItemFailure(value);
    return *this;
  }
 
 
  inline int GetMaximumBatchingWindowInSeconds() const { return m_maximumBatchingWindowInSeconds; }
  inline bool MaximumBatchingWindowInSecondsHasBeenSet() const { return m_maximumBatchingWindowInSecondsHasBeenSet; }
  inline void SetMaximumBatchingWindowInSeconds(int value) {
    m_maximumBatchingWindowInSecondsHasBeenSet = true;
    m_maximumBatchingWindowInSeconds = value;
  }
  inline PipeSourceKinesisStreamParameters& WithMaximumBatchingWindowInSeconds(int value) {
    SetMaximumBatchingWindowInSeconds(value);
    return *this;
  }
 
 
  inline int GetMaximumRecordAgeInSeconds() const { return m_maximumRecordAgeInSeconds; }
  inline bool MaximumRecordAgeInSecondsHasBeenSet() const { return m_maximumRecordAgeInSecondsHasBeenSet; }
  inline void SetMaximumRecordAgeInSeconds(int value) {
    m_maximumRecordAgeInSecondsHasBeenSet = true;
    m_maximumRecordAgeInSeconds = value;
  }
  inline PipeSourceKinesisStreamParameters& WithMaximumRecordAgeInSeconds(int value) {
    SetMaximumRecordAgeInSeconds(value);
    return *this;
  }
 
 
  inline int GetMaximumRetryAttempts() const { return m_maximumRetryAttempts; }
  inline bool MaximumRetryAttemptsHasBeenSet() const { return m_maximumRetryAttemptsHasBeenSet; }
  inline void SetMaximumRetryAttempts(int value) {
    m_maximumRetryAttemptsHasBeenSet = true;
    m_maximumRetryAttempts = value;
  }
  inline PipeSourceKinesisStreamParameters& WithMaximumRetryAttempts(int value) {
    SetMaximumRetryAttempts(value);
    return *this;
  }
 
 
  inline int GetParallelizationFactor() const { return m_parallelizationFactor; }
  inline bool ParallelizationFactorHasBeenSet() const { return m_parallelizationFactorHasBeenSet; }
  inline void SetParallelizationFactor(int value) {
    m_parallelizationFactorHasBeenSet = true;
    m_parallelizationFactor = value;
  }
  inline PipeSourceKinesisStreamParameters& WithParallelizationFactor(int value) {
    SetParallelizationFactor(value);
    return *this;
  }
 
 
  inline KinesisStreamStartPosition GetStartingPosition() const { return m_startingPosition; }
  inline bool StartingPositionHasBeenSet() const { return m_startingPositionHasBeenSet; }
  inline void SetStartingPosition(KinesisStreamStartPosition value) {
    m_startingPositionHasBeenSet = true;
    m_startingPosition = value;
  }
  inline PipeSourceKinesisStreamParameters& WithStartingPosition(KinesisStreamStartPosition value) {
    SetStartingPosition(value);
    return *this;
  }
 
 
  inline const Aws::Utils::DateTime& GetStartingPositionTimestamp() const { return m_startingPositionTimestamp; }
  inline bool StartingPositionTimestampHasBeenSet() const { return m_startingPositionTimestampHasBeenSet; }
  template <typename StartingPositionTimestampT = Aws::Utils::DateTime>
  void SetStartingPositionTimestamp(StartingPositionTimestampT&& value) {
    m_startingPositionTimestampHasBeenSet = true;
    m_startingPositionTimestamp = std::forward<StartingPositionTimestampT>(value);
  }
  template <typename StartingPositionTimestampT = Aws::Utils::DateTime>
  PipeSourceKinesisStreamParameters& WithStartingPositionTimestamp(StartingPositionTimestampT&& value) {
    SetStartingPositionTimestamp(std::forward<StartingPositionTimestampT>(value));
    return *this;
  }
 private:
  int m_batchSize{0};
 
  DeadLetterConfig m_deadLetterConfig;
 
  OnPartialBatchItemFailureStreams m_onPartialBatchItemFailure{OnPartialBatchItemFailureStreams::NOT_SET};
 
  int m_maximumBatchingWindowInSeconds{0};
 
  int m_maximumRecordAgeInSeconds{0};
 
  int m_maximumRetryAttempts{0};
 
  int m_parallelizationFactor{0};
 
  KinesisStreamStartPosition m_startingPosition{KinesisStreamStartPosition::NOT_SET};
 
  Aws::Utils::DateTime m_startingPositionTimestamp{};
  bool m_batchSizeHasBeenSet = false;
  bool m_deadLetterConfigHasBeenSet = false;
  bool m_onPartialBatchItemFailureHasBeenSet = false;
  bool m_maximumBatchingWindowInSecondsHasBeenSet = false;
  bool m_maximumRecordAgeInSecondsHasBeenSet = false;
  bool m_maximumRetryAttemptsHasBeenSet = false;
  bool m_parallelizationFactorHasBeenSet = false;
  bool m_startingPositionHasBeenSet = false;
  bool m_startingPositionTimestampHasBeenSet = false;
};
 
}  // namespace Model
}  // namespace Pipes
}  // namespace Aws