pub struct TimeWindowProperties {
pub window: Window,
pub state: HashMap<String, String>,
pub shard_id: Option<String>,
pub event_source_arn: Option<String>,
pub is_final_invoke_for_window: bool,
pub is_window_terminated_early: bool,
}
Expand description
TimeWindowProperties
is the object that captures properties that relate to the tumbling windows feature
Kinesis: https://docs.aws.amazon.com/lambda/latest/dg/with-kinesis.html#services-kinesis-windows
DDB: https://docs.aws.amazon.com/lambda/latest/dg/with-ddb.html#services-ddb-windows
Fields§
§window: Window
Time window for the records in the event.
state: HashMap<String, String>
State being built up to this invoke in the time window.
shard_id: Option<String>
Shard id of the records
event_source_arn: Option<String>
The event source ARN of the service that generated the event (eg. DynamoDB or Kinesis)
is_final_invoke_for_window: bool
Set to true for the last invoke of the time window. Subsequent invoke will start a new time window along with a fresh state.
is_window_terminated_early: bool
Set to true if window is terminated prematurely. Subsequent invoke will continue the same window with a fresh state.
Trait Implementations§
source§impl Clone for TimeWindowProperties
impl Clone for TimeWindowProperties
source§fn clone(&self) -> TimeWindowProperties
fn clone(&self) -> TimeWindowProperties
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for TimeWindowProperties
impl Debug for TimeWindowProperties
source§impl Default for TimeWindowProperties
impl Default for TimeWindowProperties
source§fn default() -> TimeWindowProperties
fn default() -> TimeWindowProperties
Returns the “default value” for a type. Read more
source§impl<'de> Deserialize<'de> for TimeWindowProperties
impl<'de> Deserialize<'de> for TimeWindowProperties
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl PartialEq for TimeWindowProperties
impl PartialEq for TimeWindowProperties
source§fn eq(&self, other: &TimeWindowProperties) -> bool
fn eq(&self, other: &TimeWindowProperties) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.source§impl Serialize for TimeWindowProperties
impl Serialize for TimeWindowProperties
impl Eq for TimeWindowProperties
impl StructuralPartialEq for TimeWindowProperties
Auto Trait Implementations§
impl Freeze for TimeWindowProperties
impl RefUnwindSafe for TimeWindowProperties
impl Send for TimeWindowProperties
impl Sync for TimeWindowProperties
impl Unpin for TimeWindowProperties
impl UnwindSafe for TimeWindowProperties
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