Struct rusoto_lambda::EventSourceMappingConfiguration

pub struct EventSourceMappingConfiguration {

    pub batch_size: Option<i64>,
    pub bisect_batch_on_function_error: Option<bool>,
    pub destination_config: Option<DestinationConfig>,
    pub event_source_arn: Option<String>,
    pub function_arn: Option<String>,
    pub function_response_types: Option<Vec<String>>,
    pub last_modified: Option<f64>,
    pub last_processing_result: Option<String>,
    pub maximum_batching_window_in_seconds: Option<i64>,
    pub maximum_record_age_in_seconds: Option<i64>,
    pub maximum_retry_attempts: Option<i64>,
    pub parallelization_factor: Option<i64>,
    pub queues: Option<Vec<String>>,
    pub self_managed_event_source: Option<SelfManagedEventSource>,
    pub source_access_configurations: Option<Vec<SourceAccessConfiguration>>,
    pub starting_position: Option<String>,
    pub starting_position_timestamp: Option<f64>,
    pub state: Option<String>,
    pub state_transition_reason: Option<String>,
    pub topics: Option<Vec<String>>,
    pub tumbling_window_in_seconds: Option<i64>,
    pub uuid: Option<String>,
}

A mapping between an AWS resource and an AWS Lambda function. See CreateEventSourceMapping for details.

Fields

batch_size: Option<i64>

The maximum number of items to retrieve in a single batch.

bisect_batch_on_function_error: Option<bool>

(Streams) If the function returns an error, split the batch in two and retry. The default value is false.

destination_config: Option<DestinationConfig>

(Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.

event_source_arn: Option<String>

The Amazon Resource Name (ARN) of the event source.

function_arn: Option<String>

The ARN of the Lambda function.

function_response_types: Option<Vec<String>>

(Streams) A list of current response type enums applied to the event source mapping.

last_modified: Option<f64>

The date that the event source mapping was last updated, or its state changed.

last_processing_result: Option<String>

The result of the last AWS Lambda invocation of your Lambda function.

maximum_batching_window_in_seconds: Option<i64>

(Streams and SQS standard queues) The maximum amount of time to gather records before invoking the function, in seconds. The default value is zero.

maximum_record_age_in_seconds: Option<i64>

(Streams) Discard records older than the specified age. The default value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires.

maximum_retry_attempts: Option<i64>

(Streams) Discard records after the specified number of retries. The default value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires.

parallelization_factor: Option<i64>

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

queues: Option<Vec<String>>

(MQ) The name of the Amazon MQ broker destination queue to consume.

self_managed_event_source: Option<SelfManagedEventSource>

The Self-Managed Apache Kafka cluster for your event source.

source_access_configurations: Option<Vec<SourceAccessConfiguration>>

An array of the authentication protocol, or the VPC components to secure your event source.

starting_position: Option<String>

The position in a stream from which to start reading. Required for Amazon Kinesis, Amazon DynamoDB, and Amazon MSK Streams sources. AT_TIMESTAMP is only supported for Amazon Kinesis streams.

starting_position_timestamp: Option<f64>

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

state: Option<String>

The state of the event source mapping. It can be one of the following: Creating, Enabling, Enabled, Disabling, Disabled, Updating, or Deleting.

state_transition_reason: Option<String>

Indicates whether the last change to the event source mapping was made by a user, or by the Lambda service.

topics: Option<Vec<String>>

The name of the Kafka topic.

tumbling_window_in_seconds: Option<i64>

(Streams) The duration in seconds of a processing window. The range is between 1 second up to 900 seconds.

uuid: Option<String>

The identifier of the event source mapping.

Trait Implementations

impl Clone for EventSourceMappingConfiguration

fn clone(&self) -> EventSourceMappingConfiguration

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EventSourceMappingConfiguration

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

Formats the value using the given formatter.

impl Default for EventSourceMappingConfiguration

fn default() -> EventSourceMappingConfiguration

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EventSourceMappingConfiguration

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<EventSourceMappingConfiguration> for EventSourceMappingConfiguration

fn eq(&self, other: &EventSourceMappingConfiguration) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &EventSourceMappingConfiguration) -> bool

This method tests for !=.

impl StructuralPartialEq for EventSourceMappingConfiguration