Struct aws_sdk_pipes::types::PipeSourceDynamoDbStreamParameters

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

The parameters for using a DynamoDB stream as a source.

Implementations

impl PipeSourceDynamoDbStreamParameters

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

The maximum number of records to include in each batch.

pub fn 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 ) -> 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) -> Option<i32>

The maximum length of a time to wait for events.

pub fn 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) -> 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) -> Option<i32>

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

pub fn starting_position(&self) -> Option<&DynamoDbStreamStartPosition>

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

impl PipeSourceDynamoDbStreamParameters

pub fn builder() -> PipeSourceDynamoDbStreamParametersBuilder

Creates a new builder-style object to manufacture PipeSourceDynamoDbStreamParameters.

Trait Implementations

impl Clone for PipeSourceDynamoDbStreamParameters

fn clone(&self) -> PipeSourceDynamoDbStreamParameters

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PipeSourceDynamoDbStreamParameters

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

Formats the value using the given formatter.

impl PartialEq<PipeSourceDynamoDbStreamParameters> for PipeSourceDynamoDbStreamParameters

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