pub struct EventSourceMapping {Show 20 fields
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>,
}Fields§
§uuid: String§event_source_arn: String§function_arn: String§batch_size: u32§enabled: boolStored 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: StringLast poll result, surfaced via Get/List for diagnostics.
“OK”, “PROBLEM:
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.
Trait Implementations§
Source§impl Clone for EventSourceMapping
impl Clone for EventSourceMapping
Source§fn clone(&self) -> EventSourceMapping
fn clone(&self) -> EventSourceMapping
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for EventSourceMapping
impl RefUnwindSafe for EventSourceMapping
impl Send for EventSourceMapping
impl Sync for EventSourceMapping
impl Unpin for EventSourceMapping
impl UnsafeUnpin for EventSourceMapping
impl UnwindSafe for EventSourceMapping
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more