Struct EventSourceMapping 

pub struct EventSourceMapping {

    pub uuid: String,
    pub event_source_arn: String,
    pub function_arn: String,
    pub batch_size: u32,
    pub enabled: bool,
    pub state: String,
    pub last_modified: String,
    pub starting_position: Option<String>,
    pub starting_position_timestamp: Option<f64>,
    pub maximum_batching_window_in_seconds: u32,
    pub maximum_record_age_in_seconds: Option<i32>,
    pub bisect_batch_on_function_error: bool,
    pub maximum_retry_attempts: Option<i32>,
    pub parallelization_factor: Option<u32>,
    pub tumbling_window_in_seconds: Option<u32>,
    pub filter_criteria: Option<Value>,
    pub destination_on_failure: Option<String>,
    pub function_response_types: Vec<String>,
    pub last_processing_result: String,
    pub shard_iterators: HashMap<String, String>,
    pub tags: HashMap<String, String>,
}

Fields

uuid: String

event_source_arn: String

function_arn: String

batch_size: u32

enabled: bool

Stored for potential future use / admin console.

state: String

last_modified: String

starting_position: Option<String>

TRIM_HORIZON | LATEST | AT_TIMESTAMP — only meaningful for Kinesis/DDB streams.

starting_position_timestamp: Option<f64>

maximum_batching_window_in_seconds: u32

maximum_record_age_in_seconds: Option<i32>

bisect_batch_on_function_error: bool

maximum_retry_attempts: Option<i32>

parallelization_factor: Option<u32>

tumbling_window_in_seconds: Option<u32>

filter_criteria: Option<Value>

Raw FilterCriteria JSON: { “Filters”: [{ “Pattern”: “…” }, …] }.

destination_on_failure: Option<String>

DestinationConfig.OnFailure.Destination ARN — receives failed batches.

function_response_types: Vec<String>

last_processing_result: String

Last poll result, surfaced via Get/List for diagnostics. “OK”, “PROBLEM: ”, or “No records processed”.

shard_iterators: HashMap<String, String>

Per-shard iterator state for Kinesis/DDB-stream pollers so we don’t re-deliver records on every tick. Keyed by shard id.

tags: HashMap<String, String>

Tags attached via TagResource against the ESM ARN.

Trait Implementations

impl Clone for EventSourceMapping

fn clone(&self) -> EventSourceMapping

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventSourceMapping

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

Formats the value using the given formatter.