Struct aws_sdk_pipes::types::builders::UpdatePipeSourceKinesisStreamParametersBuilder

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

A builder for UpdatePipeSourceKinesisStreamParameters.

Implementations

impl UpdatePipeSourceKinesisStreamParametersBuilder

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

Consumes the builder and constructs a UpdatePipeSourceKinesisStreamParameters.

Trait Implementations

impl Clone for UpdatePipeSourceKinesisStreamParametersBuilder

fn clone(&self) -> UpdatePipeSourceKinesisStreamParametersBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for UpdatePipeSourceKinesisStreamParametersBuilder

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

Formats the value using the given formatter.

impl Default for UpdatePipeSourceKinesisStreamParametersBuilder

fn default() -> UpdatePipeSourceKinesisStreamParametersBuilder

Returns the “default value” for a type.

impl PartialEq for UpdatePipeSourceKinesisStreamParametersBuilder

fn eq(&self, other: &UpdatePipeSourceKinesisStreamParametersBuilder) -> 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 UpdatePipeSourceKinesisStreamParametersBuilder