Struct aws_sdk_pipes::model::PipeSourceKinesisStreamParameters

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

The parameters for using a Kinesis stream as a source.

Implementations

impl PipeSourceKinesisStreamParameters

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<&KinesisStreamStartPosition>

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

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

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

impl PipeSourceKinesisStreamParameters

pub fn builder() -> Builder

Creates a new builder-style object to manufacture PipeSourceKinesisStreamParameters.

Trait Implementations

impl Clone for PipeSourceKinesisStreamParameters

fn clone(&self) -> PipeSourceKinesisStreamParameters

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PipeSourceKinesisStreamParameters

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

Formats the value using the given formatter.

impl PartialEq<PipeSourceKinesisStreamParameters> for PipeSourceKinesisStreamParameters

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