Struct aws_sdk_pipes::model::update_pipe_source_dynamo_db_stream_parameters::Builder

pub struct Builder { /* private fields */ }

A builder for UpdatePipeSourceDynamoDbStreamParameters.

Implementations

impl Builder

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

Consumes the builder and constructs a UpdatePipeSourceDynamoDbStreamParameters.

Trait Implementations

impl Clone for Builder

fn clone(&self) -> Builder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Builder

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

Formats the value using the given formatter.

impl Default for Builder

fn default() -> Builder

Returns the “default value” for a type.

impl PartialEq<Builder> for Builder

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