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 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 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 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 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 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 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 starting_position(self, input: KinesisStreamStartPosition) -> Self

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

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

(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 build(self) -> PipeSourceKinesisStreamParameters

Consumes the builder and constructs a PipeSourceKinesisStreamParameters.

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<PipeSourceKinesisStreamParametersBuilder> 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