Struct aws_sdk_pipes::types::builders::PipeSourceKinesisStreamParametersBuilder

#[non_exhaustive]
pub struct PipeSourceKinesisStreamParametersBuilder { /* private fields */ }

A builder for PipeSourceKinesisStreamParameters.

Implementations

impl PipeSourceKinesisStreamParametersBuilder

pub fn batch_size(self, input: i32) -> Self

The maximum number of records to include in each batch.

pub fn set_batch_size(self, input: Option<i32>) -> Self

The maximum number of records to include in each batch.

pub fn get_batch_size(&self) -> &Option<i32>

The maximum number of records to include in each batch.

pub fn dead_letter_config(self, input: DeadLetterConfig) -> Self

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

pub fn set_dead_letter_config(self, input: Option<DeadLetterConfig>) -> Self

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

pub fn get_dead_letter_config(&self) -> &Option<DeadLetterConfig>

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

pub fn on_partial_batch_item_failure( self, input: OnPartialBatchItemFailureStreams ) -> Self

(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.

pub fn set_on_partial_batch_item_failure( self, input: Option<OnPartialBatchItemFailureStreams> ) -> Self

(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.

pub fn get_on_partial_batch_item_failure( &self ) -> &Option<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.

pub fn maximum_batching_window_in_seconds(self, input: i32) -> Self

The maximum length of a time to wait for events.

pub fn set_maximum_batching_window_in_seconds(self, input: Option<i32>) -> Self

The maximum length of a time to wait for events.

pub fn get_maximum_batching_window_in_seconds(&self) -> &Option<i32>

The maximum length of a time to wait for events.

pub fn maximum_record_age_in_seconds(self, input: i32) -> Self

(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.

pub fn set_maximum_record_age_in_seconds(self, input: Option<i32>) -> Self

(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.

pub fn get_maximum_record_age_in_seconds(&self) -> &Option<i32>

(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.

pub fn maximum_retry_attempts(self, input: i32) -> Self

(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.

pub fn set_maximum_retry_attempts(self, input: Option<i32>) -> Self

(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.

pub fn get_maximum_retry_attempts(&self) -> &Option<i32>

(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.

pub fn parallelization_factor(self, input: i32) -> Self

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

pub fn set_parallelization_factor(self, input: Option<i32>) -> Self

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

pub fn get_parallelization_factor(&self) -> &Option<i32>

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

pub fn starting_position(self, input: KinesisStreamStartPosition) -> Self

(Streams only) The position in a stream from which to start reading.

This field is required.

pub fn set_starting_position( self, input: Option<KinesisStreamStartPosition> ) -> Self

(Streams only) The position in a stream from which to start reading.

pub fn get_starting_position(&self) -> &Option<KinesisStreamStartPosition>

(Streams only) The position in a stream from which to start reading.

pub fn starting_position_timestamp(self, input: DateTime) -> Self

With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.

pub fn set_starting_position_timestamp(self, input: Option<DateTime>) -> Self

With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.

pub fn get_starting_position_timestamp(&self) -> &Option<DateTime>

With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.

pub fn build(self) -> Result<PipeSourceKinesisStreamParameters, BuildError>

Consumes the builder and constructs a PipeSourceKinesisStreamParameters. This method will fail if any of the following fields are not set:

• starting_position

Trait Implementations

impl Clone for PipeSourceKinesisStreamParametersBuilder

fn clone(&self) -> PipeSourceKinesisStreamParametersBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipeSourceKinesisStreamParametersBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PipeSourceKinesisStreamParametersBuilder

fn default() -> PipeSourceKinesisStreamParametersBuilder

Returns the “default value” for a type.

impl PartialEq for PipeSourceKinesisStreamParametersBuilder

fn eq(&self, other: &PipeSourceKinesisStreamParametersBuilder) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PipeSourceKinesisStreamParametersBuilder