pub struct Builder { /* private fields */ }Expand description
A builder for EventSourceMappingConfiguration.
Implementations§
source§impl Builder
impl Builder
sourcepub fn uuid(self, input: impl Into<String>) -> Self
pub fn uuid(self, input: impl Into<String>) -> Self
The identifier of the event source mapping.
sourcepub fn set_uuid(self, input: Option<String>) -> Self
pub fn set_uuid(self, input: Option<String>) -> Self
The identifier of the event source mapping.
Examples found in repository?
src/json_deser.rs (lines 10960-10966)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn starting_position(self, input: EventSourcePosition) -> Self
pub fn starting_position(self, input: EventSourcePosition) -> Self
The position in a stream from which to start reading. Required for Amazon Kinesis, Amazon DynamoDB, and Amazon MSK stream sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams.
sourcepub fn set_starting_position(self, input: Option<EventSourcePosition>) -> Self
pub fn set_starting_position(self, input: Option<EventSourcePosition>) -> Self
The position in a stream from which to start reading. Required for Amazon Kinesis, Amazon DynamoDB, and Amazon MSK stream sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams.
Examples found in repository?
src/json_deser.rs (lines 10969-10979)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn starting_position_timestamp(self, input: DateTime) -> Self
pub fn starting_position_timestamp(self, input: DateTime) -> Self
With StartingPosition set to AT_TIMESTAMP, the time from which to start reading.
sourcepub fn set_starting_position_timestamp(self, input: Option<DateTime>) -> Self
pub fn set_starting_position_timestamp(self, input: Option<DateTime>) -> Self
With StartingPosition set to AT_TIMESTAMP, the time from which to start reading.
Examples found in repository?
src/json_deser.rs (lines 10982-10987)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn batch_size(self, input: i32) -> Self
pub fn batch_size(self, input: i32) -> Self
The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).
Default value: Varies by service. For Amazon SQS, the default is 10. For all other services, the default is 100.
Related setting: When you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
sourcepub fn set_batch_size(self, input: Option<i32>) -> Self
pub fn set_batch_size(self, input: Option<i32>) -> Self
The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).
Default value: Varies by service. For Amazon SQS, the default is 10. For all other services, the default is 100.
Related setting: When you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
Examples found in repository?
src/json_deser.rs (lines 10990-10996)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn maximum_batching_window_in_seconds(self, input: i32) -> Self
pub fn maximum_batching_window_in_seconds(self, input: i32) -> Self
(Streams and Amazon SQS standard queues) The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function.
Default: 0
Related setting: When you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
sourcepub fn set_maximum_batching_window_in_seconds(self, input: Option<i32>) -> Self
pub fn set_maximum_batching_window_in_seconds(self, input: Option<i32>) -> Self
(Streams and Amazon SQS standard queues) The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function.
Default: 0
Related setting: When you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
Examples found in repository?
src/json_deser.rs (lines 10999-11005)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn parallelization_factor(self, input: i32) -> Self
pub fn parallelization_factor(self, input: i32) -> Self
(Streams only) The number of batches to process concurrently from each shard. The default value is 1.
sourcepub fn set_parallelization_factor(self, input: Option<i32>) -> Self
pub fn set_parallelization_factor(self, input: Option<i32>) -> Self
(Streams only) The number of batches to process concurrently from each shard. The default value is 1.
Examples found in repository?
src/json_deser.rs (lines 11008-11014)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn event_source_arn(self, input: impl Into<String>) -> Self
pub fn event_source_arn(self, input: impl Into<String>) -> Self
The Amazon Resource Name (ARN) of the event source.
sourcepub fn set_event_source_arn(self, input: Option<String>) -> Self
pub fn set_event_source_arn(self, input: Option<String>) -> Self
The Amazon Resource Name (ARN) of the event source.
Examples found in repository?
src/json_deser.rs (lines 11017-11023)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn filter_criteria(self, input: FilterCriteria) -> Self
pub fn filter_criteria(self, input: FilterCriteria) -> Self
(Streams and Amazon SQS) An object that defines the filter criteria that determine whether Lambda should process an event. For more information, see Lambda event filtering.
sourcepub fn set_filter_criteria(self, input: Option<FilterCriteria>) -> Self
pub fn set_filter_criteria(self, input: Option<FilterCriteria>) -> Self
(Streams and Amazon SQS) An object that defines the filter criteria that determine whether Lambda should process an event. For more information, see Lambda event filtering.
Examples found in repository?
src/json_deser.rs (lines 11026-11030)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn function_arn(self, input: impl Into<String>) -> Self
pub fn function_arn(self, input: impl Into<String>) -> Self
The ARN of the Lambda function.
sourcepub fn set_function_arn(self, input: Option<String>) -> Self
pub fn set_function_arn(self, input: Option<String>) -> Self
The ARN of the Lambda function.
Examples found in repository?
src/json_deser.rs (lines 11033-11039)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn last_modified(self, input: DateTime) -> Self
pub fn last_modified(self, input: DateTime) -> Self
The date that the event source mapping was last updated or that its state changed.
sourcepub fn set_last_modified(self, input: Option<DateTime>) -> Self
pub fn set_last_modified(self, input: Option<DateTime>) -> Self
The date that the event source mapping was last updated or that its state changed.
Examples found in repository?
src/json_deser.rs (lines 11042-11047)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn last_processing_result(self, input: impl Into<String>) -> Self
pub fn last_processing_result(self, input: impl Into<String>) -> Self
The result of the last Lambda invocation of your function.
sourcepub fn set_last_processing_result(self, input: Option<String>) -> Self
pub fn set_last_processing_result(self, input: Option<String>) -> Self
The result of the last Lambda invocation of your function.
Examples found in repository?
src/json_deser.rs (lines 11050-11056)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn state(self, input: impl Into<String>) -> Self
pub fn state(self, input: impl Into<String>) -> Self
The state of the event source mapping. It can be one of the following: Creating, Enabling, Enabled, Disabling, Disabled, Updating, or Deleting.
sourcepub fn set_state(self, input: Option<String>) -> Self
pub fn set_state(self, input: Option<String>) -> Self
The state of the event source mapping. It can be one of the following: Creating, Enabling, Enabled, Disabling, Disabled, Updating, or Deleting.
Examples found in repository?
src/json_deser.rs (lines 11059-11065)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn state_transition_reason(self, input: impl Into<String>) -> Self
pub fn state_transition_reason(self, input: impl Into<String>) -> Self
Indicates whether a user or Lambda made the last change to the event source mapping.
sourcepub fn set_state_transition_reason(self, input: Option<String>) -> Self
pub fn set_state_transition_reason(self, input: Option<String>) -> Self
Indicates whether a user or Lambda made the last change to the event source mapping.
Examples found in repository?
src/json_deser.rs (lines 11068-11074)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn destination_config(self, input: DestinationConfig) -> Self
pub fn destination_config(self, input: DestinationConfig) -> Self
(Streams only) An Amazon SQS queue or Amazon SNS topic destination for discarded records.
sourcepub fn set_destination_config(self, input: Option<DestinationConfig>) -> Self
pub fn set_destination_config(self, input: Option<DestinationConfig>) -> Self
(Streams only) An Amazon SQS queue or Amazon SNS topic destination for discarded records.
Examples found in repository?
src/json_deser.rs (lines 11077-11079)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn topics(self, input: impl Into<String>) -> Self
pub fn topics(self, input: impl Into<String>) -> Self
Appends an item to topics.
To override the contents of this collection use set_topics.
The name of the Kafka topic.
sourcepub fn set_topics(self, input: Option<Vec<String>>) -> Self
pub fn set_topics(self, input: Option<Vec<String>>) -> Self
The name of the Kafka topic.
Examples found in repository?
src/json_deser.rs (lines 11082-11086)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn queues(self, input: impl Into<String>) -> Self
pub fn queues(self, input: impl Into<String>) -> Self
Appends an item to queues.
To override the contents of this collection use set_queues.
(Amazon MQ) The name of the Amazon MQ broker destination queue to consume.
sourcepub fn set_queues(self, input: Option<Vec<String>>) -> Self
pub fn set_queues(self, input: Option<Vec<String>>) -> Self
(Amazon MQ) The name of the Amazon MQ broker destination queue to consume.
Examples found in repository?
src/json_deser.rs (lines 11089-11093)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn source_access_configurations(
self,
input: SourceAccessConfiguration
) -> Self
pub fn source_access_configurations(
self,
input: SourceAccessConfiguration
) -> Self
Appends an item to source_access_configurations.
To override the contents of this collection use set_source_access_configurations.
An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
sourcepub fn set_source_access_configurations(
self,
input: Option<Vec<SourceAccessConfiguration>>
) -> Self
pub fn set_source_access_configurations(
self,
input: Option<Vec<SourceAccessConfiguration>>
) -> Self
An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
Examples found in repository?
src/json_deser.rs (lines 11096-11098)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn self_managed_event_source(self, input: SelfManagedEventSource) -> Self
pub fn self_managed_event_source(self, input: SelfManagedEventSource) -> Self
The self-managed Apache Kafka cluster for your event source.
sourcepub fn set_self_managed_event_source(
self,
input: Option<SelfManagedEventSource>
) -> Self
pub fn set_self_managed_event_source(
self,
input: Option<SelfManagedEventSource>
) -> Self
The self-managed Apache Kafka cluster for your event source.
Examples found in repository?
src/json_deser.rs (lines 11101-11103)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn maximum_record_age_in_seconds(self, input: i32) -> Self
pub fn maximum_record_age_in_seconds(self, input: i32) -> Self
(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, Lambda never discards old records.
sourcepub fn set_maximum_record_age_in_seconds(self, input: Option<i32>) -> Self
pub fn set_maximum_record_age_in_seconds(self, input: Option<i32>) -> Self
(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, Lambda never discards old records.
Examples found in repository?
src/json_deser.rs (lines 11106-11112)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn bisect_batch_on_function_error(self, input: bool) -> Self
pub fn bisect_batch_on_function_error(self, input: bool) -> Self
(Streams only) If the function returns an error, split the batch in two and retry. The default value is false.
sourcepub fn set_bisect_batch_on_function_error(self, input: Option<bool>) -> Self
pub fn set_bisect_batch_on_function_error(self, input: Option<bool>) -> Self
(Streams only) If the function returns an error, split the batch in two and retry. The default value is false.
Examples found in repository?
src/json_deser.rs (lines 11115-11119)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn maximum_retry_attempts(self, input: i32) -> Self
pub fn maximum_retry_attempts(self, input: i32) -> Self
(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, Lambda retries failed records until the record expires in the event source.
sourcepub fn set_maximum_retry_attempts(self, input: Option<i32>) -> Self
pub fn set_maximum_retry_attempts(self, input: Option<i32>) -> Self
(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, Lambda retries failed records until the record expires in the event source.
Examples found in repository?
src/json_deser.rs (lines 11122-11128)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn tumbling_window_in_seconds(self, input: i32) -> Self
pub fn tumbling_window_in_seconds(self, input: i32) -> Self
(Streams only) The duration in seconds of a processing window. The range is 1–900 seconds.
sourcepub fn set_tumbling_window_in_seconds(self, input: Option<i32>) -> Self
pub fn set_tumbling_window_in_seconds(self, input: Option<i32>) -> Self
(Streams only) The duration in seconds of a processing window. The range is 1–900 seconds.
Examples found in repository?
src/json_deser.rs (lines 11131-11137)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn function_response_types(self, input: FunctionResponseType) -> Self
pub fn function_response_types(self, input: FunctionResponseType) -> Self
Appends an item to function_response_types.
To override the contents of this collection use set_function_response_types.
(Streams and Amazon SQS) A list of current response type enums applied to the event source mapping.
sourcepub fn set_function_response_types(
self,
input: Option<Vec<FunctionResponseType>>
) -> Self
pub fn set_function_response_types(
self,
input: Option<Vec<FunctionResponseType>>
) -> Self
(Streams and Amazon SQS) A list of current response type enums applied to the event source mapping.
Examples found in repository?
src/json_deser.rs (lines 11140-11142)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn amazon_managed_kafka_event_source_config(
self,
input: AmazonManagedKafkaEventSourceConfig
) -> Self
pub fn amazon_managed_kafka_event_source_config(
self,
input: AmazonManagedKafkaEventSourceConfig
) -> Self
Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
sourcepub fn set_amazon_managed_kafka_event_source_config(
self,
input: Option<AmazonManagedKafkaEventSourceConfig>
) -> Self
pub fn set_amazon_managed_kafka_event_source_config(
self,
input: Option<AmazonManagedKafkaEventSourceConfig>
) -> Self
Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
Examples found in repository?
src/json_deser.rs (lines 11145-11147)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn self_managed_kafka_event_source_config(
self,
input: SelfManagedKafkaEventSourceConfig
) -> Self
pub fn self_managed_kafka_event_source_config(
self,
input: SelfManagedKafkaEventSourceConfig
) -> Self
Specific configuration settings for a self-managed Apache Kafka event source.
sourcepub fn set_self_managed_kafka_event_source_config(
self,
input: Option<SelfManagedKafkaEventSourceConfig>
) -> Self
pub fn set_self_managed_kafka_event_source_config(
self,
input: Option<SelfManagedKafkaEventSourceConfig>
) -> Self
Specific configuration settings for a self-managed Apache Kafka event source.
Examples found in repository?
src/json_deser.rs (lines 11150-11152)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}sourcepub fn build(self) -> EventSourceMappingConfiguration
pub fn build(self) -> EventSourceMappingConfiguration
Consumes the builder and constructs a EventSourceMappingConfiguration.
Examples found in repository?
src/json_deser.rs (line 11167)
10935 10936 10937 10938 10939 10940 10941 10942 10943 10944 10945 10946 10947 10948 10949 10950 10951 10952 10953 10954 10955 10956 10957 10958 10959 10960 10961 10962 10963 10964 10965 10966 10967 10968 10969 10970 10971 10972 10973 10974 10975 10976 10977 10978 10979 10980 10981 10982 10983 10984 10985 10986 10987 10988 10989 10990 10991 10992 10993 10994 10995 10996 10997 10998 10999 11000 11001 11002 11003 11004 11005 11006 11007 11008 11009 11010 11011 11012 11013 11014 11015 11016 11017 11018 11019 11020 11021 11022 11023 11024 11025 11026 11027 11028 11029 11030 11031 11032 11033 11034 11035 11036 11037 11038 11039 11040 11041 11042 11043 11044 11045 11046 11047 11048 11049 11050 11051 11052 11053 11054 11055 11056 11057 11058 11059 11060 11061 11062 11063 11064 11065 11066 11067 11068 11069 11070 11071 11072 11073 11074 11075 11076 11077 11078 11079 11080 11081 11082 11083 11084 11085 11086 11087 11088 11089 11090 11091 11092 11093 11094 11095 11096 11097 11098 11099 11100 11101 11102 11103 11104 11105 11106 11107 11108 11109 11110 11111 11112 11113 11114 11115 11116 11117 11118 11119 11120 11121 11122 11123 11124 11125 11126 11127 11128 11129 11130 11131 11132 11133 11134 11135 11136 11137 11138 11139 11140 11141 11142 11143 11144 11145 11146 11147 11148 11149 11150 11151 11152 11153 11154 11155 11156 11157 11158 11159 11160 11161 11162 11163 11164 11165 11166 11167 11168 11169 11170 11171 11172 11173 11174 11175
pub(crate) fn deser_structure_crate_model_event_source_mapping_configuration<'a, I>(
tokens: &mut std::iter::Peekable<I>,
) -> Result<
Option<crate::model::EventSourceMappingConfiguration>,
aws_smithy_json::deserialize::error::DeserializeError,
>
where
I: Iterator<
Item = Result<
aws_smithy_json::deserialize::Token<'a>,
aws_smithy_json::deserialize::error::DeserializeError,
>,
>,
{
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::ValueNull { .. }) => Ok(None),
Some(aws_smithy_json::deserialize::Token::StartObject { .. }) => {
#[allow(unused_mut)]
let mut builder = crate::model::event_source_mapping_configuration::Builder::default();
loop {
match tokens.next().transpose()? {
Some(aws_smithy_json::deserialize::Token::EndObject { .. }) => break,
Some(aws_smithy_json::deserialize::Token::ObjectKey { key, .. }) => {
match key.to_unescaped()?.as_ref() {
"UUID" => {
builder = builder.set_uuid(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StartingPosition" => {
builder = builder.set_starting_position(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| {
s.to_unescaped().map(|u| {
crate::model::EventSourcePosition::from(u.as_ref())
})
})
.transpose()?,
);
}
"StartingPositionTimestamp" => {
builder = builder.set_starting_position_timestamp(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"BatchSize" => {
builder = builder.set_batch_size(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"MaximumBatchingWindowInSeconds" => {
builder = builder.set_maximum_batching_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"ParallelizationFactor" => {
builder = builder.set_parallelization_factor(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"EventSourceArn" => {
builder = builder.set_event_source_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"FilterCriteria" => {
builder = builder.set_filter_criteria(
crate::json_deser::deser_structure_crate_model_filter_criteria(
tokens,
)?,
);
}
"FunctionArn" => {
builder = builder.set_function_arn(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"LastModified" => {
builder = builder.set_last_modified(
aws_smithy_json::deserialize::token::expect_timestamp_or_null(
tokens.next(),
aws_smithy_types::date_time::Format::EpochSeconds,
)?,
);
}
"LastProcessingResult" => {
builder = builder.set_last_processing_result(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"State" => {
builder = builder.set_state(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"StateTransitionReason" => {
builder = builder.set_state_transition_reason(
aws_smithy_json::deserialize::token::expect_string_or_null(
tokens.next(),
)?
.map(|s| s.to_unescaped().map(|u| u.into_owned()))
.transpose()?,
);
}
"DestinationConfig" => {
builder = builder.set_destination_config(
crate::json_deser::deser_structure_crate_model_destination_config(tokens)?
);
}
"Topics" => {
builder = builder.set_topics(
crate::json_deser::deser_list_com_amazonaws_lambda_topics(
tokens,
)?,
);
}
"Queues" => {
builder = builder.set_queues(
crate::json_deser::deser_list_com_amazonaws_lambda_queues(
tokens,
)?,
);
}
"SourceAccessConfigurations" => {
builder = builder.set_source_access_configurations(
crate::json_deser::deser_list_com_amazonaws_lambda_source_access_configurations(tokens)?
);
}
"SelfManagedEventSource" => {
builder = builder.set_self_managed_event_source(
crate::json_deser::deser_structure_crate_model_self_managed_event_source(tokens)?
);
}
"MaximumRecordAgeInSeconds" => {
builder = builder.set_maximum_record_age_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"BisectBatchOnFunctionError" => {
builder = builder.set_bisect_batch_on_function_error(
aws_smithy_json::deserialize::token::expect_bool_or_null(
tokens.next(),
)?,
);
}
"MaximumRetryAttempts" => {
builder = builder.set_maximum_retry_attempts(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"TumblingWindowInSeconds" => {
builder = builder.set_tumbling_window_in_seconds(
aws_smithy_json::deserialize::token::expect_number_or_null(
tokens.next(),
)?
.map(i32::try_from)
.transpose()?,
);
}
"FunctionResponseTypes" => {
builder = builder.set_function_response_types(
crate::json_deser::deser_list_com_amazonaws_lambda_function_response_type_list(tokens)?
);
}
"AmazonManagedKafkaEventSourceConfig" => {
builder = builder.set_amazon_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_amazon_managed_kafka_event_source_config(tokens)?
);
}
"SelfManagedKafkaEventSourceConfig" => {
builder = builder.set_self_managed_kafka_event_source_config(
crate::json_deser::deser_structure_crate_model_self_managed_kafka_event_source_config(tokens)?
);
}
_ => aws_smithy_json::deserialize::token::skip_value(tokens)?,
}
}
other => {
return Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(format!(
"expected object key or end object, found: {:?}",
other
)),
)
}
}
}
Ok(Some(builder.build()))
}
_ => Err(
aws_smithy_json::deserialize::error::DeserializeError::custom(
"expected start object or null",
),
),
}
}