1use std::error::Error;
14use std::fmt;
15
16use async_trait::async_trait;
17use rusoto_core::credential::ProvideAwsCredentials;
18use rusoto_core::region;
19use rusoto_core::request::{BufferedHttpResponse, DispatchSignedRequest};
20use rusoto_core::{Client, RusotoError};
21
22use rusoto_core::param::{Params, ServiceParams};
23use rusoto_core::proto;
24use rusoto_core::signature::SignedRequest;
25#[allow(unused_imports)]
26use serde::{Deserialize, Serialize};
27use serde_json;
28#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
30#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
31pub struct AccountLimit {
32 #[serde(rename = "CodeSizeUnzipped")]
34 #[serde(skip_serializing_if = "Option::is_none")]
35 pub code_size_unzipped: Option<i64>,
36 #[serde(rename = "CodeSizeZipped")]
38 #[serde(skip_serializing_if = "Option::is_none")]
39 pub code_size_zipped: Option<i64>,
40 #[serde(rename = "ConcurrentExecutions")]
42 #[serde(skip_serializing_if = "Option::is_none")]
43 pub concurrent_executions: Option<i64>,
44 #[serde(rename = "TotalCodeSize")]
46 #[serde(skip_serializing_if = "Option::is_none")]
47 pub total_code_size: Option<i64>,
48 #[serde(rename = "UnreservedConcurrentExecutions")]
50 #[serde(skip_serializing_if = "Option::is_none")]
51 pub unreserved_concurrent_executions: Option<i64>,
52}
53
54#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
56#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
57pub struct AccountUsage {
58 #[serde(rename = "FunctionCount")]
60 #[serde(skip_serializing_if = "Option::is_none")]
61 pub function_count: Option<i64>,
62 #[serde(rename = "TotalCodeSize")]
64 #[serde(skip_serializing_if = "Option::is_none")]
65 pub total_code_size: Option<i64>,
66}
67
68#[derive(Clone, Debug, Default, PartialEq, Serialize)]
69#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
70pub struct AddLayerVersionPermissionRequest {
71 #[serde(rename = "Action")]
73 pub action: String,
74 #[serde(rename = "LayerName")]
76 pub layer_name: String,
77 #[serde(rename = "OrganizationId")]
79 #[serde(skip_serializing_if = "Option::is_none")]
80 pub organization_id: Option<String>,
81 #[serde(rename = "Principal")]
83 pub principal: String,
84 #[serde(rename = "RevisionId")]
86 #[serde(skip_serializing_if = "Option::is_none")]
87 pub revision_id: Option<String>,
88 #[serde(rename = "StatementId")]
90 pub statement_id: String,
91 #[serde(rename = "VersionNumber")]
93 pub version_number: i64,
94}
95
96#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
97#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
98pub struct AddLayerVersionPermissionResponse {
99 #[serde(rename = "RevisionId")]
101 #[serde(skip_serializing_if = "Option::is_none")]
102 pub revision_id: Option<String>,
103 #[serde(rename = "Statement")]
105 #[serde(skip_serializing_if = "Option::is_none")]
106 pub statement: Option<String>,
107}
108
109#[derive(Clone, Debug, Default, PartialEq, Serialize)]
110#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
111pub struct AddPermissionRequest {
112 #[serde(rename = "Action")]
114 pub action: String,
115 #[serde(rename = "EventSourceToken")]
117 #[serde(skip_serializing_if = "Option::is_none")]
118 pub event_source_token: Option<String>,
119 #[serde(rename = "FunctionName")]
121 pub function_name: String,
122 #[serde(rename = "Principal")]
124 pub principal: String,
125 #[serde(rename = "Qualifier")]
127 #[serde(skip_serializing_if = "Option::is_none")]
128 pub qualifier: Option<String>,
129 #[serde(rename = "RevisionId")]
131 #[serde(skip_serializing_if = "Option::is_none")]
132 pub revision_id: Option<String>,
133 #[serde(rename = "SourceAccount")]
135 #[serde(skip_serializing_if = "Option::is_none")]
136 pub source_account: Option<String>,
137 #[serde(rename = "SourceArn")]
139 #[serde(skip_serializing_if = "Option::is_none")]
140 pub source_arn: Option<String>,
141 #[serde(rename = "StatementId")]
143 pub statement_id: String,
144}
145
146#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
147#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
148pub struct AddPermissionResponse {
149 #[serde(rename = "Statement")]
151 #[serde(skip_serializing_if = "Option::is_none")]
152 pub statement: Option<String>,
153}
154
155#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
157#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
158pub struct AliasConfiguration {
159 #[serde(rename = "AliasArn")]
161 #[serde(skip_serializing_if = "Option::is_none")]
162 pub alias_arn: Option<String>,
163 #[serde(rename = "Description")]
165 #[serde(skip_serializing_if = "Option::is_none")]
166 pub description: Option<String>,
167 #[serde(rename = "FunctionVersion")]
169 #[serde(skip_serializing_if = "Option::is_none")]
170 pub function_version: Option<String>,
171 #[serde(rename = "Name")]
173 #[serde(skip_serializing_if = "Option::is_none")]
174 pub name: Option<String>,
175 #[serde(rename = "RevisionId")]
177 #[serde(skip_serializing_if = "Option::is_none")]
178 pub revision_id: Option<String>,
179 #[serde(rename = "RoutingConfig")]
181 #[serde(skip_serializing_if = "Option::is_none")]
182 pub routing_config: Option<AliasRoutingConfiguration>,
183}
184
185#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
187pub struct AliasRoutingConfiguration {
188 #[serde(rename = "AdditionalVersionWeights")]
190 #[serde(skip_serializing_if = "Option::is_none")]
191 pub additional_version_weights: Option<::std::collections::HashMap<String, f64>>,
192}
193
194#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
195#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
196pub struct Concurrency {
197 #[serde(rename = "ReservedConcurrentExecutions")]
199 #[serde(skip_serializing_if = "Option::is_none")]
200 pub reserved_concurrent_executions: Option<i64>,
201}
202
203#[derive(Clone, Debug, Default, PartialEq, Serialize)]
204#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
205pub struct CreateAliasRequest {
206 #[serde(rename = "Description")]
208 #[serde(skip_serializing_if = "Option::is_none")]
209 pub description: Option<String>,
210 #[serde(rename = "FunctionName")]
212 pub function_name: String,
213 #[serde(rename = "FunctionVersion")]
215 pub function_version: String,
216 #[serde(rename = "Name")]
218 pub name: String,
219 #[serde(rename = "RoutingConfig")]
221 #[serde(skip_serializing_if = "Option::is_none")]
222 pub routing_config: Option<AliasRoutingConfiguration>,
223}
224
225#[derive(Clone, Debug, Default, PartialEq, Serialize)]
226#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
227pub struct CreateEventSourceMappingRequest {
228 #[serde(rename = "BatchSize")]
230 #[serde(skip_serializing_if = "Option::is_none")]
231 pub batch_size: Option<i64>,
232 #[serde(rename = "BisectBatchOnFunctionError")]
234 #[serde(skip_serializing_if = "Option::is_none")]
235 pub bisect_batch_on_function_error: Option<bool>,
236 #[serde(rename = "DestinationConfig")]
238 #[serde(skip_serializing_if = "Option::is_none")]
239 pub destination_config: Option<DestinationConfig>,
240 #[serde(rename = "Enabled")]
242 #[serde(skip_serializing_if = "Option::is_none")]
243 pub enabled: Option<bool>,
244 #[serde(rename = "EventSourceArn")]
246 pub event_source_arn: String,
247 #[serde(rename = "FunctionName")]
249 pub function_name: String,
250 #[serde(rename = "MaximumBatchingWindowInSeconds")]
252 #[serde(skip_serializing_if = "Option::is_none")]
253 pub maximum_batching_window_in_seconds: Option<i64>,
254 #[serde(rename = "MaximumRecordAgeInSeconds")]
256 #[serde(skip_serializing_if = "Option::is_none")]
257 pub maximum_record_age_in_seconds: Option<i64>,
258 #[serde(rename = "MaximumRetryAttempts")]
260 #[serde(skip_serializing_if = "Option::is_none")]
261 pub maximum_retry_attempts: Option<i64>,
262 #[serde(rename = "ParallelizationFactor")]
264 #[serde(skip_serializing_if = "Option::is_none")]
265 pub parallelization_factor: Option<i64>,
266 #[serde(rename = "StartingPosition")]
268 #[serde(skip_serializing_if = "Option::is_none")]
269 pub starting_position: Option<String>,
270 #[serde(rename = "StartingPositionTimestamp")]
272 #[serde(skip_serializing_if = "Option::is_none")]
273 pub starting_position_timestamp: Option<f64>,
274}
275
276#[derive(Clone, Debug, Default, PartialEq, Serialize)]
277#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
278pub struct CreateFunctionRequest {
279 #[serde(rename = "Code")]
281 pub code: FunctionCode,
282 #[serde(rename = "DeadLetterConfig")]
284 #[serde(skip_serializing_if = "Option::is_none")]
285 pub dead_letter_config: Option<DeadLetterConfig>,
286 #[serde(rename = "Description")]
288 #[serde(skip_serializing_if = "Option::is_none")]
289 pub description: Option<String>,
290 #[serde(rename = "Environment")]
292 #[serde(skip_serializing_if = "Option::is_none")]
293 pub environment: Option<Environment>,
294 #[serde(rename = "FileSystemConfigs")]
296 #[serde(skip_serializing_if = "Option::is_none")]
297 pub file_system_configs: Option<Vec<FileSystemConfig>>,
298 #[serde(rename = "FunctionName")]
300 pub function_name: String,
301 #[serde(rename = "Handler")]
303 pub handler: String,
304 #[serde(rename = "KMSKeyArn")]
306 #[serde(skip_serializing_if = "Option::is_none")]
307 pub kms_key_arn: Option<String>,
308 #[serde(rename = "Layers")]
310 #[serde(skip_serializing_if = "Option::is_none")]
311 pub layers: Option<Vec<String>>,
312 #[serde(rename = "MemorySize")]
314 #[serde(skip_serializing_if = "Option::is_none")]
315 pub memory_size: Option<i64>,
316 #[serde(rename = "Publish")]
318 #[serde(skip_serializing_if = "Option::is_none")]
319 pub publish: Option<bool>,
320 #[serde(rename = "Role")]
322 pub role: String,
323 #[serde(rename = "Runtime")]
325 pub runtime: String,
326 #[serde(rename = "Tags")]
328 #[serde(skip_serializing_if = "Option::is_none")]
329 pub tags: Option<::std::collections::HashMap<String, String>>,
330 #[serde(rename = "Timeout")]
332 #[serde(skip_serializing_if = "Option::is_none")]
333 pub timeout: Option<i64>,
334 #[serde(rename = "TracingConfig")]
336 #[serde(skip_serializing_if = "Option::is_none")]
337 pub tracing_config: Option<TracingConfig>,
338 #[serde(rename = "VpcConfig")]
340 #[serde(skip_serializing_if = "Option::is_none")]
341 pub vpc_config: Option<VpcConfig>,
342}
343
344#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
346pub struct DeadLetterConfig {
347 #[serde(rename = "TargetArn")]
349 #[serde(skip_serializing_if = "Option::is_none")]
350 pub target_arn: Option<String>,
351}
352
353#[derive(Clone, Debug, Default, PartialEq, Serialize)]
354#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
355pub struct DeleteAliasRequest {
356 #[serde(rename = "FunctionName")]
358 pub function_name: String,
359 #[serde(rename = "Name")]
361 pub name: String,
362}
363
364#[derive(Clone, Debug, Default, PartialEq, Serialize)]
365#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
366pub struct DeleteEventSourceMappingRequest {
367 #[serde(rename = "UUID")]
369 pub uuid: String,
370}
371
372#[derive(Clone, Debug, Default, PartialEq, Serialize)]
373#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
374pub struct DeleteFunctionConcurrencyRequest {
375 #[serde(rename = "FunctionName")]
377 pub function_name: String,
378}
379
380#[derive(Clone, Debug, Default, PartialEq, Serialize)]
381#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
382pub struct DeleteFunctionEventInvokeConfigRequest {
383 #[serde(rename = "FunctionName")]
385 pub function_name: String,
386 #[serde(rename = "Qualifier")]
388 #[serde(skip_serializing_if = "Option::is_none")]
389 pub qualifier: Option<String>,
390}
391
392#[derive(Clone, Debug, Default, PartialEq, Serialize)]
393#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
394pub struct DeleteFunctionRequest {
395 #[serde(rename = "FunctionName")]
397 pub function_name: String,
398 #[serde(rename = "Qualifier")]
400 #[serde(skip_serializing_if = "Option::is_none")]
401 pub qualifier: Option<String>,
402}
403
404#[derive(Clone, Debug, Default, PartialEq, Serialize)]
405#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
406pub struct DeleteLayerVersionRequest {
407 #[serde(rename = "LayerName")]
409 pub layer_name: String,
410 #[serde(rename = "VersionNumber")]
412 pub version_number: i64,
413}
414
415#[derive(Clone, Debug, Default, PartialEq, Serialize)]
416#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
417pub struct DeleteProvisionedConcurrencyConfigRequest {
418 #[serde(rename = "FunctionName")]
420 pub function_name: String,
421 #[serde(rename = "Qualifier")]
423 pub qualifier: String,
424}
425
426#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
428pub struct DestinationConfig {
429 #[serde(rename = "OnFailure")]
431 #[serde(skip_serializing_if = "Option::is_none")]
432 pub on_failure: Option<OnFailure>,
433 #[serde(rename = "OnSuccess")]
435 #[serde(skip_serializing_if = "Option::is_none")]
436 pub on_success: Option<OnSuccess>,
437}
438
439#[derive(Clone, Debug, Default, PartialEq, Serialize)]
441#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
442pub struct Environment {
443 #[serde(rename = "Variables")]
445 #[serde(skip_serializing_if = "Option::is_none")]
446 pub variables: Option<::std::collections::HashMap<String, String>>,
447}
448
449#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
451#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
452pub struct EnvironmentError {
453 #[serde(rename = "ErrorCode")]
455 #[serde(skip_serializing_if = "Option::is_none")]
456 pub error_code: Option<String>,
457 #[serde(rename = "Message")]
459 #[serde(skip_serializing_if = "Option::is_none")]
460 pub message: Option<String>,
461}
462
463#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
465#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
466pub struct EnvironmentResponse {
467 #[serde(rename = "Error")]
469 #[serde(skip_serializing_if = "Option::is_none")]
470 pub error: Option<EnvironmentError>,
471 #[serde(rename = "Variables")]
473 #[serde(skip_serializing_if = "Option::is_none")]
474 pub variables: Option<::std::collections::HashMap<String, String>>,
475}
476
477#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
479#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
480pub struct EventSourceMappingConfiguration {
481 #[serde(rename = "BatchSize")]
483 #[serde(skip_serializing_if = "Option::is_none")]
484 pub batch_size: Option<i64>,
485 #[serde(rename = "BisectBatchOnFunctionError")]
487 #[serde(skip_serializing_if = "Option::is_none")]
488 pub bisect_batch_on_function_error: Option<bool>,
489 #[serde(rename = "DestinationConfig")]
491 #[serde(skip_serializing_if = "Option::is_none")]
492 pub destination_config: Option<DestinationConfig>,
493 #[serde(rename = "EventSourceArn")]
495 #[serde(skip_serializing_if = "Option::is_none")]
496 pub event_source_arn: Option<String>,
497 #[serde(rename = "FunctionArn")]
499 #[serde(skip_serializing_if = "Option::is_none")]
500 pub function_arn: Option<String>,
501 #[serde(rename = "LastModified")]
503 #[serde(skip_serializing_if = "Option::is_none")]
504 pub last_modified: Option<f64>,
505 #[serde(rename = "LastProcessingResult")]
507 #[serde(skip_serializing_if = "Option::is_none")]
508 pub last_processing_result: Option<String>,
509 #[serde(rename = "MaximumBatchingWindowInSeconds")]
511 #[serde(skip_serializing_if = "Option::is_none")]
512 pub maximum_batching_window_in_seconds: Option<i64>,
513 #[serde(rename = "MaximumRecordAgeInSeconds")]
515 #[serde(skip_serializing_if = "Option::is_none")]
516 pub maximum_record_age_in_seconds: Option<i64>,
517 #[serde(rename = "MaximumRetryAttempts")]
519 #[serde(skip_serializing_if = "Option::is_none")]
520 pub maximum_retry_attempts: Option<i64>,
521 #[serde(rename = "ParallelizationFactor")]
523 #[serde(skip_serializing_if = "Option::is_none")]
524 pub parallelization_factor: Option<i64>,
525 #[serde(rename = "State")]
527 #[serde(skip_serializing_if = "Option::is_none")]
528 pub state: Option<String>,
529 #[serde(rename = "StateTransitionReason")]
531 #[serde(skip_serializing_if = "Option::is_none")]
532 pub state_transition_reason: Option<String>,
533 #[serde(rename = "UUID")]
535 #[serde(skip_serializing_if = "Option::is_none")]
536 pub uuid: Option<String>,
537}
538
539#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
541pub struct FileSystemConfig {
542 #[serde(rename = "Arn")]
544 pub arn: String,
545 #[serde(rename = "LocalMountPath")]
547 pub local_mount_path: String,
548}
549
550#[derive(Clone, Debug, Default, PartialEq, Serialize)]
552#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
553pub struct FunctionCode {
554 #[serde(rename = "S3Bucket")]
556 #[serde(skip_serializing_if = "Option::is_none")]
557 pub s3_bucket: Option<String>,
558 #[serde(rename = "S3Key")]
560 #[serde(skip_serializing_if = "Option::is_none")]
561 pub s3_key: Option<String>,
562 #[serde(rename = "S3ObjectVersion")]
564 #[serde(skip_serializing_if = "Option::is_none")]
565 pub s3_object_version: Option<String>,
566 #[serde(rename = "ZipFile")]
568 #[serde(
569 deserialize_with = "::rusoto_core::serialization::SerdeBlob::deserialize_blob",
570 serialize_with = "::rusoto_core::serialization::SerdeBlob::serialize_blob",
571 default
572 )]
573 #[serde(skip_serializing_if = "Option::is_none")]
574 pub zip_file: Option<bytes::Bytes>,
575}
576
577#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
579#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
580pub struct FunctionCodeLocation {
581 #[serde(rename = "Location")]
583 #[serde(skip_serializing_if = "Option::is_none")]
584 pub location: Option<String>,
585 #[serde(rename = "RepositoryType")]
587 #[serde(skip_serializing_if = "Option::is_none")]
588 pub repository_type: Option<String>,
589}
590
591#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
593#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
594pub struct FunctionConfiguration {
595 #[serde(rename = "CodeSha256")]
597 #[serde(skip_serializing_if = "Option::is_none")]
598 pub code_sha_256: Option<String>,
599 #[serde(rename = "CodeSize")]
601 #[serde(skip_serializing_if = "Option::is_none")]
602 pub code_size: Option<i64>,
603 #[serde(rename = "DeadLetterConfig")]
605 #[serde(skip_serializing_if = "Option::is_none")]
606 pub dead_letter_config: Option<DeadLetterConfig>,
607 #[serde(rename = "Description")]
609 #[serde(skip_serializing_if = "Option::is_none")]
610 pub description: Option<String>,
611 #[serde(rename = "Environment")]
613 #[serde(skip_serializing_if = "Option::is_none")]
614 pub environment: Option<EnvironmentResponse>,
615 #[serde(rename = "FileSystemConfigs")]
617 #[serde(skip_serializing_if = "Option::is_none")]
618 pub file_system_configs: Option<Vec<FileSystemConfig>>,
619 #[serde(rename = "FunctionArn")]
621 #[serde(skip_serializing_if = "Option::is_none")]
622 pub function_arn: Option<String>,
623 #[serde(rename = "FunctionName")]
625 #[serde(skip_serializing_if = "Option::is_none")]
626 pub function_name: Option<String>,
627 #[serde(rename = "Handler")]
629 #[serde(skip_serializing_if = "Option::is_none")]
630 pub handler: Option<String>,
631 #[serde(rename = "KMSKeyArn")]
633 #[serde(skip_serializing_if = "Option::is_none")]
634 pub kms_key_arn: Option<String>,
635 #[serde(rename = "LastModified")]
637 #[serde(skip_serializing_if = "Option::is_none")]
638 pub last_modified: Option<String>,
639 #[serde(rename = "LastUpdateStatus")]
641 #[serde(skip_serializing_if = "Option::is_none")]
642 pub last_update_status: Option<String>,
643 #[serde(rename = "LastUpdateStatusReason")]
645 #[serde(skip_serializing_if = "Option::is_none")]
646 pub last_update_status_reason: Option<String>,
647 #[serde(rename = "LastUpdateStatusReasonCode")]
649 #[serde(skip_serializing_if = "Option::is_none")]
650 pub last_update_status_reason_code: Option<String>,
651 #[serde(rename = "Layers")]
653 #[serde(skip_serializing_if = "Option::is_none")]
654 pub layers: Option<Vec<Layer>>,
655 #[serde(rename = "MasterArn")]
657 #[serde(skip_serializing_if = "Option::is_none")]
658 pub master_arn: Option<String>,
659 #[serde(rename = "MemorySize")]
661 #[serde(skip_serializing_if = "Option::is_none")]
662 pub memory_size: Option<i64>,
663 #[serde(rename = "RevisionId")]
665 #[serde(skip_serializing_if = "Option::is_none")]
666 pub revision_id: Option<String>,
667 #[serde(rename = "Role")]
669 #[serde(skip_serializing_if = "Option::is_none")]
670 pub role: Option<String>,
671 #[serde(rename = "Runtime")]
673 #[serde(skip_serializing_if = "Option::is_none")]
674 pub runtime: Option<String>,
675 #[serde(rename = "State")]
677 #[serde(skip_serializing_if = "Option::is_none")]
678 pub state: Option<String>,
679 #[serde(rename = "StateReason")]
681 #[serde(skip_serializing_if = "Option::is_none")]
682 pub state_reason: Option<String>,
683 #[serde(rename = "StateReasonCode")]
685 #[serde(skip_serializing_if = "Option::is_none")]
686 pub state_reason_code: Option<String>,
687 #[serde(rename = "Timeout")]
689 #[serde(skip_serializing_if = "Option::is_none")]
690 pub timeout: Option<i64>,
691 #[serde(rename = "TracingConfig")]
693 #[serde(skip_serializing_if = "Option::is_none")]
694 pub tracing_config: Option<TracingConfigResponse>,
695 #[serde(rename = "Version")]
697 #[serde(skip_serializing_if = "Option::is_none")]
698 pub version: Option<String>,
699 #[serde(rename = "VpcConfig")]
701 #[serde(skip_serializing_if = "Option::is_none")]
702 pub vpc_config: Option<VpcConfigResponse>,
703}
704
705#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
706#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
707pub struct FunctionEventInvokeConfig {
708 #[serde(rename = "DestinationConfig")]
710 #[serde(skip_serializing_if = "Option::is_none")]
711 pub destination_config: Option<DestinationConfig>,
712 #[serde(rename = "FunctionArn")]
714 #[serde(skip_serializing_if = "Option::is_none")]
715 pub function_arn: Option<String>,
716 #[serde(rename = "LastModified")]
718 #[serde(skip_serializing_if = "Option::is_none")]
719 pub last_modified: Option<f64>,
720 #[serde(rename = "MaximumEventAgeInSeconds")]
722 #[serde(skip_serializing_if = "Option::is_none")]
723 pub maximum_event_age_in_seconds: Option<i64>,
724 #[serde(rename = "MaximumRetryAttempts")]
726 #[serde(skip_serializing_if = "Option::is_none")]
727 pub maximum_retry_attempts: Option<i64>,
728}
729
730#[derive(Clone, Debug, Default, PartialEq, Serialize)]
731#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
732pub struct GetAccountSettingsRequest {}
733
734#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
735#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
736pub struct GetAccountSettingsResponse {
737 #[serde(rename = "AccountLimit")]
739 #[serde(skip_serializing_if = "Option::is_none")]
740 pub account_limit: Option<AccountLimit>,
741 #[serde(rename = "AccountUsage")]
743 #[serde(skip_serializing_if = "Option::is_none")]
744 pub account_usage: Option<AccountUsage>,
745}
746
747#[derive(Clone, Debug, Default, PartialEq, Serialize)]
748#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
749pub struct GetAliasRequest {
750 #[serde(rename = "FunctionName")]
752 pub function_name: String,
753 #[serde(rename = "Name")]
755 pub name: String,
756}
757
758#[derive(Clone, Debug, Default, PartialEq, Serialize)]
759#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
760pub struct GetEventSourceMappingRequest {
761 #[serde(rename = "UUID")]
763 pub uuid: String,
764}
765
766#[derive(Clone, Debug, Default, PartialEq, Serialize)]
767#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
768pub struct GetFunctionConcurrencyRequest {
769 #[serde(rename = "FunctionName")]
771 pub function_name: String,
772}
773
774#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
775#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
776pub struct GetFunctionConcurrencyResponse {
777 #[serde(rename = "ReservedConcurrentExecutions")]
779 #[serde(skip_serializing_if = "Option::is_none")]
780 pub reserved_concurrent_executions: Option<i64>,
781}
782
783#[derive(Clone, Debug, Default, PartialEq, Serialize)]
784#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
785pub struct GetFunctionConfigurationRequest {
786 #[serde(rename = "FunctionName")]
788 pub function_name: String,
789 #[serde(rename = "Qualifier")]
791 #[serde(skip_serializing_if = "Option::is_none")]
792 pub qualifier: Option<String>,
793}
794
795#[derive(Clone, Debug, Default, PartialEq, Serialize)]
796#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
797pub struct GetFunctionEventInvokeConfigRequest {
798 #[serde(rename = "FunctionName")]
800 pub function_name: String,
801 #[serde(rename = "Qualifier")]
803 #[serde(skip_serializing_if = "Option::is_none")]
804 pub qualifier: Option<String>,
805}
806
807#[derive(Clone, Debug, Default, PartialEq, Serialize)]
808#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
809pub struct GetFunctionRequest {
810 #[serde(rename = "FunctionName")]
812 pub function_name: String,
813 #[serde(rename = "Qualifier")]
815 #[serde(skip_serializing_if = "Option::is_none")]
816 pub qualifier: Option<String>,
817}
818
819#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
820#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
821pub struct GetFunctionResponse {
822 #[serde(rename = "Code")]
824 #[serde(skip_serializing_if = "Option::is_none")]
825 pub code: Option<FunctionCodeLocation>,
826 #[serde(rename = "Concurrency")]
828 #[serde(skip_serializing_if = "Option::is_none")]
829 pub concurrency: Option<Concurrency>,
830 #[serde(rename = "Configuration")]
832 #[serde(skip_serializing_if = "Option::is_none")]
833 pub configuration: Option<FunctionConfiguration>,
834 #[serde(rename = "Tags")]
836 #[serde(skip_serializing_if = "Option::is_none")]
837 pub tags: Option<::std::collections::HashMap<String, String>>,
838}
839
840#[derive(Clone, Debug, Default, PartialEq, Serialize)]
841#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
842pub struct GetLayerVersionByArnRequest {
843 #[serde(rename = "Arn")]
845 pub arn: String,
846}
847
848#[derive(Clone, Debug, Default, PartialEq, Serialize)]
849#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
850pub struct GetLayerVersionPolicyRequest {
851 #[serde(rename = "LayerName")]
853 pub layer_name: String,
854 #[serde(rename = "VersionNumber")]
856 pub version_number: i64,
857}
858
859#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
860#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
861pub struct GetLayerVersionPolicyResponse {
862 #[serde(rename = "Policy")]
864 #[serde(skip_serializing_if = "Option::is_none")]
865 pub policy: Option<String>,
866 #[serde(rename = "RevisionId")]
868 #[serde(skip_serializing_if = "Option::is_none")]
869 pub revision_id: Option<String>,
870}
871
872#[derive(Clone, Debug, Default, PartialEq, Serialize)]
873#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
874pub struct GetLayerVersionRequest {
875 #[serde(rename = "LayerName")]
877 pub layer_name: String,
878 #[serde(rename = "VersionNumber")]
880 pub version_number: i64,
881}
882
883#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
884#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
885pub struct GetLayerVersionResponse {
886 #[serde(rename = "CompatibleRuntimes")]
888 #[serde(skip_serializing_if = "Option::is_none")]
889 pub compatible_runtimes: Option<Vec<String>>,
890 #[serde(rename = "Content")]
892 #[serde(skip_serializing_if = "Option::is_none")]
893 pub content: Option<LayerVersionContentOutput>,
894 #[serde(rename = "CreatedDate")]
896 #[serde(skip_serializing_if = "Option::is_none")]
897 pub created_date: Option<String>,
898 #[serde(rename = "Description")]
900 #[serde(skip_serializing_if = "Option::is_none")]
901 pub description: Option<String>,
902 #[serde(rename = "LayerArn")]
904 #[serde(skip_serializing_if = "Option::is_none")]
905 pub layer_arn: Option<String>,
906 #[serde(rename = "LayerVersionArn")]
908 #[serde(skip_serializing_if = "Option::is_none")]
909 pub layer_version_arn: Option<String>,
910 #[serde(rename = "LicenseInfo")]
912 #[serde(skip_serializing_if = "Option::is_none")]
913 pub license_info: Option<String>,
914 #[serde(rename = "Version")]
916 #[serde(skip_serializing_if = "Option::is_none")]
917 pub version: Option<i64>,
918}
919
920#[derive(Clone, Debug, Default, PartialEq, Serialize)]
921#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
922pub struct GetPolicyRequest {
923 #[serde(rename = "FunctionName")]
925 pub function_name: String,
926 #[serde(rename = "Qualifier")]
928 #[serde(skip_serializing_if = "Option::is_none")]
929 pub qualifier: Option<String>,
930}
931
932#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
933#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
934pub struct GetPolicyResponse {
935 #[serde(rename = "Policy")]
937 #[serde(skip_serializing_if = "Option::is_none")]
938 pub policy: Option<String>,
939 #[serde(rename = "RevisionId")]
941 #[serde(skip_serializing_if = "Option::is_none")]
942 pub revision_id: Option<String>,
943}
944
945#[derive(Clone, Debug, Default, PartialEq, Serialize)]
946#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
947pub struct GetProvisionedConcurrencyConfigRequest {
948 #[serde(rename = "FunctionName")]
950 pub function_name: String,
951 #[serde(rename = "Qualifier")]
953 pub qualifier: String,
954}
955
956#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
957#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
958pub struct GetProvisionedConcurrencyConfigResponse {
959 #[serde(rename = "AllocatedProvisionedConcurrentExecutions")]
961 #[serde(skip_serializing_if = "Option::is_none")]
962 pub allocated_provisioned_concurrent_executions: Option<i64>,
963 #[serde(rename = "AvailableProvisionedConcurrentExecutions")]
965 #[serde(skip_serializing_if = "Option::is_none")]
966 pub available_provisioned_concurrent_executions: Option<i64>,
967 #[serde(rename = "LastModified")]
969 #[serde(skip_serializing_if = "Option::is_none")]
970 pub last_modified: Option<String>,
971 #[serde(rename = "RequestedProvisionedConcurrentExecutions")]
973 #[serde(skip_serializing_if = "Option::is_none")]
974 pub requested_provisioned_concurrent_executions: Option<i64>,
975 #[serde(rename = "Status")]
977 #[serde(skip_serializing_if = "Option::is_none")]
978 pub status: Option<String>,
979 #[serde(rename = "StatusReason")]
981 #[serde(skip_serializing_if = "Option::is_none")]
982 pub status_reason: Option<String>,
983}
984
985#[derive(Clone, Debug, Default, PartialEq, Serialize)]
986#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
987pub struct InvocationRequest {
988 #[serde(rename = "ClientContext")]
990 #[serde(skip_serializing_if = "Option::is_none")]
991 pub client_context: Option<String>,
992 #[serde(rename = "FunctionName")]
994 pub function_name: String,
995 #[serde(rename = "InvocationType")]
997 #[serde(skip_serializing_if = "Option::is_none")]
998 pub invocation_type: Option<String>,
999 #[serde(rename = "LogType")]
1001 #[serde(skip_serializing_if = "Option::is_none")]
1002 pub log_type: Option<String>,
1003 #[serde(rename = "Payload")]
1005 #[serde(
1006 deserialize_with = "::rusoto_core::serialization::SerdeBlob::deserialize_blob",
1007 serialize_with = "::rusoto_core::serialization::SerdeBlob::serialize_blob",
1008 default
1009 )]
1010 #[serde(skip_serializing_if = "Option::is_none")]
1011 pub payload: Option<bytes::Bytes>,
1012 #[serde(rename = "Qualifier")]
1014 #[serde(skip_serializing_if = "Option::is_none")]
1015 pub qualifier: Option<String>,
1016}
1017
1018#[derive(Clone, Debug, Default, PartialEq)]
1019pub struct InvocationResponse {
1020 pub executed_version: Option<String>,
1022 pub function_error: Option<String>,
1024 pub log_result: Option<String>,
1026 pub payload: Option<bytes::Bytes>,
1028 pub status_code: Option<i64>,
1030}
1031
1032#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1033#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1034pub struct InvokeAsyncRequest {
1035 #[serde(rename = "FunctionName")]
1037 pub function_name: String,
1038 #[serde(rename = "InvokeArgs")]
1040 #[serde(
1041 deserialize_with = "::rusoto_core::serialization::SerdeBlob::deserialize_blob",
1042 serialize_with = "::rusoto_core::serialization::SerdeBlob::serialize_blob",
1043 default
1044 )]
1045 pub invoke_args: bytes::Bytes,
1046}
1047
1048#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1050#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1051pub struct InvokeAsyncResponse {
1052 #[serde(rename = "Status")]
1054 #[serde(skip_serializing_if = "Option::is_none")]
1055 pub status: Option<i64>,
1056}
1057
1058#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1060#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1061pub struct Layer {
1062 #[serde(rename = "Arn")]
1064 #[serde(skip_serializing_if = "Option::is_none")]
1065 pub arn: Option<String>,
1066 #[serde(rename = "CodeSize")]
1068 #[serde(skip_serializing_if = "Option::is_none")]
1069 pub code_size: Option<i64>,
1070}
1071
1072#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1074#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1075pub struct LayerVersionContentInput {
1076 #[serde(rename = "S3Bucket")]
1078 #[serde(skip_serializing_if = "Option::is_none")]
1079 pub s3_bucket: Option<String>,
1080 #[serde(rename = "S3Key")]
1082 #[serde(skip_serializing_if = "Option::is_none")]
1083 pub s3_key: Option<String>,
1084 #[serde(rename = "S3ObjectVersion")]
1086 #[serde(skip_serializing_if = "Option::is_none")]
1087 pub s3_object_version: Option<String>,
1088 #[serde(rename = "ZipFile")]
1090 #[serde(
1091 deserialize_with = "::rusoto_core::serialization::SerdeBlob::deserialize_blob",
1092 serialize_with = "::rusoto_core::serialization::SerdeBlob::serialize_blob",
1093 default
1094 )]
1095 #[serde(skip_serializing_if = "Option::is_none")]
1096 pub zip_file: Option<bytes::Bytes>,
1097}
1098
1099#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1101#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1102pub struct LayerVersionContentOutput {
1103 #[serde(rename = "CodeSha256")]
1105 #[serde(skip_serializing_if = "Option::is_none")]
1106 pub code_sha_256: Option<String>,
1107 #[serde(rename = "CodeSize")]
1109 #[serde(skip_serializing_if = "Option::is_none")]
1110 pub code_size: Option<i64>,
1111 #[serde(rename = "Location")]
1113 #[serde(skip_serializing_if = "Option::is_none")]
1114 pub location: Option<String>,
1115}
1116
1117#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1119#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1120pub struct LayerVersionsListItem {
1121 #[serde(rename = "CompatibleRuntimes")]
1123 #[serde(skip_serializing_if = "Option::is_none")]
1124 pub compatible_runtimes: Option<Vec<String>>,
1125 #[serde(rename = "CreatedDate")]
1127 #[serde(skip_serializing_if = "Option::is_none")]
1128 pub created_date: Option<String>,
1129 #[serde(rename = "Description")]
1131 #[serde(skip_serializing_if = "Option::is_none")]
1132 pub description: Option<String>,
1133 #[serde(rename = "LayerVersionArn")]
1135 #[serde(skip_serializing_if = "Option::is_none")]
1136 pub layer_version_arn: Option<String>,
1137 #[serde(rename = "LicenseInfo")]
1139 #[serde(skip_serializing_if = "Option::is_none")]
1140 pub license_info: Option<String>,
1141 #[serde(rename = "Version")]
1143 #[serde(skip_serializing_if = "Option::is_none")]
1144 pub version: Option<i64>,
1145}
1146
1147#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1149#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1150pub struct LayersListItem {
1151 #[serde(rename = "LatestMatchingVersion")]
1153 #[serde(skip_serializing_if = "Option::is_none")]
1154 pub latest_matching_version: Option<LayerVersionsListItem>,
1155 #[serde(rename = "LayerArn")]
1157 #[serde(skip_serializing_if = "Option::is_none")]
1158 pub layer_arn: Option<String>,
1159 #[serde(rename = "LayerName")]
1161 #[serde(skip_serializing_if = "Option::is_none")]
1162 pub layer_name: Option<String>,
1163}
1164
1165#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1166#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1167pub struct ListAliasesRequest {
1168 #[serde(rename = "FunctionName")]
1170 pub function_name: String,
1171 #[serde(rename = "FunctionVersion")]
1173 #[serde(skip_serializing_if = "Option::is_none")]
1174 pub function_version: Option<String>,
1175 #[serde(rename = "Marker")]
1177 #[serde(skip_serializing_if = "Option::is_none")]
1178 pub marker: Option<String>,
1179 #[serde(rename = "MaxItems")]
1181 #[serde(skip_serializing_if = "Option::is_none")]
1182 pub max_items: Option<i64>,
1183}
1184
1185#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1186#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1187pub struct ListAliasesResponse {
1188 #[serde(rename = "Aliases")]
1190 #[serde(skip_serializing_if = "Option::is_none")]
1191 pub aliases: Option<Vec<AliasConfiguration>>,
1192 #[serde(rename = "NextMarker")]
1194 #[serde(skip_serializing_if = "Option::is_none")]
1195 pub next_marker: Option<String>,
1196}
1197
1198#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1199#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1200pub struct ListEventSourceMappingsRequest {
1201 #[serde(rename = "EventSourceArn")]
1203 #[serde(skip_serializing_if = "Option::is_none")]
1204 pub event_source_arn: Option<String>,
1205 #[serde(rename = "FunctionName")]
1207 #[serde(skip_serializing_if = "Option::is_none")]
1208 pub function_name: Option<String>,
1209 #[serde(rename = "Marker")]
1211 #[serde(skip_serializing_if = "Option::is_none")]
1212 pub marker: Option<String>,
1213 #[serde(rename = "MaxItems")]
1215 #[serde(skip_serializing_if = "Option::is_none")]
1216 pub max_items: Option<i64>,
1217}
1218
1219#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1220#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1221pub struct ListEventSourceMappingsResponse {
1222 #[serde(rename = "EventSourceMappings")]
1224 #[serde(skip_serializing_if = "Option::is_none")]
1225 pub event_source_mappings: Option<Vec<EventSourceMappingConfiguration>>,
1226 #[serde(rename = "NextMarker")]
1228 #[serde(skip_serializing_if = "Option::is_none")]
1229 pub next_marker: Option<String>,
1230}
1231
1232#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1233#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1234pub struct ListFunctionEventInvokeConfigsRequest {
1235 #[serde(rename = "FunctionName")]
1237 pub function_name: String,
1238 #[serde(rename = "Marker")]
1240 #[serde(skip_serializing_if = "Option::is_none")]
1241 pub marker: Option<String>,
1242 #[serde(rename = "MaxItems")]
1244 #[serde(skip_serializing_if = "Option::is_none")]
1245 pub max_items: Option<i64>,
1246}
1247
1248#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1249#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1250pub struct ListFunctionEventInvokeConfigsResponse {
1251 #[serde(rename = "FunctionEventInvokeConfigs")]
1253 #[serde(skip_serializing_if = "Option::is_none")]
1254 pub function_event_invoke_configs: Option<Vec<FunctionEventInvokeConfig>>,
1255 #[serde(rename = "NextMarker")]
1257 #[serde(skip_serializing_if = "Option::is_none")]
1258 pub next_marker: Option<String>,
1259}
1260
1261#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1262#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1263pub struct ListFunctionsRequest {
1264 #[serde(rename = "FunctionVersion")]
1266 #[serde(skip_serializing_if = "Option::is_none")]
1267 pub function_version: Option<String>,
1268 #[serde(rename = "Marker")]
1270 #[serde(skip_serializing_if = "Option::is_none")]
1271 pub marker: Option<String>,
1272 #[serde(rename = "MasterRegion")]
1274 #[serde(skip_serializing_if = "Option::is_none")]
1275 pub master_region: Option<String>,
1276 #[serde(rename = "MaxItems")]
1278 #[serde(skip_serializing_if = "Option::is_none")]
1279 pub max_items: Option<i64>,
1280}
1281
1282#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1284#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1285pub struct ListFunctionsResponse {
1286 #[serde(rename = "Functions")]
1288 #[serde(skip_serializing_if = "Option::is_none")]
1289 pub functions: Option<Vec<FunctionConfiguration>>,
1290 #[serde(rename = "NextMarker")]
1292 #[serde(skip_serializing_if = "Option::is_none")]
1293 pub next_marker: Option<String>,
1294}
1295
1296#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1297#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1298pub struct ListLayerVersionsRequest {
1299 #[serde(rename = "CompatibleRuntime")]
1301 #[serde(skip_serializing_if = "Option::is_none")]
1302 pub compatible_runtime: Option<String>,
1303 #[serde(rename = "LayerName")]
1305 pub layer_name: String,
1306 #[serde(rename = "Marker")]
1308 #[serde(skip_serializing_if = "Option::is_none")]
1309 pub marker: Option<String>,
1310 #[serde(rename = "MaxItems")]
1312 #[serde(skip_serializing_if = "Option::is_none")]
1313 pub max_items: Option<i64>,
1314}
1315
1316#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1317#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1318pub struct ListLayerVersionsResponse {
1319 #[serde(rename = "LayerVersions")]
1321 #[serde(skip_serializing_if = "Option::is_none")]
1322 pub layer_versions: Option<Vec<LayerVersionsListItem>>,
1323 #[serde(rename = "NextMarker")]
1325 #[serde(skip_serializing_if = "Option::is_none")]
1326 pub next_marker: Option<String>,
1327}
1328
1329#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1330#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1331pub struct ListLayersRequest {
1332 #[serde(rename = "CompatibleRuntime")]
1334 #[serde(skip_serializing_if = "Option::is_none")]
1335 pub compatible_runtime: Option<String>,
1336 #[serde(rename = "Marker")]
1338 #[serde(skip_serializing_if = "Option::is_none")]
1339 pub marker: Option<String>,
1340 #[serde(rename = "MaxItems")]
1342 #[serde(skip_serializing_if = "Option::is_none")]
1343 pub max_items: Option<i64>,
1344}
1345
1346#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1347#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1348pub struct ListLayersResponse {
1349 #[serde(rename = "Layers")]
1351 #[serde(skip_serializing_if = "Option::is_none")]
1352 pub layers: Option<Vec<LayersListItem>>,
1353 #[serde(rename = "NextMarker")]
1355 #[serde(skip_serializing_if = "Option::is_none")]
1356 pub next_marker: Option<String>,
1357}
1358
1359#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1360#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1361pub struct ListProvisionedConcurrencyConfigsRequest {
1362 #[serde(rename = "FunctionName")]
1364 pub function_name: String,
1365 #[serde(rename = "Marker")]
1367 #[serde(skip_serializing_if = "Option::is_none")]
1368 pub marker: Option<String>,
1369 #[serde(rename = "MaxItems")]
1371 #[serde(skip_serializing_if = "Option::is_none")]
1372 pub max_items: Option<i64>,
1373}
1374
1375#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1376#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1377pub struct ListProvisionedConcurrencyConfigsResponse {
1378 #[serde(rename = "NextMarker")]
1380 #[serde(skip_serializing_if = "Option::is_none")]
1381 pub next_marker: Option<String>,
1382 #[serde(rename = "ProvisionedConcurrencyConfigs")]
1384 #[serde(skip_serializing_if = "Option::is_none")]
1385 pub provisioned_concurrency_configs: Option<Vec<ProvisionedConcurrencyConfigListItem>>,
1386}
1387
1388#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1389#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1390pub struct ListTagsRequest {
1391 #[serde(rename = "Resource")]
1393 pub resource: String,
1394}
1395
1396#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1397#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1398pub struct ListTagsResponse {
1399 #[serde(rename = "Tags")]
1401 #[serde(skip_serializing_if = "Option::is_none")]
1402 pub tags: Option<::std::collections::HashMap<String, String>>,
1403}
1404
1405#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1406#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1407pub struct ListVersionsByFunctionRequest {
1408 #[serde(rename = "FunctionName")]
1410 pub function_name: String,
1411 #[serde(rename = "Marker")]
1413 #[serde(skip_serializing_if = "Option::is_none")]
1414 pub marker: Option<String>,
1415 #[serde(rename = "MaxItems")]
1417 #[serde(skip_serializing_if = "Option::is_none")]
1418 pub max_items: Option<i64>,
1419}
1420
1421#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1422#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1423pub struct ListVersionsByFunctionResponse {
1424 #[serde(rename = "NextMarker")]
1426 #[serde(skip_serializing_if = "Option::is_none")]
1427 pub next_marker: Option<String>,
1428 #[serde(rename = "Versions")]
1430 #[serde(skip_serializing_if = "Option::is_none")]
1431 pub versions: Option<Vec<FunctionConfiguration>>,
1432}
1433
1434#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1436pub struct OnFailure {
1437 #[serde(rename = "Destination")]
1439 #[serde(skip_serializing_if = "Option::is_none")]
1440 pub destination: Option<String>,
1441}
1442
1443#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1445pub struct OnSuccess {
1446 #[serde(rename = "Destination")]
1448 #[serde(skip_serializing_if = "Option::is_none")]
1449 pub destination: Option<String>,
1450}
1451
1452#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1454#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1455pub struct ProvisionedConcurrencyConfigListItem {
1456 #[serde(rename = "AllocatedProvisionedConcurrentExecutions")]
1458 #[serde(skip_serializing_if = "Option::is_none")]
1459 pub allocated_provisioned_concurrent_executions: Option<i64>,
1460 #[serde(rename = "AvailableProvisionedConcurrentExecutions")]
1462 #[serde(skip_serializing_if = "Option::is_none")]
1463 pub available_provisioned_concurrent_executions: Option<i64>,
1464 #[serde(rename = "FunctionArn")]
1466 #[serde(skip_serializing_if = "Option::is_none")]
1467 pub function_arn: Option<String>,
1468 #[serde(rename = "LastModified")]
1470 #[serde(skip_serializing_if = "Option::is_none")]
1471 pub last_modified: Option<String>,
1472 #[serde(rename = "RequestedProvisionedConcurrentExecutions")]
1474 #[serde(skip_serializing_if = "Option::is_none")]
1475 pub requested_provisioned_concurrent_executions: Option<i64>,
1476 #[serde(rename = "Status")]
1478 #[serde(skip_serializing_if = "Option::is_none")]
1479 pub status: Option<String>,
1480 #[serde(rename = "StatusReason")]
1482 #[serde(skip_serializing_if = "Option::is_none")]
1483 pub status_reason: Option<String>,
1484}
1485
1486#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1487#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1488pub struct PublishLayerVersionRequest {
1489 #[serde(rename = "CompatibleRuntimes")]
1491 #[serde(skip_serializing_if = "Option::is_none")]
1492 pub compatible_runtimes: Option<Vec<String>>,
1493 #[serde(rename = "Content")]
1495 pub content: LayerVersionContentInput,
1496 #[serde(rename = "Description")]
1498 #[serde(skip_serializing_if = "Option::is_none")]
1499 pub description: Option<String>,
1500 #[serde(rename = "LayerName")]
1502 pub layer_name: String,
1503 #[serde(rename = "LicenseInfo")]
1505 #[serde(skip_serializing_if = "Option::is_none")]
1506 pub license_info: Option<String>,
1507}
1508
1509#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1510#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1511pub struct PublishLayerVersionResponse {
1512 #[serde(rename = "CompatibleRuntimes")]
1514 #[serde(skip_serializing_if = "Option::is_none")]
1515 pub compatible_runtimes: Option<Vec<String>>,
1516 #[serde(rename = "Content")]
1518 #[serde(skip_serializing_if = "Option::is_none")]
1519 pub content: Option<LayerVersionContentOutput>,
1520 #[serde(rename = "CreatedDate")]
1522 #[serde(skip_serializing_if = "Option::is_none")]
1523 pub created_date: Option<String>,
1524 #[serde(rename = "Description")]
1526 #[serde(skip_serializing_if = "Option::is_none")]
1527 pub description: Option<String>,
1528 #[serde(rename = "LayerArn")]
1530 #[serde(skip_serializing_if = "Option::is_none")]
1531 pub layer_arn: Option<String>,
1532 #[serde(rename = "LayerVersionArn")]
1534 #[serde(skip_serializing_if = "Option::is_none")]
1535 pub layer_version_arn: Option<String>,
1536 #[serde(rename = "LicenseInfo")]
1538 #[serde(skip_serializing_if = "Option::is_none")]
1539 pub license_info: Option<String>,
1540 #[serde(rename = "Version")]
1542 #[serde(skip_serializing_if = "Option::is_none")]
1543 pub version: Option<i64>,
1544}
1545
1546#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1547#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1548pub struct PublishVersionRequest {
1549 #[serde(rename = "CodeSha256")]
1551 #[serde(skip_serializing_if = "Option::is_none")]
1552 pub code_sha_256: Option<String>,
1553 #[serde(rename = "Description")]
1555 #[serde(skip_serializing_if = "Option::is_none")]
1556 pub description: Option<String>,
1557 #[serde(rename = "FunctionName")]
1559 pub function_name: String,
1560 #[serde(rename = "RevisionId")]
1562 #[serde(skip_serializing_if = "Option::is_none")]
1563 pub revision_id: Option<String>,
1564}
1565
1566#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1567#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1568pub struct PutFunctionConcurrencyRequest {
1569 #[serde(rename = "FunctionName")]
1571 pub function_name: String,
1572 #[serde(rename = "ReservedConcurrentExecutions")]
1574 pub reserved_concurrent_executions: i64,
1575}
1576
1577#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1578#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1579pub struct PutFunctionEventInvokeConfigRequest {
1580 #[serde(rename = "DestinationConfig")]
1582 #[serde(skip_serializing_if = "Option::is_none")]
1583 pub destination_config: Option<DestinationConfig>,
1584 #[serde(rename = "FunctionName")]
1586 pub function_name: String,
1587 #[serde(rename = "MaximumEventAgeInSeconds")]
1589 #[serde(skip_serializing_if = "Option::is_none")]
1590 pub maximum_event_age_in_seconds: Option<i64>,
1591 #[serde(rename = "MaximumRetryAttempts")]
1593 #[serde(skip_serializing_if = "Option::is_none")]
1594 pub maximum_retry_attempts: Option<i64>,
1595 #[serde(rename = "Qualifier")]
1597 #[serde(skip_serializing_if = "Option::is_none")]
1598 pub qualifier: Option<String>,
1599}
1600
1601#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1602#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1603pub struct PutProvisionedConcurrencyConfigRequest {
1604 #[serde(rename = "FunctionName")]
1606 pub function_name: String,
1607 #[serde(rename = "ProvisionedConcurrentExecutions")]
1609 pub provisioned_concurrent_executions: i64,
1610 #[serde(rename = "Qualifier")]
1612 pub qualifier: String,
1613}
1614
1615#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1616#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1617pub struct PutProvisionedConcurrencyConfigResponse {
1618 #[serde(rename = "AllocatedProvisionedConcurrentExecutions")]
1620 #[serde(skip_serializing_if = "Option::is_none")]
1621 pub allocated_provisioned_concurrent_executions: Option<i64>,
1622 #[serde(rename = "AvailableProvisionedConcurrentExecutions")]
1624 #[serde(skip_serializing_if = "Option::is_none")]
1625 pub available_provisioned_concurrent_executions: Option<i64>,
1626 #[serde(rename = "LastModified")]
1628 #[serde(skip_serializing_if = "Option::is_none")]
1629 pub last_modified: Option<String>,
1630 #[serde(rename = "RequestedProvisionedConcurrentExecutions")]
1632 #[serde(skip_serializing_if = "Option::is_none")]
1633 pub requested_provisioned_concurrent_executions: Option<i64>,
1634 #[serde(rename = "Status")]
1636 #[serde(skip_serializing_if = "Option::is_none")]
1637 pub status: Option<String>,
1638 #[serde(rename = "StatusReason")]
1640 #[serde(skip_serializing_if = "Option::is_none")]
1641 pub status_reason: Option<String>,
1642}
1643
1644#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1645#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1646pub struct RemoveLayerVersionPermissionRequest {
1647 #[serde(rename = "LayerName")]
1649 pub layer_name: String,
1650 #[serde(rename = "RevisionId")]
1652 #[serde(skip_serializing_if = "Option::is_none")]
1653 pub revision_id: Option<String>,
1654 #[serde(rename = "StatementId")]
1656 pub statement_id: String,
1657 #[serde(rename = "VersionNumber")]
1659 pub version_number: i64,
1660}
1661
1662#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1663#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1664pub struct RemovePermissionRequest {
1665 #[serde(rename = "FunctionName")]
1667 pub function_name: String,
1668 #[serde(rename = "Qualifier")]
1670 #[serde(skip_serializing_if = "Option::is_none")]
1671 pub qualifier: Option<String>,
1672 #[serde(rename = "RevisionId")]
1674 #[serde(skip_serializing_if = "Option::is_none")]
1675 pub revision_id: Option<String>,
1676 #[serde(rename = "StatementId")]
1678 pub statement_id: String,
1679}
1680
1681#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1682#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1683pub struct TagResourceRequest {
1684 #[serde(rename = "Resource")]
1686 pub resource: String,
1687 #[serde(rename = "Tags")]
1689 pub tags: ::std::collections::HashMap<String, String>,
1690}
1691
1692#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1694#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1695pub struct TracingConfig {
1696 #[serde(rename = "Mode")]
1698 #[serde(skip_serializing_if = "Option::is_none")]
1699 pub mode: Option<String>,
1700}
1701
1702#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1704#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1705pub struct TracingConfigResponse {
1706 #[serde(rename = "Mode")]
1708 #[serde(skip_serializing_if = "Option::is_none")]
1709 pub mode: Option<String>,
1710}
1711
1712#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1713#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1714pub struct UntagResourceRequest {
1715 #[serde(rename = "Resource")]
1717 pub resource: String,
1718 #[serde(rename = "TagKeys")]
1720 pub tag_keys: Vec<String>,
1721}
1722
1723#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1724#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1725pub struct UpdateAliasRequest {
1726 #[serde(rename = "Description")]
1728 #[serde(skip_serializing_if = "Option::is_none")]
1729 pub description: Option<String>,
1730 #[serde(rename = "FunctionName")]
1732 pub function_name: String,
1733 #[serde(rename = "FunctionVersion")]
1735 #[serde(skip_serializing_if = "Option::is_none")]
1736 pub function_version: Option<String>,
1737 #[serde(rename = "Name")]
1739 pub name: String,
1740 #[serde(rename = "RevisionId")]
1742 #[serde(skip_serializing_if = "Option::is_none")]
1743 pub revision_id: Option<String>,
1744 #[serde(rename = "RoutingConfig")]
1746 #[serde(skip_serializing_if = "Option::is_none")]
1747 pub routing_config: Option<AliasRoutingConfiguration>,
1748}
1749
1750#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1751#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1752pub struct UpdateEventSourceMappingRequest {
1753 #[serde(rename = "BatchSize")]
1755 #[serde(skip_serializing_if = "Option::is_none")]
1756 pub batch_size: Option<i64>,
1757 #[serde(rename = "BisectBatchOnFunctionError")]
1759 #[serde(skip_serializing_if = "Option::is_none")]
1760 pub bisect_batch_on_function_error: Option<bool>,
1761 #[serde(rename = "DestinationConfig")]
1763 #[serde(skip_serializing_if = "Option::is_none")]
1764 pub destination_config: Option<DestinationConfig>,
1765 #[serde(rename = "Enabled")]
1767 #[serde(skip_serializing_if = "Option::is_none")]
1768 pub enabled: Option<bool>,
1769 #[serde(rename = "FunctionName")]
1771 #[serde(skip_serializing_if = "Option::is_none")]
1772 pub function_name: Option<String>,
1773 #[serde(rename = "MaximumBatchingWindowInSeconds")]
1775 #[serde(skip_serializing_if = "Option::is_none")]
1776 pub maximum_batching_window_in_seconds: Option<i64>,
1777 #[serde(rename = "MaximumRecordAgeInSeconds")]
1779 #[serde(skip_serializing_if = "Option::is_none")]
1780 pub maximum_record_age_in_seconds: Option<i64>,
1781 #[serde(rename = "MaximumRetryAttempts")]
1783 #[serde(skip_serializing_if = "Option::is_none")]
1784 pub maximum_retry_attempts: Option<i64>,
1785 #[serde(rename = "ParallelizationFactor")]
1787 #[serde(skip_serializing_if = "Option::is_none")]
1788 pub parallelization_factor: Option<i64>,
1789 #[serde(rename = "UUID")]
1791 pub uuid: String,
1792}
1793
1794#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1795#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1796pub struct UpdateFunctionCodeRequest {
1797 #[serde(rename = "DryRun")]
1799 #[serde(skip_serializing_if = "Option::is_none")]
1800 pub dry_run: Option<bool>,
1801 #[serde(rename = "FunctionName")]
1803 pub function_name: String,
1804 #[serde(rename = "Publish")]
1806 #[serde(skip_serializing_if = "Option::is_none")]
1807 pub publish: Option<bool>,
1808 #[serde(rename = "RevisionId")]
1810 #[serde(skip_serializing_if = "Option::is_none")]
1811 pub revision_id: Option<String>,
1812 #[serde(rename = "S3Bucket")]
1814 #[serde(skip_serializing_if = "Option::is_none")]
1815 pub s3_bucket: Option<String>,
1816 #[serde(rename = "S3Key")]
1818 #[serde(skip_serializing_if = "Option::is_none")]
1819 pub s3_key: Option<String>,
1820 #[serde(rename = "S3ObjectVersion")]
1822 #[serde(skip_serializing_if = "Option::is_none")]
1823 pub s3_object_version: Option<String>,
1824 #[serde(rename = "ZipFile")]
1826 #[serde(
1827 deserialize_with = "::rusoto_core::serialization::SerdeBlob::deserialize_blob",
1828 serialize_with = "::rusoto_core::serialization::SerdeBlob::serialize_blob",
1829 default
1830 )]
1831 #[serde(skip_serializing_if = "Option::is_none")]
1832 pub zip_file: Option<bytes::Bytes>,
1833}
1834
1835#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1836#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1837pub struct UpdateFunctionConfigurationRequest {
1838 #[serde(rename = "DeadLetterConfig")]
1840 #[serde(skip_serializing_if = "Option::is_none")]
1841 pub dead_letter_config: Option<DeadLetterConfig>,
1842 #[serde(rename = "Description")]
1844 #[serde(skip_serializing_if = "Option::is_none")]
1845 pub description: Option<String>,
1846 #[serde(rename = "Environment")]
1848 #[serde(skip_serializing_if = "Option::is_none")]
1849 pub environment: Option<Environment>,
1850 #[serde(rename = "FileSystemConfigs")]
1852 #[serde(skip_serializing_if = "Option::is_none")]
1853 pub file_system_configs: Option<Vec<FileSystemConfig>>,
1854 #[serde(rename = "FunctionName")]
1856 pub function_name: String,
1857 #[serde(rename = "Handler")]
1859 #[serde(skip_serializing_if = "Option::is_none")]
1860 pub handler: Option<String>,
1861 #[serde(rename = "KMSKeyArn")]
1863 #[serde(skip_serializing_if = "Option::is_none")]
1864 pub kms_key_arn: Option<String>,
1865 #[serde(rename = "Layers")]
1867 #[serde(skip_serializing_if = "Option::is_none")]
1868 pub layers: Option<Vec<String>>,
1869 #[serde(rename = "MemorySize")]
1871 #[serde(skip_serializing_if = "Option::is_none")]
1872 pub memory_size: Option<i64>,
1873 #[serde(rename = "RevisionId")]
1875 #[serde(skip_serializing_if = "Option::is_none")]
1876 pub revision_id: Option<String>,
1877 #[serde(rename = "Role")]
1879 #[serde(skip_serializing_if = "Option::is_none")]
1880 pub role: Option<String>,
1881 #[serde(rename = "Runtime")]
1883 #[serde(skip_serializing_if = "Option::is_none")]
1884 pub runtime: Option<String>,
1885 #[serde(rename = "Timeout")]
1887 #[serde(skip_serializing_if = "Option::is_none")]
1888 pub timeout: Option<i64>,
1889 #[serde(rename = "TracingConfig")]
1891 #[serde(skip_serializing_if = "Option::is_none")]
1892 pub tracing_config: Option<TracingConfig>,
1893 #[serde(rename = "VpcConfig")]
1895 #[serde(skip_serializing_if = "Option::is_none")]
1896 pub vpc_config: Option<VpcConfig>,
1897}
1898
1899#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1900#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1901pub struct UpdateFunctionEventInvokeConfigRequest {
1902 #[serde(rename = "DestinationConfig")]
1904 #[serde(skip_serializing_if = "Option::is_none")]
1905 pub destination_config: Option<DestinationConfig>,
1906 #[serde(rename = "FunctionName")]
1908 pub function_name: String,
1909 #[serde(rename = "MaximumEventAgeInSeconds")]
1911 #[serde(skip_serializing_if = "Option::is_none")]
1912 pub maximum_event_age_in_seconds: Option<i64>,
1913 #[serde(rename = "MaximumRetryAttempts")]
1915 #[serde(skip_serializing_if = "Option::is_none")]
1916 pub maximum_retry_attempts: Option<i64>,
1917 #[serde(rename = "Qualifier")]
1919 #[serde(skip_serializing_if = "Option::is_none")]
1920 pub qualifier: Option<String>,
1921}
1922
1923#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1925#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1926pub struct VpcConfig {
1927 #[serde(rename = "SecurityGroupIds")]
1929 #[serde(skip_serializing_if = "Option::is_none")]
1930 pub security_group_ids: Option<Vec<String>>,
1931 #[serde(rename = "SubnetIds")]
1933 #[serde(skip_serializing_if = "Option::is_none")]
1934 pub subnet_ids: Option<Vec<String>>,
1935}
1936
1937#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1939#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1940pub struct VpcConfigResponse {
1941 #[serde(rename = "SecurityGroupIds")]
1943 #[serde(skip_serializing_if = "Option::is_none")]
1944 pub security_group_ids: Option<Vec<String>>,
1945 #[serde(rename = "SubnetIds")]
1947 #[serde(skip_serializing_if = "Option::is_none")]
1948 pub subnet_ids: Option<Vec<String>>,
1949 #[serde(rename = "VpcId")]
1951 #[serde(skip_serializing_if = "Option::is_none")]
1952 pub vpc_id: Option<String>,
1953}
1954
1955#[derive(Debug, PartialEq)]
1957pub enum AddLayerVersionPermissionError {
1958 InvalidParameterValue(String),
1960 PolicyLengthExceeded(String),
1962 PreconditionFailed(String),
1964 ResourceConflict(String),
1966 ResourceNotFound(String),
1968 Service(String),
1970 TooManyRequests(String),
1972}
1973
1974impl AddLayerVersionPermissionError {
1975 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<AddLayerVersionPermissionError> {
1976 if let Some(err) = proto::json::Error::parse_rest(&res) {
1977 match err.typ.as_str() {
1978 "InvalidParameterValueException" => {
1979 return RusotoError::Service(
1980 AddLayerVersionPermissionError::InvalidParameterValue(err.msg),
1981 )
1982 }
1983 "PolicyLengthExceededException" => {
1984 return RusotoError::Service(
1985 AddLayerVersionPermissionError::PolicyLengthExceeded(err.msg),
1986 )
1987 }
1988 "PreconditionFailedException" => {
1989 return RusotoError::Service(
1990 AddLayerVersionPermissionError::PreconditionFailed(err.msg),
1991 )
1992 }
1993 "ResourceConflictException" => {
1994 return RusotoError::Service(AddLayerVersionPermissionError::ResourceConflict(
1995 err.msg,
1996 ))
1997 }
1998 "ResourceNotFoundException" => {
1999 return RusotoError::Service(AddLayerVersionPermissionError::ResourceNotFound(
2000 err.msg,
2001 ))
2002 }
2003 "ServiceException" => {
2004 return RusotoError::Service(AddLayerVersionPermissionError::Service(err.msg))
2005 }
2006 "TooManyRequestsException" => {
2007 return RusotoError::Service(AddLayerVersionPermissionError::TooManyRequests(
2008 err.msg,
2009 ))
2010 }
2011 "ValidationException" => return RusotoError::Validation(err.msg),
2012 _ => {}
2013 }
2014 }
2015 RusotoError::Unknown(res)
2016 }
2017}
2018impl fmt::Display for AddLayerVersionPermissionError {
2019 #[allow(unused_variables)]
2020 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2021 match *self {
2022 AddLayerVersionPermissionError::InvalidParameterValue(ref cause) => {
2023 write!(f, "{}", cause)
2024 }
2025 AddLayerVersionPermissionError::PolicyLengthExceeded(ref cause) => {
2026 write!(f, "{}", cause)
2027 }
2028 AddLayerVersionPermissionError::PreconditionFailed(ref cause) => write!(f, "{}", cause),
2029 AddLayerVersionPermissionError::ResourceConflict(ref cause) => write!(f, "{}", cause),
2030 AddLayerVersionPermissionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2031 AddLayerVersionPermissionError::Service(ref cause) => write!(f, "{}", cause),
2032 AddLayerVersionPermissionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2033 }
2034 }
2035}
2036impl Error for AddLayerVersionPermissionError {}
2037#[derive(Debug, PartialEq)]
2039pub enum AddPermissionError {
2040 InvalidParameterValue(String),
2042 PolicyLengthExceeded(String),
2044 PreconditionFailed(String),
2046 ResourceConflict(String),
2048 ResourceNotFound(String),
2050 Service(String),
2052 TooManyRequests(String),
2054}
2055
2056impl AddPermissionError {
2057 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<AddPermissionError> {
2058 if let Some(err) = proto::json::Error::parse_rest(&res) {
2059 match err.typ.as_str() {
2060 "InvalidParameterValueException" => {
2061 return RusotoError::Service(AddPermissionError::InvalidParameterValue(err.msg))
2062 }
2063 "PolicyLengthExceededException" => {
2064 return RusotoError::Service(AddPermissionError::PolicyLengthExceeded(err.msg))
2065 }
2066 "PreconditionFailedException" => {
2067 return RusotoError::Service(AddPermissionError::PreconditionFailed(err.msg))
2068 }
2069 "ResourceConflictException" => {
2070 return RusotoError::Service(AddPermissionError::ResourceConflict(err.msg))
2071 }
2072 "ResourceNotFoundException" => {
2073 return RusotoError::Service(AddPermissionError::ResourceNotFound(err.msg))
2074 }
2075 "ServiceException" => {
2076 return RusotoError::Service(AddPermissionError::Service(err.msg))
2077 }
2078 "TooManyRequestsException" => {
2079 return RusotoError::Service(AddPermissionError::TooManyRequests(err.msg))
2080 }
2081 "ValidationException" => return RusotoError::Validation(err.msg),
2082 _ => {}
2083 }
2084 }
2085 RusotoError::Unknown(res)
2086 }
2087}
2088impl fmt::Display for AddPermissionError {
2089 #[allow(unused_variables)]
2090 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2091 match *self {
2092 AddPermissionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2093 AddPermissionError::PolicyLengthExceeded(ref cause) => write!(f, "{}", cause),
2094 AddPermissionError::PreconditionFailed(ref cause) => write!(f, "{}", cause),
2095 AddPermissionError::ResourceConflict(ref cause) => write!(f, "{}", cause),
2096 AddPermissionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2097 AddPermissionError::Service(ref cause) => write!(f, "{}", cause),
2098 AddPermissionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2099 }
2100 }
2101}
2102impl Error for AddPermissionError {}
2103#[derive(Debug, PartialEq)]
2105pub enum CreateAliasError {
2106 InvalidParameterValue(String),
2108 ResourceConflict(String),
2110 ResourceNotFound(String),
2112 Service(String),
2114 TooManyRequests(String),
2116}
2117
2118impl CreateAliasError {
2119 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateAliasError> {
2120 if let Some(err) = proto::json::Error::parse_rest(&res) {
2121 match err.typ.as_str() {
2122 "InvalidParameterValueException" => {
2123 return RusotoError::Service(CreateAliasError::InvalidParameterValue(err.msg))
2124 }
2125 "ResourceConflictException" => {
2126 return RusotoError::Service(CreateAliasError::ResourceConflict(err.msg))
2127 }
2128 "ResourceNotFoundException" => {
2129 return RusotoError::Service(CreateAliasError::ResourceNotFound(err.msg))
2130 }
2131 "ServiceException" => {
2132 return RusotoError::Service(CreateAliasError::Service(err.msg))
2133 }
2134 "TooManyRequestsException" => {
2135 return RusotoError::Service(CreateAliasError::TooManyRequests(err.msg))
2136 }
2137 "ValidationException" => return RusotoError::Validation(err.msg),
2138 _ => {}
2139 }
2140 }
2141 RusotoError::Unknown(res)
2142 }
2143}
2144impl fmt::Display for CreateAliasError {
2145 #[allow(unused_variables)]
2146 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2147 match *self {
2148 CreateAliasError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2149 CreateAliasError::ResourceConflict(ref cause) => write!(f, "{}", cause),
2150 CreateAliasError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2151 CreateAliasError::Service(ref cause) => write!(f, "{}", cause),
2152 CreateAliasError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2153 }
2154 }
2155}
2156impl Error for CreateAliasError {}
2157#[derive(Debug, PartialEq)]
2159pub enum CreateEventSourceMappingError {
2160 InvalidParameterValue(String),
2162 ResourceConflict(String),
2164 ResourceNotFound(String),
2166 Service(String),
2168 TooManyRequests(String),
2170}
2171
2172impl CreateEventSourceMappingError {
2173 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateEventSourceMappingError> {
2174 if let Some(err) = proto::json::Error::parse_rest(&res) {
2175 match err.typ.as_str() {
2176 "InvalidParameterValueException" => {
2177 return RusotoError::Service(
2178 CreateEventSourceMappingError::InvalidParameterValue(err.msg),
2179 )
2180 }
2181 "ResourceConflictException" => {
2182 return RusotoError::Service(CreateEventSourceMappingError::ResourceConflict(
2183 err.msg,
2184 ))
2185 }
2186 "ResourceNotFoundException" => {
2187 return RusotoError::Service(CreateEventSourceMappingError::ResourceNotFound(
2188 err.msg,
2189 ))
2190 }
2191 "ServiceException" => {
2192 return RusotoError::Service(CreateEventSourceMappingError::Service(err.msg))
2193 }
2194 "TooManyRequestsException" => {
2195 return RusotoError::Service(CreateEventSourceMappingError::TooManyRequests(
2196 err.msg,
2197 ))
2198 }
2199 "ValidationException" => return RusotoError::Validation(err.msg),
2200 _ => {}
2201 }
2202 }
2203 RusotoError::Unknown(res)
2204 }
2205}
2206impl fmt::Display for CreateEventSourceMappingError {
2207 #[allow(unused_variables)]
2208 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2209 match *self {
2210 CreateEventSourceMappingError::InvalidParameterValue(ref cause) => {
2211 write!(f, "{}", cause)
2212 }
2213 CreateEventSourceMappingError::ResourceConflict(ref cause) => write!(f, "{}", cause),
2214 CreateEventSourceMappingError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2215 CreateEventSourceMappingError::Service(ref cause) => write!(f, "{}", cause),
2216 CreateEventSourceMappingError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2217 }
2218 }
2219}
2220impl Error for CreateEventSourceMappingError {}
2221#[derive(Debug, PartialEq)]
2223pub enum CreateFunctionError {
2224 CodeStorageExceeded(String),
2226 InvalidParameterValue(String),
2228 ResourceConflict(String),
2230 ResourceNotFound(String),
2232 Service(String),
2234 TooManyRequests(String),
2236}
2237
2238impl CreateFunctionError {
2239 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateFunctionError> {
2240 if let Some(err) = proto::json::Error::parse_rest(&res) {
2241 match err.typ.as_str() {
2242 "CodeStorageExceededException" => {
2243 return RusotoError::Service(CreateFunctionError::CodeStorageExceeded(err.msg))
2244 }
2245 "InvalidParameterValueException" => {
2246 return RusotoError::Service(CreateFunctionError::InvalidParameterValue(
2247 err.msg,
2248 ))
2249 }
2250 "ResourceConflictException" => {
2251 return RusotoError::Service(CreateFunctionError::ResourceConflict(err.msg))
2252 }
2253 "ResourceNotFoundException" => {
2254 return RusotoError::Service(CreateFunctionError::ResourceNotFound(err.msg))
2255 }
2256 "ServiceException" => {
2257 return RusotoError::Service(CreateFunctionError::Service(err.msg))
2258 }
2259 "TooManyRequestsException" => {
2260 return RusotoError::Service(CreateFunctionError::TooManyRequests(err.msg))
2261 }
2262 "ValidationException" => return RusotoError::Validation(err.msg),
2263 _ => {}
2264 }
2265 }
2266 RusotoError::Unknown(res)
2267 }
2268}
2269impl fmt::Display for CreateFunctionError {
2270 #[allow(unused_variables)]
2271 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2272 match *self {
2273 CreateFunctionError::CodeStorageExceeded(ref cause) => write!(f, "{}", cause),
2274 CreateFunctionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2275 CreateFunctionError::ResourceConflict(ref cause) => write!(f, "{}", cause),
2276 CreateFunctionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2277 CreateFunctionError::Service(ref cause) => write!(f, "{}", cause),
2278 CreateFunctionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2279 }
2280 }
2281}
2282impl Error for CreateFunctionError {}
2283#[derive(Debug, PartialEq)]
2285pub enum DeleteAliasError {
2286 InvalidParameterValue(String),
2288 ResourceConflict(String),
2290 Service(String),
2292 TooManyRequests(String),
2294}
2295
2296impl DeleteAliasError {
2297 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteAliasError> {
2298 if let Some(err) = proto::json::Error::parse_rest(&res) {
2299 match err.typ.as_str() {
2300 "InvalidParameterValueException" => {
2301 return RusotoError::Service(DeleteAliasError::InvalidParameterValue(err.msg))
2302 }
2303 "ResourceConflictException" => {
2304 return RusotoError::Service(DeleteAliasError::ResourceConflict(err.msg))
2305 }
2306 "ServiceException" => {
2307 return RusotoError::Service(DeleteAliasError::Service(err.msg))
2308 }
2309 "TooManyRequestsException" => {
2310 return RusotoError::Service(DeleteAliasError::TooManyRequests(err.msg))
2311 }
2312 "ValidationException" => return RusotoError::Validation(err.msg),
2313 _ => {}
2314 }
2315 }
2316 RusotoError::Unknown(res)
2317 }
2318}
2319impl fmt::Display for DeleteAliasError {
2320 #[allow(unused_variables)]
2321 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2322 match *self {
2323 DeleteAliasError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2324 DeleteAliasError::ResourceConflict(ref cause) => write!(f, "{}", cause),
2325 DeleteAliasError::Service(ref cause) => write!(f, "{}", cause),
2326 DeleteAliasError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2327 }
2328 }
2329}
2330impl Error for DeleteAliasError {}
2331#[derive(Debug, PartialEq)]
2333pub enum DeleteEventSourceMappingError {
2334 InvalidParameterValue(String),
2336 ResourceInUse(String),
2338 ResourceNotFound(String),
2340 Service(String),
2342 TooManyRequests(String),
2344}
2345
2346impl DeleteEventSourceMappingError {
2347 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteEventSourceMappingError> {
2348 if let Some(err) = proto::json::Error::parse_rest(&res) {
2349 match err.typ.as_str() {
2350 "InvalidParameterValueException" => {
2351 return RusotoError::Service(
2352 DeleteEventSourceMappingError::InvalidParameterValue(err.msg),
2353 )
2354 }
2355 "ResourceInUseException" => {
2356 return RusotoError::Service(DeleteEventSourceMappingError::ResourceInUse(
2357 err.msg,
2358 ))
2359 }
2360 "ResourceNotFoundException" => {
2361 return RusotoError::Service(DeleteEventSourceMappingError::ResourceNotFound(
2362 err.msg,
2363 ))
2364 }
2365 "ServiceException" => {
2366 return RusotoError::Service(DeleteEventSourceMappingError::Service(err.msg))
2367 }
2368 "TooManyRequestsException" => {
2369 return RusotoError::Service(DeleteEventSourceMappingError::TooManyRequests(
2370 err.msg,
2371 ))
2372 }
2373 "ValidationException" => return RusotoError::Validation(err.msg),
2374 _ => {}
2375 }
2376 }
2377 RusotoError::Unknown(res)
2378 }
2379}
2380impl fmt::Display for DeleteEventSourceMappingError {
2381 #[allow(unused_variables)]
2382 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2383 match *self {
2384 DeleteEventSourceMappingError::InvalidParameterValue(ref cause) => {
2385 write!(f, "{}", cause)
2386 }
2387 DeleteEventSourceMappingError::ResourceInUse(ref cause) => write!(f, "{}", cause),
2388 DeleteEventSourceMappingError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2389 DeleteEventSourceMappingError::Service(ref cause) => write!(f, "{}", cause),
2390 DeleteEventSourceMappingError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2391 }
2392 }
2393}
2394impl Error for DeleteEventSourceMappingError {}
2395#[derive(Debug, PartialEq)]
2397pub enum DeleteFunctionError {
2398 InvalidParameterValue(String),
2400 ResourceConflict(String),
2402 ResourceNotFound(String),
2404 Service(String),
2406 TooManyRequests(String),
2408}
2409
2410impl DeleteFunctionError {
2411 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteFunctionError> {
2412 if let Some(err) = proto::json::Error::parse_rest(&res) {
2413 match err.typ.as_str() {
2414 "InvalidParameterValueException" => {
2415 return RusotoError::Service(DeleteFunctionError::InvalidParameterValue(
2416 err.msg,
2417 ))
2418 }
2419 "ResourceConflictException" => {
2420 return RusotoError::Service(DeleteFunctionError::ResourceConflict(err.msg))
2421 }
2422 "ResourceNotFoundException" => {
2423 return RusotoError::Service(DeleteFunctionError::ResourceNotFound(err.msg))
2424 }
2425 "ServiceException" => {
2426 return RusotoError::Service(DeleteFunctionError::Service(err.msg))
2427 }
2428 "TooManyRequestsException" => {
2429 return RusotoError::Service(DeleteFunctionError::TooManyRequests(err.msg))
2430 }
2431 "ValidationException" => return RusotoError::Validation(err.msg),
2432 _ => {}
2433 }
2434 }
2435 RusotoError::Unknown(res)
2436 }
2437}
2438impl fmt::Display for DeleteFunctionError {
2439 #[allow(unused_variables)]
2440 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2441 match *self {
2442 DeleteFunctionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2443 DeleteFunctionError::ResourceConflict(ref cause) => write!(f, "{}", cause),
2444 DeleteFunctionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2445 DeleteFunctionError::Service(ref cause) => write!(f, "{}", cause),
2446 DeleteFunctionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2447 }
2448 }
2449}
2450impl Error for DeleteFunctionError {}
2451#[derive(Debug, PartialEq)]
2453pub enum DeleteFunctionConcurrencyError {
2454 InvalidParameterValue(String),
2456 ResourceConflict(String),
2458 ResourceNotFound(String),
2460 Service(String),
2462 TooManyRequests(String),
2464}
2465
2466impl DeleteFunctionConcurrencyError {
2467 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteFunctionConcurrencyError> {
2468 if let Some(err) = proto::json::Error::parse_rest(&res) {
2469 match err.typ.as_str() {
2470 "InvalidParameterValueException" => {
2471 return RusotoError::Service(
2472 DeleteFunctionConcurrencyError::InvalidParameterValue(err.msg),
2473 )
2474 }
2475 "ResourceConflictException" => {
2476 return RusotoError::Service(DeleteFunctionConcurrencyError::ResourceConflict(
2477 err.msg,
2478 ))
2479 }
2480 "ResourceNotFoundException" => {
2481 return RusotoError::Service(DeleteFunctionConcurrencyError::ResourceNotFound(
2482 err.msg,
2483 ))
2484 }
2485 "ServiceException" => {
2486 return RusotoError::Service(DeleteFunctionConcurrencyError::Service(err.msg))
2487 }
2488 "TooManyRequestsException" => {
2489 return RusotoError::Service(DeleteFunctionConcurrencyError::TooManyRequests(
2490 err.msg,
2491 ))
2492 }
2493 "ValidationException" => return RusotoError::Validation(err.msg),
2494 _ => {}
2495 }
2496 }
2497 RusotoError::Unknown(res)
2498 }
2499}
2500impl fmt::Display for DeleteFunctionConcurrencyError {
2501 #[allow(unused_variables)]
2502 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2503 match *self {
2504 DeleteFunctionConcurrencyError::InvalidParameterValue(ref cause) => {
2505 write!(f, "{}", cause)
2506 }
2507 DeleteFunctionConcurrencyError::ResourceConflict(ref cause) => write!(f, "{}", cause),
2508 DeleteFunctionConcurrencyError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2509 DeleteFunctionConcurrencyError::Service(ref cause) => write!(f, "{}", cause),
2510 DeleteFunctionConcurrencyError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2511 }
2512 }
2513}
2514impl Error for DeleteFunctionConcurrencyError {}
2515#[derive(Debug, PartialEq)]
2517pub enum DeleteFunctionEventInvokeConfigError {
2518 InvalidParameterValue(String),
2520 ResourceNotFound(String),
2522 Service(String),
2524 TooManyRequests(String),
2526}
2527
2528impl DeleteFunctionEventInvokeConfigError {
2529 pub fn from_response(
2530 res: BufferedHttpResponse,
2531 ) -> RusotoError<DeleteFunctionEventInvokeConfigError> {
2532 if let Some(err) = proto::json::Error::parse_rest(&res) {
2533 match err.typ.as_str() {
2534 "InvalidParameterValueException" => {
2535 return RusotoError::Service(
2536 DeleteFunctionEventInvokeConfigError::InvalidParameterValue(err.msg),
2537 )
2538 }
2539 "ResourceNotFoundException" => {
2540 return RusotoError::Service(
2541 DeleteFunctionEventInvokeConfigError::ResourceNotFound(err.msg),
2542 )
2543 }
2544 "ServiceException" => {
2545 return RusotoError::Service(DeleteFunctionEventInvokeConfigError::Service(
2546 err.msg,
2547 ))
2548 }
2549 "TooManyRequestsException" => {
2550 return RusotoError::Service(
2551 DeleteFunctionEventInvokeConfigError::TooManyRequests(err.msg),
2552 )
2553 }
2554 "ValidationException" => return RusotoError::Validation(err.msg),
2555 _ => {}
2556 }
2557 }
2558 RusotoError::Unknown(res)
2559 }
2560}
2561impl fmt::Display for DeleteFunctionEventInvokeConfigError {
2562 #[allow(unused_variables)]
2563 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2564 match *self {
2565 DeleteFunctionEventInvokeConfigError::InvalidParameterValue(ref cause) => {
2566 write!(f, "{}", cause)
2567 }
2568 DeleteFunctionEventInvokeConfigError::ResourceNotFound(ref cause) => {
2569 write!(f, "{}", cause)
2570 }
2571 DeleteFunctionEventInvokeConfigError::Service(ref cause) => write!(f, "{}", cause),
2572 DeleteFunctionEventInvokeConfigError::TooManyRequests(ref cause) => {
2573 write!(f, "{}", cause)
2574 }
2575 }
2576 }
2577}
2578impl Error for DeleteFunctionEventInvokeConfigError {}
2579#[derive(Debug, PartialEq)]
2581pub enum DeleteLayerVersionError {
2582 Service(String),
2584 TooManyRequests(String),
2586}
2587
2588impl DeleteLayerVersionError {
2589 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteLayerVersionError> {
2590 if let Some(err) = proto::json::Error::parse_rest(&res) {
2591 match err.typ.as_str() {
2592 "ServiceException" => {
2593 return RusotoError::Service(DeleteLayerVersionError::Service(err.msg))
2594 }
2595 "TooManyRequestsException" => {
2596 return RusotoError::Service(DeleteLayerVersionError::TooManyRequests(err.msg))
2597 }
2598 "ValidationException" => return RusotoError::Validation(err.msg),
2599 _ => {}
2600 }
2601 }
2602 RusotoError::Unknown(res)
2603 }
2604}
2605impl fmt::Display for DeleteLayerVersionError {
2606 #[allow(unused_variables)]
2607 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2608 match *self {
2609 DeleteLayerVersionError::Service(ref cause) => write!(f, "{}", cause),
2610 DeleteLayerVersionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2611 }
2612 }
2613}
2614impl Error for DeleteLayerVersionError {}
2615#[derive(Debug, PartialEq)]
2617pub enum DeleteProvisionedConcurrencyConfigError {
2618 InvalidParameterValue(String),
2620 ResourceConflict(String),
2622 ResourceNotFound(String),
2624 Service(String),
2626 TooManyRequests(String),
2628}
2629
2630impl DeleteProvisionedConcurrencyConfigError {
2631 pub fn from_response(
2632 res: BufferedHttpResponse,
2633 ) -> RusotoError<DeleteProvisionedConcurrencyConfigError> {
2634 if let Some(err) = proto::json::Error::parse_rest(&res) {
2635 match err.typ.as_str() {
2636 "InvalidParameterValueException" => {
2637 return RusotoError::Service(
2638 DeleteProvisionedConcurrencyConfigError::InvalidParameterValue(err.msg),
2639 )
2640 }
2641 "ResourceConflictException" => {
2642 return RusotoError::Service(
2643 DeleteProvisionedConcurrencyConfigError::ResourceConflict(err.msg),
2644 )
2645 }
2646 "ResourceNotFoundException" => {
2647 return RusotoError::Service(
2648 DeleteProvisionedConcurrencyConfigError::ResourceNotFound(err.msg),
2649 )
2650 }
2651 "ServiceException" => {
2652 return RusotoError::Service(DeleteProvisionedConcurrencyConfigError::Service(
2653 err.msg,
2654 ))
2655 }
2656 "TooManyRequestsException" => {
2657 return RusotoError::Service(
2658 DeleteProvisionedConcurrencyConfigError::TooManyRequests(err.msg),
2659 )
2660 }
2661 "ValidationException" => return RusotoError::Validation(err.msg),
2662 _ => {}
2663 }
2664 }
2665 RusotoError::Unknown(res)
2666 }
2667}
2668impl fmt::Display for DeleteProvisionedConcurrencyConfigError {
2669 #[allow(unused_variables)]
2670 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2671 match *self {
2672 DeleteProvisionedConcurrencyConfigError::InvalidParameterValue(ref cause) => {
2673 write!(f, "{}", cause)
2674 }
2675 DeleteProvisionedConcurrencyConfigError::ResourceConflict(ref cause) => {
2676 write!(f, "{}", cause)
2677 }
2678 DeleteProvisionedConcurrencyConfigError::ResourceNotFound(ref cause) => {
2679 write!(f, "{}", cause)
2680 }
2681 DeleteProvisionedConcurrencyConfigError::Service(ref cause) => write!(f, "{}", cause),
2682 DeleteProvisionedConcurrencyConfigError::TooManyRequests(ref cause) => {
2683 write!(f, "{}", cause)
2684 }
2685 }
2686 }
2687}
2688impl Error for DeleteProvisionedConcurrencyConfigError {}
2689#[derive(Debug, PartialEq)]
2691pub enum GetAccountSettingsError {
2692 Service(String),
2694 TooManyRequests(String),
2696}
2697
2698impl GetAccountSettingsError {
2699 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetAccountSettingsError> {
2700 if let Some(err) = proto::json::Error::parse_rest(&res) {
2701 match err.typ.as_str() {
2702 "ServiceException" => {
2703 return RusotoError::Service(GetAccountSettingsError::Service(err.msg))
2704 }
2705 "TooManyRequestsException" => {
2706 return RusotoError::Service(GetAccountSettingsError::TooManyRequests(err.msg))
2707 }
2708 "ValidationException" => return RusotoError::Validation(err.msg),
2709 _ => {}
2710 }
2711 }
2712 RusotoError::Unknown(res)
2713 }
2714}
2715impl fmt::Display for GetAccountSettingsError {
2716 #[allow(unused_variables)]
2717 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2718 match *self {
2719 GetAccountSettingsError::Service(ref cause) => write!(f, "{}", cause),
2720 GetAccountSettingsError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2721 }
2722 }
2723}
2724impl Error for GetAccountSettingsError {}
2725#[derive(Debug, PartialEq)]
2727pub enum GetAliasError {
2728 InvalidParameterValue(String),
2730 ResourceNotFound(String),
2732 Service(String),
2734 TooManyRequests(String),
2736}
2737
2738impl GetAliasError {
2739 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetAliasError> {
2740 if let Some(err) = proto::json::Error::parse_rest(&res) {
2741 match err.typ.as_str() {
2742 "InvalidParameterValueException" => {
2743 return RusotoError::Service(GetAliasError::InvalidParameterValue(err.msg))
2744 }
2745 "ResourceNotFoundException" => {
2746 return RusotoError::Service(GetAliasError::ResourceNotFound(err.msg))
2747 }
2748 "ServiceException" => return RusotoError::Service(GetAliasError::Service(err.msg)),
2749 "TooManyRequestsException" => {
2750 return RusotoError::Service(GetAliasError::TooManyRequests(err.msg))
2751 }
2752 "ValidationException" => return RusotoError::Validation(err.msg),
2753 _ => {}
2754 }
2755 }
2756 RusotoError::Unknown(res)
2757 }
2758}
2759impl fmt::Display for GetAliasError {
2760 #[allow(unused_variables)]
2761 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2762 match *self {
2763 GetAliasError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2764 GetAliasError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2765 GetAliasError::Service(ref cause) => write!(f, "{}", cause),
2766 GetAliasError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2767 }
2768 }
2769}
2770impl Error for GetAliasError {}
2771#[derive(Debug, PartialEq)]
2773pub enum GetEventSourceMappingError {
2774 InvalidParameterValue(String),
2776 ResourceNotFound(String),
2778 Service(String),
2780 TooManyRequests(String),
2782}
2783
2784impl GetEventSourceMappingError {
2785 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetEventSourceMappingError> {
2786 if let Some(err) = proto::json::Error::parse_rest(&res) {
2787 match err.typ.as_str() {
2788 "InvalidParameterValueException" => {
2789 return RusotoError::Service(GetEventSourceMappingError::InvalidParameterValue(
2790 err.msg,
2791 ))
2792 }
2793 "ResourceNotFoundException" => {
2794 return RusotoError::Service(GetEventSourceMappingError::ResourceNotFound(
2795 err.msg,
2796 ))
2797 }
2798 "ServiceException" => {
2799 return RusotoError::Service(GetEventSourceMappingError::Service(err.msg))
2800 }
2801 "TooManyRequestsException" => {
2802 return RusotoError::Service(GetEventSourceMappingError::TooManyRequests(
2803 err.msg,
2804 ))
2805 }
2806 "ValidationException" => return RusotoError::Validation(err.msg),
2807 _ => {}
2808 }
2809 }
2810 RusotoError::Unknown(res)
2811 }
2812}
2813impl fmt::Display for GetEventSourceMappingError {
2814 #[allow(unused_variables)]
2815 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2816 match *self {
2817 GetEventSourceMappingError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2818 GetEventSourceMappingError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2819 GetEventSourceMappingError::Service(ref cause) => write!(f, "{}", cause),
2820 GetEventSourceMappingError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2821 }
2822 }
2823}
2824impl Error for GetEventSourceMappingError {}
2825#[derive(Debug, PartialEq)]
2827pub enum GetFunctionError {
2828 InvalidParameterValue(String),
2830 ResourceNotFound(String),
2832 Service(String),
2834 TooManyRequests(String),
2836}
2837
2838impl GetFunctionError {
2839 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetFunctionError> {
2840 if let Some(err) = proto::json::Error::parse_rest(&res) {
2841 match err.typ.as_str() {
2842 "InvalidParameterValueException" => {
2843 return RusotoError::Service(GetFunctionError::InvalidParameterValue(err.msg))
2844 }
2845 "ResourceNotFoundException" => {
2846 return RusotoError::Service(GetFunctionError::ResourceNotFound(err.msg))
2847 }
2848 "ServiceException" => {
2849 return RusotoError::Service(GetFunctionError::Service(err.msg))
2850 }
2851 "TooManyRequestsException" => {
2852 return RusotoError::Service(GetFunctionError::TooManyRequests(err.msg))
2853 }
2854 "ValidationException" => return RusotoError::Validation(err.msg),
2855 _ => {}
2856 }
2857 }
2858 RusotoError::Unknown(res)
2859 }
2860}
2861impl fmt::Display for GetFunctionError {
2862 #[allow(unused_variables)]
2863 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2864 match *self {
2865 GetFunctionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2866 GetFunctionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2867 GetFunctionError::Service(ref cause) => write!(f, "{}", cause),
2868 GetFunctionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2869 }
2870 }
2871}
2872impl Error for GetFunctionError {}
2873#[derive(Debug, PartialEq)]
2875pub enum GetFunctionConcurrencyError {
2876 InvalidParameterValue(String),
2878 ResourceNotFound(String),
2880 Service(String),
2882 TooManyRequests(String),
2884}
2885
2886impl GetFunctionConcurrencyError {
2887 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetFunctionConcurrencyError> {
2888 if let Some(err) = proto::json::Error::parse_rest(&res) {
2889 match err.typ.as_str() {
2890 "InvalidParameterValueException" => {
2891 return RusotoError::Service(
2892 GetFunctionConcurrencyError::InvalidParameterValue(err.msg),
2893 )
2894 }
2895 "ResourceNotFoundException" => {
2896 return RusotoError::Service(GetFunctionConcurrencyError::ResourceNotFound(
2897 err.msg,
2898 ))
2899 }
2900 "ServiceException" => {
2901 return RusotoError::Service(GetFunctionConcurrencyError::Service(err.msg))
2902 }
2903 "TooManyRequestsException" => {
2904 return RusotoError::Service(GetFunctionConcurrencyError::TooManyRequests(
2905 err.msg,
2906 ))
2907 }
2908 "ValidationException" => return RusotoError::Validation(err.msg),
2909 _ => {}
2910 }
2911 }
2912 RusotoError::Unknown(res)
2913 }
2914}
2915impl fmt::Display for GetFunctionConcurrencyError {
2916 #[allow(unused_variables)]
2917 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2918 match *self {
2919 GetFunctionConcurrencyError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
2920 GetFunctionConcurrencyError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2921 GetFunctionConcurrencyError::Service(ref cause) => write!(f, "{}", cause),
2922 GetFunctionConcurrencyError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2923 }
2924 }
2925}
2926impl Error for GetFunctionConcurrencyError {}
2927#[derive(Debug, PartialEq)]
2929pub enum GetFunctionConfigurationError {
2930 InvalidParameterValue(String),
2932 ResourceNotFound(String),
2934 Service(String),
2936 TooManyRequests(String),
2938}
2939
2940impl GetFunctionConfigurationError {
2941 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetFunctionConfigurationError> {
2942 if let Some(err) = proto::json::Error::parse_rest(&res) {
2943 match err.typ.as_str() {
2944 "InvalidParameterValueException" => {
2945 return RusotoError::Service(
2946 GetFunctionConfigurationError::InvalidParameterValue(err.msg),
2947 )
2948 }
2949 "ResourceNotFoundException" => {
2950 return RusotoError::Service(GetFunctionConfigurationError::ResourceNotFound(
2951 err.msg,
2952 ))
2953 }
2954 "ServiceException" => {
2955 return RusotoError::Service(GetFunctionConfigurationError::Service(err.msg))
2956 }
2957 "TooManyRequestsException" => {
2958 return RusotoError::Service(GetFunctionConfigurationError::TooManyRequests(
2959 err.msg,
2960 ))
2961 }
2962 "ValidationException" => return RusotoError::Validation(err.msg),
2963 _ => {}
2964 }
2965 }
2966 RusotoError::Unknown(res)
2967 }
2968}
2969impl fmt::Display for GetFunctionConfigurationError {
2970 #[allow(unused_variables)]
2971 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2972 match *self {
2973 GetFunctionConfigurationError::InvalidParameterValue(ref cause) => {
2974 write!(f, "{}", cause)
2975 }
2976 GetFunctionConfigurationError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2977 GetFunctionConfigurationError::Service(ref cause) => write!(f, "{}", cause),
2978 GetFunctionConfigurationError::TooManyRequests(ref cause) => write!(f, "{}", cause),
2979 }
2980 }
2981}
2982impl Error for GetFunctionConfigurationError {}
2983#[derive(Debug, PartialEq)]
2985pub enum GetFunctionEventInvokeConfigError {
2986 InvalidParameterValue(String),
2988 ResourceNotFound(String),
2990 Service(String),
2992 TooManyRequests(String),
2994}
2995
2996impl GetFunctionEventInvokeConfigError {
2997 pub fn from_response(
2998 res: BufferedHttpResponse,
2999 ) -> RusotoError<GetFunctionEventInvokeConfigError> {
3000 if let Some(err) = proto::json::Error::parse_rest(&res) {
3001 match err.typ.as_str() {
3002 "InvalidParameterValueException" => {
3003 return RusotoError::Service(
3004 GetFunctionEventInvokeConfigError::InvalidParameterValue(err.msg),
3005 )
3006 }
3007 "ResourceNotFoundException" => {
3008 return RusotoError::Service(
3009 GetFunctionEventInvokeConfigError::ResourceNotFound(err.msg),
3010 )
3011 }
3012 "ServiceException" => {
3013 return RusotoError::Service(GetFunctionEventInvokeConfigError::Service(
3014 err.msg,
3015 ))
3016 }
3017 "TooManyRequestsException" => {
3018 return RusotoError::Service(
3019 GetFunctionEventInvokeConfigError::TooManyRequests(err.msg),
3020 )
3021 }
3022 "ValidationException" => return RusotoError::Validation(err.msg),
3023 _ => {}
3024 }
3025 }
3026 RusotoError::Unknown(res)
3027 }
3028}
3029impl fmt::Display for GetFunctionEventInvokeConfigError {
3030 #[allow(unused_variables)]
3031 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3032 match *self {
3033 GetFunctionEventInvokeConfigError::InvalidParameterValue(ref cause) => {
3034 write!(f, "{}", cause)
3035 }
3036 GetFunctionEventInvokeConfigError::ResourceNotFound(ref cause) => {
3037 write!(f, "{}", cause)
3038 }
3039 GetFunctionEventInvokeConfigError::Service(ref cause) => write!(f, "{}", cause),
3040 GetFunctionEventInvokeConfigError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3041 }
3042 }
3043}
3044impl Error for GetFunctionEventInvokeConfigError {}
3045#[derive(Debug, PartialEq)]
3047pub enum GetLayerVersionError {
3048 InvalidParameterValue(String),
3050 ResourceNotFound(String),
3052 Service(String),
3054 TooManyRequests(String),
3056}
3057
3058impl GetLayerVersionError {
3059 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetLayerVersionError> {
3060 if let Some(err) = proto::json::Error::parse_rest(&res) {
3061 match err.typ.as_str() {
3062 "InvalidParameterValueException" => {
3063 return RusotoError::Service(GetLayerVersionError::InvalidParameterValue(
3064 err.msg,
3065 ))
3066 }
3067 "ResourceNotFoundException" => {
3068 return RusotoError::Service(GetLayerVersionError::ResourceNotFound(err.msg))
3069 }
3070 "ServiceException" => {
3071 return RusotoError::Service(GetLayerVersionError::Service(err.msg))
3072 }
3073 "TooManyRequestsException" => {
3074 return RusotoError::Service(GetLayerVersionError::TooManyRequests(err.msg))
3075 }
3076 "ValidationException" => return RusotoError::Validation(err.msg),
3077 _ => {}
3078 }
3079 }
3080 RusotoError::Unknown(res)
3081 }
3082}
3083impl fmt::Display for GetLayerVersionError {
3084 #[allow(unused_variables)]
3085 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3086 match *self {
3087 GetLayerVersionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3088 GetLayerVersionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3089 GetLayerVersionError::Service(ref cause) => write!(f, "{}", cause),
3090 GetLayerVersionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3091 }
3092 }
3093}
3094impl Error for GetLayerVersionError {}
3095#[derive(Debug, PartialEq)]
3097pub enum GetLayerVersionByArnError {
3098 InvalidParameterValue(String),
3100 ResourceNotFound(String),
3102 Service(String),
3104 TooManyRequests(String),
3106}
3107
3108impl GetLayerVersionByArnError {
3109 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetLayerVersionByArnError> {
3110 if let Some(err) = proto::json::Error::parse_rest(&res) {
3111 match err.typ.as_str() {
3112 "InvalidParameterValueException" => {
3113 return RusotoError::Service(GetLayerVersionByArnError::InvalidParameterValue(
3114 err.msg,
3115 ))
3116 }
3117 "ResourceNotFoundException" => {
3118 return RusotoError::Service(GetLayerVersionByArnError::ResourceNotFound(
3119 err.msg,
3120 ))
3121 }
3122 "ServiceException" => {
3123 return RusotoError::Service(GetLayerVersionByArnError::Service(err.msg))
3124 }
3125 "TooManyRequestsException" => {
3126 return RusotoError::Service(GetLayerVersionByArnError::TooManyRequests(
3127 err.msg,
3128 ))
3129 }
3130 "ValidationException" => return RusotoError::Validation(err.msg),
3131 _ => {}
3132 }
3133 }
3134 RusotoError::Unknown(res)
3135 }
3136}
3137impl fmt::Display for GetLayerVersionByArnError {
3138 #[allow(unused_variables)]
3139 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3140 match *self {
3141 GetLayerVersionByArnError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3142 GetLayerVersionByArnError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3143 GetLayerVersionByArnError::Service(ref cause) => write!(f, "{}", cause),
3144 GetLayerVersionByArnError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3145 }
3146 }
3147}
3148impl Error for GetLayerVersionByArnError {}
3149#[derive(Debug, PartialEq)]
3151pub enum GetLayerVersionPolicyError {
3152 InvalidParameterValue(String),
3154 ResourceNotFound(String),
3156 Service(String),
3158 TooManyRequests(String),
3160}
3161
3162impl GetLayerVersionPolicyError {
3163 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetLayerVersionPolicyError> {
3164 if let Some(err) = proto::json::Error::parse_rest(&res) {
3165 match err.typ.as_str() {
3166 "InvalidParameterValueException" => {
3167 return RusotoError::Service(GetLayerVersionPolicyError::InvalidParameterValue(
3168 err.msg,
3169 ))
3170 }
3171 "ResourceNotFoundException" => {
3172 return RusotoError::Service(GetLayerVersionPolicyError::ResourceNotFound(
3173 err.msg,
3174 ))
3175 }
3176 "ServiceException" => {
3177 return RusotoError::Service(GetLayerVersionPolicyError::Service(err.msg))
3178 }
3179 "TooManyRequestsException" => {
3180 return RusotoError::Service(GetLayerVersionPolicyError::TooManyRequests(
3181 err.msg,
3182 ))
3183 }
3184 "ValidationException" => return RusotoError::Validation(err.msg),
3185 _ => {}
3186 }
3187 }
3188 RusotoError::Unknown(res)
3189 }
3190}
3191impl fmt::Display for GetLayerVersionPolicyError {
3192 #[allow(unused_variables)]
3193 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3194 match *self {
3195 GetLayerVersionPolicyError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3196 GetLayerVersionPolicyError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3197 GetLayerVersionPolicyError::Service(ref cause) => write!(f, "{}", cause),
3198 GetLayerVersionPolicyError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3199 }
3200 }
3201}
3202impl Error for GetLayerVersionPolicyError {}
3203#[derive(Debug, PartialEq)]
3205pub enum GetPolicyError {
3206 InvalidParameterValue(String),
3208 ResourceNotFound(String),
3210 Service(String),
3212 TooManyRequests(String),
3214}
3215
3216impl GetPolicyError {
3217 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<GetPolicyError> {
3218 if let Some(err) = proto::json::Error::parse_rest(&res) {
3219 match err.typ.as_str() {
3220 "InvalidParameterValueException" => {
3221 return RusotoError::Service(GetPolicyError::InvalidParameterValue(err.msg))
3222 }
3223 "ResourceNotFoundException" => {
3224 return RusotoError::Service(GetPolicyError::ResourceNotFound(err.msg))
3225 }
3226 "ServiceException" => {
3227 return RusotoError::Service(GetPolicyError::Service(err.msg))
3228 }
3229 "TooManyRequestsException" => {
3230 return RusotoError::Service(GetPolicyError::TooManyRequests(err.msg))
3231 }
3232 "ValidationException" => return RusotoError::Validation(err.msg),
3233 _ => {}
3234 }
3235 }
3236 RusotoError::Unknown(res)
3237 }
3238}
3239impl fmt::Display for GetPolicyError {
3240 #[allow(unused_variables)]
3241 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3242 match *self {
3243 GetPolicyError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3244 GetPolicyError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3245 GetPolicyError::Service(ref cause) => write!(f, "{}", cause),
3246 GetPolicyError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3247 }
3248 }
3249}
3250impl Error for GetPolicyError {}
3251#[derive(Debug, PartialEq)]
3253pub enum GetProvisionedConcurrencyConfigError {
3254 InvalidParameterValue(String),
3256 ProvisionedConcurrencyConfigNotFound(String),
3258 ResourceNotFound(String),
3260 Service(String),
3262 TooManyRequests(String),
3264}
3265
3266impl GetProvisionedConcurrencyConfigError {
3267 pub fn from_response(
3268 res: BufferedHttpResponse,
3269 ) -> RusotoError<GetProvisionedConcurrencyConfigError> {
3270 if let Some(err) = proto::json::Error::parse_rest(&res) {
3271 match err.typ.as_str() {
3272 "InvalidParameterValueException" => {
3273 return RusotoError::Service(
3274 GetProvisionedConcurrencyConfigError::InvalidParameterValue(err.msg),
3275 )
3276 }
3277 "ProvisionedConcurrencyConfigNotFoundException" => {
3278 return RusotoError::Service(
3279 GetProvisionedConcurrencyConfigError::ProvisionedConcurrencyConfigNotFound(
3280 err.msg,
3281 ),
3282 )
3283 }
3284 "ResourceNotFoundException" => {
3285 return RusotoError::Service(
3286 GetProvisionedConcurrencyConfigError::ResourceNotFound(err.msg),
3287 )
3288 }
3289 "ServiceException" => {
3290 return RusotoError::Service(GetProvisionedConcurrencyConfigError::Service(
3291 err.msg,
3292 ))
3293 }
3294 "TooManyRequestsException" => {
3295 return RusotoError::Service(
3296 GetProvisionedConcurrencyConfigError::TooManyRequests(err.msg),
3297 )
3298 }
3299 "ValidationException" => return RusotoError::Validation(err.msg),
3300 _ => {}
3301 }
3302 }
3303 RusotoError::Unknown(res)
3304 }
3305}
3306impl fmt::Display for GetProvisionedConcurrencyConfigError {
3307 #[allow(unused_variables)]
3308 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3309 match *self {
3310 GetProvisionedConcurrencyConfigError::InvalidParameterValue(ref cause) => {
3311 write!(f, "{}", cause)
3312 }
3313 GetProvisionedConcurrencyConfigError::ProvisionedConcurrencyConfigNotFound(
3314 ref cause,
3315 ) => write!(f, "{}", cause),
3316 GetProvisionedConcurrencyConfigError::ResourceNotFound(ref cause) => {
3317 write!(f, "{}", cause)
3318 }
3319 GetProvisionedConcurrencyConfigError::Service(ref cause) => write!(f, "{}", cause),
3320 GetProvisionedConcurrencyConfigError::TooManyRequests(ref cause) => {
3321 write!(f, "{}", cause)
3322 }
3323 }
3324 }
3325}
3326impl Error for GetProvisionedConcurrencyConfigError {}
3327#[derive(Debug, PartialEq)]
3329pub enum InvokeError {
3330 EC2AccessDenied(String),
3332 EC2Throttled(String),
3334 EC2Unexpected(String),
3336 EFSIO(String),
3338 EFSMountConnectivity(String),
3340 EFSMountFailure(String),
3342 EFSMountTimeout(String),
3344 ENILimitReached(String),
3346 InvalidParameterValue(String),
3348 InvalidRequestContent(String),
3350 InvalidRuntime(String),
3352 InvalidSecurityGroupID(String),
3354 InvalidSubnetID(String),
3356 InvalidZipFile(String),
3358 KMSAccessDenied(String),
3360 KMSDisabled(String),
3362 KMSInvalidState(String),
3364 KMSNotFound(String),
3366 RequestTooLarge(String),
3368 ResourceConflict(String),
3370 ResourceNotFound(String),
3372 ResourceNotReady(String),
3374 Service(String),
3376 SubnetIPAddressLimitReached(String),
3378 TooManyRequests(String),
3380 UnsupportedMediaType(String),
3382}
3383
3384impl InvokeError {
3385 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<InvokeError> {
3386 if let Some(err) = proto::json::Error::parse_rest(&res) {
3387 match err.typ.as_str() {
3388 "EC2AccessDeniedException" => {
3389 return RusotoError::Service(InvokeError::EC2AccessDenied(err.msg))
3390 }
3391 "EC2ThrottledException" => {
3392 return RusotoError::Service(InvokeError::EC2Throttled(err.msg))
3393 }
3394 "EC2UnexpectedException" => {
3395 return RusotoError::Service(InvokeError::EC2Unexpected(err.msg))
3396 }
3397 "EFSIOException" => return RusotoError::Service(InvokeError::EFSIO(err.msg)),
3398 "EFSMountConnectivityException" => {
3399 return RusotoError::Service(InvokeError::EFSMountConnectivity(err.msg))
3400 }
3401 "EFSMountFailureException" => {
3402 return RusotoError::Service(InvokeError::EFSMountFailure(err.msg))
3403 }
3404 "EFSMountTimeoutException" => {
3405 return RusotoError::Service(InvokeError::EFSMountTimeout(err.msg))
3406 }
3407 "ENILimitReachedException" => {
3408 return RusotoError::Service(InvokeError::ENILimitReached(err.msg))
3409 }
3410 "InvalidParameterValueException" => {
3411 return RusotoError::Service(InvokeError::InvalidParameterValue(err.msg))
3412 }
3413 "InvalidRequestContentException" => {
3414 return RusotoError::Service(InvokeError::InvalidRequestContent(err.msg))
3415 }
3416 "InvalidRuntimeException" => {
3417 return RusotoError::Service(InvokeError::InvalidRuntime(err.msg))
3418 }
3419 "InvalidSecurityGroupIDException" => {
3420 return RusotoError::Service(InvokeError::InvalidSecurityGroupID(err.msg))
3421 }
3422 "InvalidSubnetIDException" => {
3423 return RusotoError::Service(InvokeError::InvalidSubnetID(err.msg))
3424 }
3425 "InvalidZipFileException" => {
3426 return RusotoError::Service(InvokeError::InvalidZipFile(err.msg))
3427 }
3428 "KMSAccessDeniedException" => {
3429 return RusotoError::Service(InvokeError::KMSAccessDenied(err.msg))
3430 }
3431 "KMSDisabledException" => {
3432 return RusotoError::Service(InvokeError::KMSDisabled(err.msg))
3433 }
3434 "KMSInvalidStateException" => {
3435 return RusotoError::Service(InvokeError::KMSInvalidState(err.msg))
3436 }
3437 "KMSNotFoundException" => {
3438 return RusotoError::Service(InvokeError::KMSNotFound(err.msg))
3439 }
3440 "RequestTooLargeException" => {
3441 return RusotoError::Service(InvokeError::RequestTooLarge(err.msg))
3442 }
3443 "ResourceConflictException" => {
3444 return RusotoError::Service(InvokeError::ResourceConflict(err.msg))
3445 }
3446 "ResourceNotFoundException" => {
3447 return RusotoError::Service(InvokeError::ResourceNotFound(err.msg))
3448 }
3449 "ResourceNotReadyException" => {
3450 return RusotoError::Service(InvokeError::ResourceNotReady(err.msg))
3451 }
3452 "ServiceException" => return RusotoError::Service(InvokeError::Service(err.msg)),
3453 "SubnetIPAddressLimitReachedException" => {
3454 return RusotoError::Service(InvokeError::SubnetIPAddressLimitReached(err.msg))
3455 }
3456 "TooManyRequestsException" => {
3457 return RusotoError::Service(InvokeError::TooManyRequests(err.msg))
3458 }
3459 "UnsupportedMediaTypeException" => {
3460 return RusotoError::Service(InvokeError::UnsupportedMediaType(err.msg))
3461 }
3462 "ValidationException" => return RusotoError::Validation(err.msg),
3463 _ => {}
3464 }
3465 }
3466 RusotoError::Unknown(res)
3467 }
3468}
3469impl fmt::Display for InvokeError {
3470 #[allow(unused_variables)]
3471 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3472 match *self {
3473 InvokeError::EC2AccessDenied(ref cause) => write!(f, "{}", cause),
3474 InvokeError::EC2Throttled(ref cause) => write!(f, "{}", cause),
3475 InvokeError::EC2Unexpected(ref cause) => write!(f, "{}", cause),
3476 InvokeError::EFSIO(ref cause) => write!(f, "{}", cause),
3477 InvokeError::EFSMountConnectivity(ref cause) => write!(f, "{}", cause),
3478 InvokeError::EFSMountFailure(ref cause) => write!(f, "{}", cause),
3479 InvokeError::EFSMountTimeout(ref cause) => write!(f, "{}", cause),
3480 InvokeError::ENILimitReached(ref cause) => write!(f, "{}", cause),
3481 InvokeError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3482 InvokeError::InvalidRequestContent(ref cause) => write!(f, "{}", cause),
3483 InvokeError::InvalidRuntime(ref cause) => write!(f, "{}", cause),
3484 InvokeError::InvalidSecurityGroupID(ref cause) => write!(f, "{}", cause),
3485 InvokeError::InvalidSubnetID(ref cause) => write!(f, "{}", cause),
3486 InvokeError::InvalidZipFile(ref cause) => write!(f, "{}", cause),
3487 InvokeError::KMSAccessDenied(ref cause) => write!(f, "{}", cause),
3488 InvokeError::KMSDisabled(ref cause) => write!(f, "{}", cause),
3489 InvokeError::KMSInvalidState(ref cause) => write!(f, "{}", cause),
3490 InvokeError::KMSNotFound(ref cause) => write!(f, "{}", cause),
3491 InvokeError::RequestTooLarge(ref cause) => write!(f, "{}", cause),
3492 InvokeError::ResourceConflict(ref cause) => write!(f, "{}", cause),
3493 InvokeError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3494 InvokeError::ResourceNotReady(ref cause) => write!(f, "{}", cause),
3495 InvokeError::Service(ref cause) => write!(f, "{}", cause),
3496 InvokeError::SubnetIPAddressLimitReached(ref cause) => write!(f, "{}", cause),
3497 InvokeError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3498 InvokeError::UnsupportedMediaType(ref cause) => write!(f, "{}", cause),
3499 }
3500 }
3501}
3502impl Error for InvokeError {}
3503#[derive(Debug, PartialEq)]
3505pub enum InvokeAsyncError {
3506 InvalidRequestContent(String),
3508 InvalidRuntime(String),
3510 ResourceConflict(String),
3512 ResourceNotFound(String),
3514 Service(String),
3516}
3517
3518impl InvokeAsyncError {
3519 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<InvokeAsyncError> {
3520 if let Some(err) = proto::json::Error::parse_rest(&res) {
3521 match err.typ.as_str() {
3522 "InvalidRequestContentException" => {
3523 return RusotoError::Service(InvokeAsyncError::InvalidRequestContent(err.msg))
3524 }
3525 "InvalidRuntimeException" => {
3526 return RusotoError::Service(InvokeAsyncError::InvalidRuntime(err.msg))
3527 }
3528 "ResourceConflictException" => {
3529 return RusotoError::Service(InvokeAsyncError::ResourceConflict(err.msg))
3530 }
3531 "ResourceNotFoundException" => {
3532 return RusotoError::Service(InvokeAsyncError::ResourceNotFound(err.msg))
3533 }
3534 "ServiceException" => {
3535 return RusotoError::Service(InvokeAsyncError::Service(err.msg))
3536 }
3537 "ValidationException" => return RusotoError::Validation(err.msg),
3538 _ => {}
3539 }
3540 }
3541 RusotoError::Unknown(res)
3542 }
3543}
3544impl fmt::Display for InvokeAsyncError {
3545 #[allow(unused_variables)]
3546 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3547 match *self {
3548 InvokeAsyncError::InvalidRequestContent(ref cause) => write!(f, "{}", cause),
3549 InvokeAsyncError::InvalidRuntime(ref cause) => write!(f, "{}", cause),
3550 InvokeAsyncError::ResourceConflict(ref cause) => write!(f, "{}", cause),
3551 InvokeAsyncError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3552 InvokeAsyncError::Service(ref cause) => write!(f, "{}", cause),
3553 }
3554 }
3555}
3556impl Error for InvokeAsyncError {}
3557#[derive(Debug, PartialEq)]
3559pub enum ListAliasesError {
3560 InvalidParameterValue(String),
3562 ResourceNotFound(String),
3564 Service(String),
3566 TooManyRequests(String),
3568}
3569
3570impl ListAliasesError {
3571 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListAliasesError> {
3572 if let Some(err) = proto::json::Error::parse_rest(&res) {
3573 match err.typ.as_str() {
3574 "InvalidParameterValueException" => {
3575 return RusotoError::Service(ListAliasesError::InvalidParameterValue(err.msg))
3576 }
3577 "ResourceNotFoundException" => {
3578 return RusotoError::Service(ListAliasesError::ResourceNotFound(err.msg))
3579 }
3580 "ServiceException" => {
3581 return RusotoError::Service(ListAliasesError::Service(err.msg))
3582 }
3583 "TooManyRequestsException" => {
3584 return RusotoError::Service(ListAliasesError::TooManyRequests(err.msg))
3585 }
3586 "ValidationException" => return RusotoError::Validation(err.msg),
3587 _ => {}
3588 }
3589 }
3590 RusotoError::Unknown(res)
3591 }
3592}
3593impl fmt::Display for ListAliasesError {
3594 #[allow(unused_variables)]
3595 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3596 match *self {
3597 ListAliasesError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3598 ListAliasesError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3599 ListAliasesError::Service(ref cause) => write!(f, "{}", cause),
3600 ListAliasesError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3601 }
3602 }
3603}
3604impl Error for ListAliasesError {}
3605#[derive(Debug, PartialEq)]
3607pub enum ListEventSourceMappingsError {
3608 InvalidParameterValue(String),
3610 ResourceNotFound(String),
3612 Service(String),
3614 TooManyRequests(String),
3616}
3617
3618impl ListEventSourceMappingsError {
3619 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListEventSourceMappingsError> {
3620 if let Some(err) = proto::json::Error::parse_rest(&res) {
3621 match err.typ.as_str() {
3622 "InvalidParameterValueException" => {
3623 return RusotoError::Service(
3624 ListEventSourceMappingsError::InvalidParameterValue(err.msg),
3625 )
3626 }
3627 "ResourceNotFoundException" => {
3628 return RusotoError::Service(ListEventSourceMappingsError::ResourceNotFound(
3629 err.msg,
3630 ))
3631 }
3632 "ServiceException" => {
3633 return RusotoError::Service(ListEventSourceMappingsError::Service(err.msg))
3634 }
3635 "TooManyRequestsException" => {
3636 return RusotoError::Service(ListEventSourceMappingsError::TooManyRequests(
3637 err.msg,
3638 ))
3639 }
3640 "ValidationException" => return RusotoError::Validation(err.msg),
3641 _ => {}
3642 }
3643 }
3644 RusotoError::Unknown(res)
3645 }
3646}
3647impl fmt::Display for ListEventSourceMappingsError {
3648 #[allow(unused_variables)]
3649 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3650 match *self {
3651 ListEventSourceMappingsError::InvalidParameterValue(ref cause) => {
3652 write!(f, "{}", cause)
3653 }
3654 ListEventSourceMappingsError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3655 ListEventSourceMappingsError::Service(ref cause) => write!(f, "{}", cause),
3656 ListEventSourceMappingsError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3657 }
3658 }
3659}
3660impl Error for ListEventSourceMappingsError {}
3661#[derive(Debug, PartialEq)]
3663pub enum ListFunctionEventInvokeConfigsError {
3664 InvalidParameterValue(String),
3666 ResourceNotFound(String),
3668 Service(String),
3670 TooManyRequests(String),
3672}
3673
3674impl ListFunctionEventInvokeConfigsError {
3675 pub fn from_response(
3676 res: BufferedHttpResponse,
3677 ) -> RusotoError<ListFunctionEventInvokeConfigsError> {
3678 if let Some(err) = proto::json::Error::parse_rest(&res) {
3679 match err.typ.as_str() {
3680 "InvalidParameterValueException" => {
3681 return RusotoError::Service(
3682 ListFunctionEventInvokeConfigsError::InvalidParameterValue(err.msg),
3683 )
3684 }
3685 "ResourceNotFoundException" => {
3686 return RusotoError::Service(
3687 ListFunctionEventInvokeConfigsError::ResourceNotFound(err.msg),
3688 )
3689 }
3690 "ServiceException" => {
3691 return RusotoError::Service(ListFunctionEventInvokeConfigsError::Service(
3692 err.msg,
3693 ))
3694 }
3695 "TooManyRequestsException" => {
3696 return RusotoError::Service(
3697 ListFunctionEventInvokeConfigsError::TooManyRequests(err.msg),
3698 )
3699 }
3700 "ValidationException" => return RusotoError::Validation(err.msg),
3701 _ => {}
3702 }
3703 }
3704 RusotoError::Unknown(res)
3705 }
3706}
3707impl fmt::Display for ListFunctionEventInvokeConfigsError {
3708 #[allow(unused_variables)]
3709 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3710 match *self {
3711 ListFunctionEventInvokeConfigsError::InvalidParameterValue(ref cause) => {
3712 write!(f, "{}", cause)
3713 }
3714 ListFunctionEventInvokeConfigsError::ResourceNotFound(ref cause) => {
3715 write!(f, "{}", cause)
3716 }
3717 ListFunctionEventInvokeConfigsError::Service(ref cause) => write!(f, "{}", cause),
3718 ListFunctionEventInvokeConfigsError::TooManyRequests(ref cause) => {
3719 write!(f, "{}", cause)
3720 }
3721 }
3722 }
3723}
3724impl Error for ListFunctionEventInvokeConfigsError {}
3725#[derive(Debug, PartialEq)]
3727pub enum ListFunctionsError {
3728 InvalidParameterValue(String),
3730 Service(String),
3732 TooManyRequests(String),
3734}
3735
3736impl ListFunctionsError {
3737 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListFunctionsError> {
3738 if let Some(err) = proto::json::Error::parse_rest(&res) {
3739 match err.typ.as_str() {
3740 "InvalidParameterValueException" => {
3741 return RusotoError::Service(ListFunctionsError::InvalidParameterValue(err.msg))
3742 }
3743 "ServiceException" => {
3744 return RusotoError::Service(ListFunctionsError::Service(err.msg))
3745 }
3746 "TooManyRequestsException" => {
3747 return RusotoError::Service(ListFunctionsError::TooManyRequests(err.msg))
3748 }
3749 "ValidationException" => return RusotoError::Validation(err.msg),
3750 _ => {}
3751 }
3752 }
3753 RusotoError::Unknown(res)
3754 }
3755}
3756impl fmt::Display for ListFunctionsError {
3757 #[allow(unused_variables)]
3758 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3759 match *self {
3760 ListFunctionsError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3761 ListFunctionsError::Service(ref cause) => write!(f, "{}", cause),
3762 ListFunctionsError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3763 }
3764 }
3765}
3766impl Error for ListFunctionsError {}
3767#[derive(Debug, PartialEq)]
3769pub enum ListLayerVersionsError {
3770 InvalidParameterValue(String),
3772 ResourceNotFound(String),
3774 Service(String),
3776 TooManyRequests(String),
3778}
3779
3780impl ListLayerVersionsError {
3781 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListLayerVersionsError> {
3782 if let Some(err) = proto::json::Error::parse_rest(&res) {
3783 match err.typ.as_str() {
3784 "InvalidParameterValueException" => {
3785 return RusotoError::Service(ListLayerVersionsError::InvalidParameterValue(
3786 err.msg,
3787 ))
3788 }
3789 "ResourceNotFoundException" => {
3790 return RusotoError::Service(ListLayerVersionsError::ResourceNotFound(err.msg))
3791 }
3792 "ServiceException" => {
3793 return RusotoError::Service(ListLayerVersionsError::Service(err.msg))
3794 }
3795 "TooManyRequestsException" => {
3796 return RusotoError::Service(ListLayerVersionsError::TooManyRequests(err.msg))
3797 }
3798 "ValidationException" => return RusotoError::Validation(err.msg),
3799 _ => {}
3800 }
3801 }
3802 RusotoError::Unknown(res)
3803 }
3804}
3805impl fmt::Display for ListLayerVersionsError {
3806 #[allow(unused_variables)]
3807 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3808 match *self {
3809 ListLayerVersionsError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3810 ListLayerVersionsError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3811 ListLayerVersionsError::Service(ref cause) => write!(f, "{}", cause),
3812 ListLayerVersionsError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3813 }
3814 }
3815}
3816impl Error for ListLayerVersionsError {}
3817#[derive(Debug, PartialEq)]
3819pub enum ListLayersError {
3820 InvalidParameterValue(String),
3822 Service(String),
3824 TooManyRequests(String),
3826}
3827
3828impl ListLayersError {
3829 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListLayersError> {
3830 if let Some(err) = proto::json::Error::parse_rest(&res) {
3831 match err.typ.as_str() {
3832 "InvalidParameterValueException" => {
3833 return RusotoError::Service(ListLayersError::InvalidParameterValue(err.msg))
3834 }
3835 "ServiceException" => {
3836 return RusotoError::Service(ListLayersError::Service(err.msg))
3837 }
3838 "TooManyRequestsException" => {
3839 return RusotoError::Service(ListLayersError::TooManyRequests(err.msg))
3840 }
3841 "ValidationException" => return RusotoError::Validation(err.msg),
3842 _ => {}
3843 }
3844 }
3845 RusotoError::Unknown(res)
3846 }
3847}
3848impl fmt::Display for ListLayersError {
3849 #[allow(unused_variables)]
3850 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3851 match *self {
3852 ListLayersError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3853 ListLayersError::Service(ref cause) => write!(f, "{}", cause),
3854 ListLayersError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3855 }
3856 }
3857}
3858impl Error for ListLayersError {}
3859#[derive(Debug, PartialEq)]
3861pub enum ListProvisionedConcurrencyConfigsError {
3862 InvalidParameterValue(String),
3864 ResourceNotFound(String),
3866 Service(String),
3868 TooManyRequests(String),
3870}
3871
3872impl ListProvisionedConcurrencyConfigsError {
3873 pub fn from_response(
3874 res: BufferedHttpResponse,
3875 ) -> RusotoError<ListProvisionedConcurrencyConfigsError> {
3876 if let Some(err) = proto::json::Error::parse_rest(&res) {
3877 match err.typ.as_str() {
3878 "InvalidParameterValueException" => {
3879 return RusotoError::Service(
3880 ListProvisionedConcurrencyConfigsError::InvalidParameterValue(err.msg),
3881 )
3882 }
3883 "ResourceNotFoundException" => {
3884 return RusotoError::Service(
3885 ListProvisionedConcurrencyConfigsError::ResourceNotFound(err.msg),
3886 )
3887 }
3888 "ServiceException" => {
3889 return RusotoError::Service(ListProvisionedConcurrencyConfigsError::Service(
3890 err.msg,
3891 ))
3892 }
3893 "TooManyRequestsException" => {
3894 return RusotoError::Service(
3895 ListProvisionedConcurrencyConfigsError::TooManyRequests(err.msg),
3896 )
3897 }
3898 "ValidationException" => return RusotoError::Validation(err.msg),
3899 _ => {}
3900 }
3901 }
3902 RusotoError::Unknown(res)
3903 }
3904}
3905impl fmt::Display for ListProvisionedConcurrencyConfigsError {
3906 #[allow(unused_variables)]
3907 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3908 match *self {
3909 ListProvisionedConcurrencyConfigsError::InvalidParameterValue(ref cause) => {
3910 write!(f, "{}", cause)
3911 }
3912 ListProvisionedConcurrencyConfigsError::ResourceNotFound(ref cause) => {
3913 write!(f, "{}", cause)
3914 }
3915 ListProvisionedConcurrencyConfigsError::Service(ref cause) => write!(f, "{}", cause),
3916 ListProvisionedConcurrencyConfigsError::TooManyRequests(ref cause) => {
3917 write!(f, "{}", cause)
3918 }
3919 }
3920 }
3921}
3922impl Error for ListProvisionedConcurrencyConfigsError {}
3923#[derive(Debug, PartialEq)]
3925pub enum ListTagsError {
3926 InvalidParameterValue(String),
3928 ResourceNotFound(String),
3930 Service(String),
3932 TooManyRequests(String),
3934}
3935
3936impl ListTagsError {
3937 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListTagsError> {
3938 if let Some(err) = proto::json::Error::parse_rest(&res) {
3939 match err.typ.as_str() {
3940 "InvalidParameterValueException" => {
3941 return RusotoError::Service(ListTagsError::InvalidParameterValue(err.msg))
3942 }
3943 "ResourceNotFoundException" => {
3944 return RusotoError::Service(ListTagsError::ResourceNotFound(err.msg))
3945 }
3946 "ServiceException" => return RusotoError::Service(ListTagsError::Service(err.msg)),
3947 "TooManyRequestsException" => {
3948 return RusotoError::Service(ListTagsError::TooManyRequests(err.msg))
3949 }
3950 "ValidationException" => return RusotoError::Validation(err.msg),
3951 _ => {}
3952 }
3953 }
3954 RusotoError::Unknown(res)
3955 }
3956}
3957impl fmt::Display for ListTagsError {
3958 #[allow(unused_variables)]
3959 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3960 match *self {
3961 ListTagsError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
3962 ListTagsError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3963 ListTagsError::Service(ref cause) => write!(f, "{}", cause),
3964 ListTagsError::TooManyRequests(ref cause) => write!(f, "{}", cause),
3965 }
3966 }
3967}
3968impl Error for ListTagsError {}
3969#[derive(Debug, PartialEq)]
3971pub enum ListVersionsByFunctionError {
3972 InvalidParameterValue(String),
3974 ResourceNotFound(String),
3976 Service(String),
3978 TooManyRequests(String),
3980}
3981
3982impl ListVersionsByFunctionError {
3983 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListVersionsByFunctionError> {
3984 if let Some(err) = proto::json::Error::parse_rest(&res) {
3985 match err.typ.as_str() {
3986 "InvalidParameterValueException" => {
3987 return RusotoError::Service(
3988 ListVersionsByFunctionError::InvalidParameterValue(err.msg),
3989 )
3990 }
3991 "ResourceNotFoundException" => {
3992 return RusotoError::Service(ListVersionsByFunctionError::ResourceNotFound(
3993 err.msg,
3994 ))
3995 }
3996 "ServiceException" => {
3997 return RusotoError::Service(ListVersionsByFunctionError::Service(err.msg))
3998 }
3999 "TooManyRequestsException" => {
4000 return RusotoError::Service(ListVersionsByFunctionError::TooManyRequests(
4001 err.msg,
4002 ))
4003 }
4004 "ValidationException" => return RusotoError::Validation(err.msg),
4005 _ => {}
4006 }
4007 }
4008 RusotoError::Unknown(res)
4009 }
4010}
4011impl fmt::Display for ListVersionsByFunctionError {
4012 #[allow(unused_variables)]
4013 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4014 match *self {
4015 ListVersionsByFunctionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4016 ListVersionsByFunctionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4017 ListVersionsByFunctionError::Service(ref cause) => write!(f, "{}", cause),
4018 ListVersionsByFunctionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4019 }
4020 }
4021}
4022impl Error for ListVersionsByFunctionError {}
4023#[derive(Debug, PartialEq)]
4025pub enum PublishLayerVersionError {
4026 CodeStorageExceeded(String),
4028 InvalidParameterValue(String),
4030 ResourceNotFound(String),
4032 Service(String),
4034 TooManyRequests(String),
4036}
4037
4038impl PublishLayerVersionError {
4039 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<PublishLayerVersionError> {
4040 if let Some(err) = proto::json::Error::parse_rest(&res) {
4041 match err.typ.as_str() {
4042 "CodeStorageExceededException" => {
4043 return RusotoError::Service(PublishLayerVersionError::CodeStorageExceeded(
4044 err.msg,
4045 ))
4046 }
4047 "InvalidParameterValueException" => {
4048 return RusotoError::Service(PublishLayerVersionError::InvalidParameterValue(
4049 err.msg,
4050 ))
4051 }
4052 "ResourceNotFoundException" => {
4053 return RusotoError::Service(PublishLayerVersionError::ResourceNotFound(
4054 err.msg,
4055 ))
4056 }
4057 "ServiceException" => {
4058 return RusotoError::Service(PublishLayerVersionError::Service(err.msg))
4059 }
4060 "TooManyRequestsException" => {
4061 return RusotoError::Service(PublishLayerVersionError::TooManyRequests(err.msg))
4062 }
4063 "ValidationException" => return RusotoError::Validation(err.msg),
4064 _ => {}
4065 }
4066 }
4067 RusotoError::Unknown(res)
4068 }
4069}
4070impl fmt::Display for PublishLayerVersionError {
4071 #[allow(unused_variables)]
4072 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4073 match *self {
4074 PublishLayerVersionError::CodeStorageExceeded(ref cause) => write!(f, "{}", cause),
4075 PublishLayerVersionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4076 PublishLayerVersionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4077 PublishLayerVersionError::Service(ref cause) => write!(f, "{}", cause),
4078 PublishLayerVersionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4079 }
4080 }
4081}
4082impl Error for PublishLayerVersionError {}
4083#[derive(Debug, PartialEq)]
4085pub enum PublishVersionError {
4086 CodeStorageExceeded(String),
4088 InvalidParameterValue(String),
4090 PreconditionFailed(String),
4092 ResourceConflict(String),
4094 ResourceNotFound(String),
4096 Service(String),
4098 TooManyRequests(String),
4100}
4101
4102impl PublishVersionError {
4103 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<PublishVersionError> {
4104 if let Some(err) = proto::json::Error::parse_rest(&res) {
4105 match err.typ.as_str() {
4106 "CodeStorageExceededException" => {
4107 return RusotoError::Service(PublishVersionError::CodeStorageExceeded(err.msg))
4108 }
4109 "InvalidParameterValueException" => {
4110 return RusotoError::Service(PublishVersionError::InvalidParameterValue(
4111 err.msg,
4112 ))
4113 }
4114 "PreconditionFailedException" => {
4115 return RusotoError::Service(PublishVersionError::PreconditionFailed(err.msg))
4116 }
4117 "ResourceConflictException" => {
4118 return RusotoError::Service(PublishVersionError::ResourceConflict(err.msg))
4119 }
4120 "ResourceNotFoundException" => {
4121 return RusotoError::Service(PublishVersionError::ResourceNotFound(err.msg))
4122 }
4123 "ServiceException" => {
4124 return RusotoError::Service(PublishVersionError::Service(err.msg))
4125 }
4126 "TooManyRequestsException" => {
4127 return RusotoError::Service(PublishVersionError::TooManyRequests(err.msg))
4128 }
4129 "ValidationException" => return RusotoError::Validation(err.msg),
4130 _ => {}
4131 }
4132 }
4133 RusotoError::Unknown(res)
4134 }
4135}
4136impl fmt::Display for PublishVersionError {
4137 #[allow(unused_variables)]
4138 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4139 match *self {
4140 PublishVersionError::CodeStorageExceeded(ref cause) => write!(f, "{}", cause),
4141 PublishVersionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4142 PublishVersionError::PreconditionFailed(ref cause) => write!(f, "{}", cause),
4143 PublishVersionError::ResourceConflict(ref cause) => write!(f, "{}", cause),
4144 PublishVersionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4145 PublishVersionError::Service(ref cause) => write!(f, "{}", cause),
4146 PublishVersionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4147 }
4148 }
4149}
4150impl Error for PublishVersionError {}
4151#[derive(Debug, PartialEq)]
4153pub enum PutFunctionConcurrencyError {
4154 InvalidParameterValue(String),
4156 ResourceConflict(String),
4158 ResourceNotFound(String),
4160 Service(String),
4162 TooManyRequests(String),
4164}
4165
4166impl PutFunctionConcurrencyError {
4167 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<PutFunctionConcurrencyError> {
4168 if let Some(err) = proto::json::Error::parse_rest(&res) {
4169 match err.typ.as_str() {
4170 "InvalidParameterValueException" => {
4171 return RusotoError::Service(
4172 PutFunctionConcurrencyError::InvalidParameterValue(err.msg),
4173 )
4174 }
4175 "ResourceConflictException" => {
4176 return RusotoError::Service(PutFunctionConcurrencyError::ResourceConflict(
4177 err.msg,
4178 ))
4179 }
4180 "ResourceNotFoundException" => {
4181 return RusotoError::Service(PutFunctionConcurrencyError::ResourceNotFound(
4182 err.msg,
4183 ))
4184 }
4185 "ServiceException" => {
4186 return RusotoError::Service(PutFunctionConcurrencyError::Service(err.msg))
4187 }
4188 "TooManyRequestsException" => {
4189 return RusotoError::Service(PutFunctionConcurrencyError::TooManyRequests(
4190 err.msg,
4191 ))
4192 }
4193 "ValidationException" => return RusotoError::Validation(err.msg),
4194 _ => {}
4195 }
4196 }
4197 RusotoError::Unknown(res)
4198 }
4199}
4200impl fmt::Display for PutFunctionConcurrencyError {
4201 #[allow(unused_variables)]
4202 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4203 match *self {
4204 PutFunctionConcurrencyError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4205 PutFunctionConcurrencyError::ResourceConflict(ref cause) => write!(f, "{}", cause),
4206 PutFunctionConcurrencyError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4207 PutFunctionConcurrencyError::Service(ref cause) => write!(f, "{}", cause),
4208 PutFunctionConcurrencyError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4209 }
4210 }
4211}
4212impl Error for PutFunctionConcurrencyError {}
4213#[derive(Debug, PartialEq)]
4215pub enum PutFunctionEventInvokeConfigError {
4216 InvalidParameterValue(String),
4218 ResourceNotFound(String),
4220 Service(String),
4222 TooManyRequests(String),
4224}
4225
4226impl PutFunctionEventInvokeConfigError {
4227 pub fn from_response(
4228 res: BufferedHttpResponse,
4229 ) -> RusotoError<PutFunctionEventInvokeConfigError> {
4230 if let Some(err) = proto::json::Error::parse_rest(&res) {
4231 match err.typ.as_str() {
4232 "InvalidParameterValueException" => {
4233 return RusotoError::Service(
4234 PutFunctionEventInvokeConfigError::InvalidParameterValue(err.msg),
4235 )
4236 }
4237 "ResourceNotFoundException" => {
4238 return RusotoError::Service(
4239 PutFunctionEventInvokeConfigError::ResourceNotFound(err.msg),
4240 )
4241 }
4242 "ServiceException" => {
4243 return RusotoError::Service(PutFunctionEventInvokeConfigError::Service(
4244 err.msg,
4245 ))
4246 }
4247 "TooManyRequestsException" => {
4248 return RusotoError::Service(
4249 PutFunctionEventInvokeConfigError::TooManyRequests(err.msg),
4250 )
4251 }
4252 "ValidationException" => return RusotoError::Validation(err.msg),
4253 _ => {}
4254 }
4255 }
4256 RusotoError::Unknown(res)
4257 }
4258}
4259impl fmt::Display for PutFunctionEventInvokeConfigError {
4260 #[allow(unused_variables)]
4261 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4262 match *self {
4263 PutFunctionEventInvokeConfigError::InvalidParameterValue(ref cause) => {
4264 write!(f, "{}", cause)
4265 }
4266 PutFunctionEventInvokeConfigError::ResourceNotFound(ref cause) => {
4267 write!(f, "{}", cause)
4268 }
4269 PutFunctionEventInvokeConfigError::Service(ref cause) => write!(f, "{}", cause),
4270 PutFunctionEventInvokeConfigError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4271 }
4272 }
4273}
4274impl Error for PutFunctionEventInvokeConfigError {}
4275#[derive(Debug, PartialEq)]
4277pub enum PutProvisionedConcurrencyConfigError {
4278 InvalidParameterValue(String),
4280 ResourceConflict(String),
4282 ResourceNotFound(String),
4284 Service(String),
4286 TooManyRequests(String),
4288}
4289
4290impl PutProvisionedConcurrencyConfigError {
4291 pub fn from_response(
4292 res: BufferedHttpResponse,
4293 ) -> RusotoError<PutProvisionedConcurrencyConfigError> {
4294 if let Some(err) = proto::json::Error::parse_rest(&res) {
4295 match err.typ.as_str() {
4296 "InvalidParameterValueException" => {
4297 return RusotoError::Service(
4298 PutProvisionedConcurrencyConfigError::InvalidParameterValue(err.msg),
4299 )
4300 }
4301 "ResourceConflictException" => {
4302 return RusotoError::Service(
4303 PutProvisionedConcurrencyConfigError::ResourceConflict(err.msg),
4304 )
4305 }
4306 "ResourceNotFoundException" => {
4307 return RusotoError::Service(
4308 PutProvisionedConcurrencyConfigError::ResourceNotFound(err.msg),
4309 )
4310 }
4311 "ServiceException" => {
4312 return RusotoError::Service(PutProvisionedConcurrencyConfigError::Service(
4313 err.msg,
4314 ))
4315 }
4316 "TooManyRequestsException" => {
4317 return RusotoError::Service(
4318 PutProvisionedConcurrencyConfigError::TooManyRequests(err.msg),
4319 )
4320 }
4321 "ValidationException" => return RusotoError::Validation(err.msg),
4322 _ => {}
4323 }
4324 }
4325 RusotoError::Unknown(res)
4326 }
4327}
4328impl fmt::Display for PutProvisionedConcurrencyConfigError {
4329 #[allow(unused_variables)]
4330 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4331 match *self {
4332 PutProvisionedConcurrencyConfigError::InvalidParameterValue(ref cause) => {
4333 write!(f, "{}", cause)
4334 }
4335 PutProvisionedConcurrencyConfigError::ResourceConflict(ref cause) => {
4336 write!(f, "{}", cause)
4337 }
4338 PutProvisionedConcurrencyConfigError::ResourceNotFound(ref cause) => {
4339 write!(f, "{}", cause)
4340 }
4341 PutProvisionedConcurrencyConfigError::Service(ref cause) => write!(f, "{}", cause),
4342 PutProvisionedConcurrencyConfigError::TooManyRequests(ref cause) => {
4343 write!(f, "{}", cause)
4344 }
4345 }
4346 }
4347}
4348impl Error for PutProvisionedConcurrencyConfigError {}
4349#[derive(Debug, PartialEq)]
4351pub enum RemoveLayerVersionPermissionError {
4352 InvalidParameterValue(String),
4354 PreconditionFailed(String),
4356 ResourceNotFound(String),
4358 Service(String),
4360 TooManyRequests(String),
4362}
4363
4364impl RemoveLayerVersionPermissionError {
4365 pub fn from_response(
4366 res: BufferedHttpResponse,
4367 ) -> RusotoError<RemoveLayerVersionPermissionError> {
4368 if let Some(err) = proto::json::Error::parse_rest(&res) {
4369 match err.typ.as_str() {
4370 "InvalidParameterValueException" => {
4371 return RusotoError::Service(
4372 RemoveLayerVersionPermissionError::InvalidParameterValue(err.msg),
4373 )
4374 }
4375 "PreconditionFailedException" => {
4376 return RusotoError::Service(
4377 RemoveLayerVersionPermissionError::PreconditionFailed(err.msg),
4378 )
4379 }
4380 "ResourceNotFoundException" => {
4381 return RusotoError::Service(
4382 RemoveLayerVersionPermissionError::ResourceNotFound(err.msg),
4383 )
4384 }
4385 "ServiceException" => {
4386 return RusotoError::Service(RemoveLayerVersionPermissionError::Service(
4387 err.msg,
4388 ))
4389 }
4390 "TooManyRequestsException" => {
4391 return RusotoError::Service(
4392 RemoveLayerVersionPermissionError::TooManyRequests(err.msg),
4393 )
4394 }
4395 "ValidationException" => return RusotoError::Validation(err.msg),
4396 _ => {}
4397 }
4398 }
4399 RusotoError::Unknown(res)
4400 }
4401}
4402impl fmt::Display for RemoveLayerVersionPermissionError {
4403 #[allow(unused_variables)]
4404 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4405 match *self {
4406 RemoveLayerVersionPermissionError::InvalidParameterValue(ref cause) => {
4407 write!(f, "{}", cause)
4408 }
4409 RemoveLayerVersionPermissionError::PreconditionFailed(ref cause) => {
4410 write!(f, "{}", cause)
4411 }
4412 RemoveLayerVersionPermissionError::ResourceNotFound(ref cause) => {
4413 write!(f, "{}", cause)
4414 }
4415 RemoveLayerVersionPermissionError::Service(ref cause) => write!(f, "{}", cause),
4416 RemoveLayerVersionPermissionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4417 }
4418 }
4419}
4420impl Error for RemoveLayerVersionPermissionError {}
4421#[derive(Debug, PartialEq)]
4423pub enum RemovePermissionError {
4424 InvalidParameterValue(String),
4426 PreconditionFailed(String),
4428 ResourceNotFound(String),
4430 Service(String),
4432 TooManyRequests(String),
4434}
4435
4436impl RemovePermissionError {
4437 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<RemovePermissionError> {
4438 if let Some(err) = proto::json::Error::parse_rest(&res) {
4439 match err.typ.as_str() {
4440 "InvalidParameterValueException" => {
4441 return RusotoError::Service(RemovePermissionError::InvalidParameterValue(
4442 err.msg,
4443 ))
4444 }
4445 "PreconditionFailedException" => {
4446 return RusotoError::Service(RemovePermissionError::PreconditionFailed(err.msg))
4447 }
4448 "ResourceNotFoundException" => {
4449 return RusotoError::Service(RemovePermissionError::ResourceNotFound(err.msg))
4450 }
4451 "ServiceException" => {
4452 return RusotoError::Service(RemovePermissionError::Service(err.msg))
4453 }
4454 "TooManyRequestsException" => {
4455 return RusotoError::Service(RemovePermissionError::TooManyRequests(err.msg))
4456 }
4457 "ValidationException" => return RusotoError::Validation(err.msg),
4458 _ => {}
4459 }
4460 }
4461 RusotoError::Unknown(res)
4462 }
4463}
4464impl fmt::Display for RemovePermissionError {
4465 #[allow(unused_variables)]
4466 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4467 match *self {
4468 RemovePermissionError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4469 RemovePermissionError::PreconditionFailed(ref cause) => write!(f, "{}", cause),
4470 RemovePermissionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4471 RemovePermissionError::Service(ref cause) => write!(f, "{}", cause),
4472 RemovePermissionError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4473 }
4474 }
4475}
4476impl Error for RemovePermissionError {}
4477#[derive(Debug, PartialEq)]
4479pub enum TagResourceError {
4480 InvalidParameterValue(String),
4482 ResourceConflict(String),
4484 ResourceNotFound(String),
4486 Service(String),
4488 TooManyRequests(String),
4490}
4491
4492impl TagResourceError {
4493 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<TagResourceError> {
4494 if let Some(err) = proto::json::Error::parse_rest(&res) {
4495 match err.typ.as_str() {
4496 "InvalidParameterValueException" => {
4497 return RusotoError::Service(TagResourceError::InvalidParameterValue(err.msg))
4498 }
4499 "ResourceConflictException" => {
4500 return RusotoError::Service(TagResourceError::ResourceConflict(err.msg))
4501 }
4502 "ResourceNotFoundException" => {
4503 return RusotoError::Service(TagResourceError::ResourceNotFound(err.msg))
4504 }
4505 "ServiceException" => {
4506 return RusotoError::Service(TagResourceError::Service(err.msg))
4507 }
4508 "TooManyRequestsException" => {
4509 return RusotoError::Service(TagResourceError::TooManyRequests(err.msg))
4510 }
4511 "ValidationException" => return RusotoError::Validation(err.msg),
4512 _ => {}
4513 }
4514 }
4515 RusotoError::Unknown(res)
4516 }
4517}
4518impl fmt::Display for TagResourceError {
4519 #[allow(unused_variables)]
4520 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4521 match *self {
4522 TagResourceError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4523 TagResourceError::ResourceConflict(ref cause) => write!(f, "{}", cause),
4524 TagResourceError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4525 TagResourceError::Service(ref cause) => write!(f, "{}", cause),
4526 TagResourceError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4527 }
4528 }
4529}
4530impl Error for TagResourceError {}
4531#[derive(Debug, PartialEq)]
4533pub enum UntagResourceError {
4534 InvalidParameterValue(String),
4536 ResourceConflict(String),
4538 ResourceNotFound(String),
4540 Service(String),
4542 TooManyRequests(String),
4544}
4545
4546impl UntagResourceError {
4547 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UntagResourceError> {
4548 if let Some(err) = proto::json::Error::parse_rest(&res) {
4549 match err.typ.as_str() {
4550 "InvalidParameterValueException" => {
4551 return RusotoError::Service(UntagResourceError::InvalidParameterValue(err.msg))
4552 }
4553 "ResourceConflictException" => {
4554 return RusotoError::Service(UntagResourceError::ResourceConflict(err.msg))
4555 }
4556 "ResourceNotFoundException" => {
4557 return RusotoError::Service(UntagResourceError::ResourceNotFound(err.msg))
4558 }
4559 "ServiceException" => {
4560 return RusotoError::Service(UntagResourceError::Service(err.msg))
4561 }
4562 "TooManyRequestsException" => {
4563 return RusotoError::Service(UntagResourceError::TooManyRequests(err.msg))
4564 }
4565 "ValidationException" => return RusotoError::Validation(err.msg),
4566 _ => {}
4567 }
4568 }
4569 RusotoError::Unknown(res)
4570 }
4571}
4572impl fmt::Display for UntagResourceError {
4573 #[allow(unused_variables)]
4574 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4575 match *self {
4576 UntagResourceError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4577 UntagResourceError::ResourceConflict(ref cause) => write!(f, "{}", cause),
4578 UntagResourceError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4579 UntagResourceError::Service(ref cause) => write!(f, "{}", cause),
4580 UntagResourceError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4581 }
4582 }
4583}
4584impl Error for UntagResourceError {}
4585#[derive(Debug, PartialEq)]
4587pub enum UpdateAliasError {
4588 InvalidParameterValue(String),
4590 PreconditionFailed(String),
4592 ResourceConflict(String),
4594 ResourceNotFound(String),
4596 Service(String),
4598 TooManyRequests(String),
4600}
4601
4602impl UpdateAliasError {
4603 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UpdateAliasError> {
4604 if let Some(err) = proto::json::Error::parse_rest(&res) {
4605 match err.typ.as_str() {
4606 "InvalidParameterValueException" => {
4607 return RusotoError::Service(UpdateAliasError::InvalidParameterValue(err.msg))
4608 }
4609 "PreconditionFailedException" => {
4610 return RusotoError::Service(UpdateAliasError::PreconditionFailed(err.msg))
4611 }
4612 "ResourceConflictException" => {
4613 return RusotoError::Service(UpdateAliasError::ResourceConflict(err.msg))
4614 }
4615 "ResourceNotFoundException" => {
4616 return RusotoError::Service(UpdateAliasError::ResourceNotFound(err.msg))
4617 }
4618 "ServiceException" => {
4619 return RusotoError::Service(UpdateAliasError::Service(err.msg))
4620 }
4621 "TooManyRequestsException" => {
4622 return RusotoError::Service(UpdateAliasError::TooManyRequests(err.msg))
4623 }
4624 "ValidationException" => return RusotoError::Validation(err.msg),
4625 _ => {}
4626 }
4627 }
4628 RusotoError::Unknown(res)
4629 }
4630}
4631impl fmt::Display for UpdateAliasError {
4632 #[allow(unused_variables)]
4633 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4634 match *self {
4635 UpdateAliasError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4636 UpdateAliasError::PreconditionFailed(ref cause) => write!(f, "{}", cause),
4637 UpdateAliasError::ResourceConflict(ref cause) => write!(f, "{}", cause),
4638 UpdateAliasError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4639 UpdateAliasError::Service(ref cause) => write!(f, "{}", cause),
4640 UpdateAliasError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4641 }
4642 }
4643}
4644impl Error for UpdateAliasError {}
4645#[derive(Debug, PartialEq)]
4647pub enum UpdateEventSourceMappingError {
4648 InvalidParameterValue(String),
4650 ResourceConflict(String),
4652 ResourceInUse(String),
4654 ResourceNotFound(String),
4656 Service(String),
4658 TooManyRequests(String),
4660}
4661
4662impl UpdateEventSourceMappingError {
4663 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UpdateEventSourceMappingError> {
4664 if let Some(err) = proto::json::Error::parse_rest(&res) {
4665 match err.typ.as_str() {
4666 "InvalidParameterValueException" => {
4667 return RusotoError::Service(
4668 UpdateEventSourceMappingError::InvalidParameterValue(err.msg),
4669 )
4670 }
4671 "ResourceConflictException" => {
4672 return RusotoError::Service(UpdateEventSourceMappingError::ResourceConflict(
4673 err.msg,
4674 ))
4675 }
4676 "ResourceInUseException" => {
4677 return RusotoError::Service(UpdateEventSourceMappingError::ResourceInUse(
4678 err.msg,
4679 ))
4680 }
4681 "ResourceNotFoundException" => {
4682 return RusotoError::Service(UpdateEventSourceMappingError::ResourceNotFound(
4683 err.msg,
4684 ))
4685 }
4686 "ServiceException" => {
4687 return RusotoError::Service(UpdateEventSourceMappingError::Service(err.msg))
4688 }
4689 "TooManyRequestsException" => {
4690 return RusotoError::Service(UpdateEventSourceMappingError::TooManyRequests(
4691 err.msg,
4692 ))
4693 }
4694 "ValidationException" => return RusotoError::Validation(err.msg),
4695 _ => {}
4696 }
4697 }
4698 RusotoError::Unknown(res)
4699 }
4700}
4701impl fmt::Display for UpdateEventSourceMappingError {
4702 #[allow(unused_variables)]
4703 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4704 match *self {
4705 UpdateEventSourceMappingError::InvalidParameterValue(ref cause) => {
4706 write!(f, "{}", cause)
4707 }
4708 UpdateEventSourceMappingError::ResourceConflict(ref cause) => write!(f, "{}", cause),
4709 UpdateEventSourceMappingError::ResourceInUse(ref cause) => write!(f, "{}", cause),
4710 UpdateEventSourceMappingError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4711 UpdateEventSourceMappingError::Service(ref cause) => write!(f, "{}", cause),
4712 UpdateEventSourceMappingError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4713 }
4714 }
4715}
4716impl Error for UpdateEventSourceMappingError {}
4717#[derive(Debug, PartialEq)]
4719pub enum UpdateFunctionCodeError {
4720 CodeStorageExceeded(String),
4722 InvalidParameterValue(String),
4724 PreconditionFailed(String),
4726 ResourceConflict(String),
4728 ResourceNotFound(String),
4730 Service(String),
4732 TooManyRequests(String),
4734}
4735
4736impl UpdateFunctionCodeError {
4737 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UpdateFunctionCodeError> {
4738 if let Some(err) = proto::json::Error::parse_rest(&res) {
4739 match err.typ.as_str() {
4740 "CodeStorageExceededException" => {
4741 return RusotoError::Service(UpdateFunctionCodeError::CodeStorageExceeded(
4742 err.msg,
4743 ))
4744 }
4745 "InvalidParameterValueException" => {
4746 return RusotoError::Service(UpdateFunctionCodeError::InvalidParameterValue(
4747 err.msg,
4748 ))
4749 }
4750 "PreconditionFailedException" => {
4751 return RusotoError::Service(UpdateFunctionCodeError::PreconditionFailed(
4752 err.msg,
4753 ))
4754 }
4755 "ResourceConflictException" => {
4756 return RusotoError::Service(UpdateFunctionCodeError::ResourceConflict(err.msg))
4757 }
4758 "ResourceNotFoundException" => {
4759 return RusotoError::Service(UpdateFunctionCodeError::ResourceNotFound(err.msg))
4760 }
4761 "ServiceException" => {
4762 return RusotoError::Service(UpdateFunctionCodeError::Service(err.msg))
4763 }
4764 "TooManyRequestsException" => {
4765 return RusotoError::Service(UpdateFunctionCodeError::TooManyRequests(err.msg))
4766 }
4767 "ValidationException" => return RusotoError::Validation(err.msg),
4768 _ => {}
4769 }
4770 }
4771 RusotoError::Unknown(res)
4772 }
4773}
4774impl fmt::Display for UpdateFunctionCodeError {
4775 #[allow(unused_variables)]
4776 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4777 match *self {
4778 UpdateFunctionCodeError::CodeStorageExceeded(ref cause) => write!(f, "{}", cause),
4779 UpdateFunctionCodeError::InvalidParameterValue(ref cause) => write!(f, "{}", cause),
4780 UpdateFunctionCodeError::PreconditionFailed(ref cause) => write!(f, "{}", cause),
4781 UpdateFunctionCodeError::ResourceConflict(ref cause) => write!(f, "{}", cause),
4782 UpdateFunctionCodeError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4783 UpdateFunctionCodeError::Service(ref cause) => write!(f, "{}", cause),
4784 UpdateFunctionCodeError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4785 }
4786 }
4787}
4788impl Error for UpdateFunctionCodeError {}
4789#[derive(Debug, PartialEq)]
4791pub enum UpdateFunctionConfigurationError {
4792 InvalidParameterValue(String),
4794 PreconditionFailed(String),
4796 ResourceConflict(String),
4798 ResourceNotFound(String),
4800 Service(String),
4802 TooManyRequests(String),
4804}
4805
4806impl UpdateFunctionConfigurationError {
4807 pub fn from_response(
4808 res: BufferedHttpResponse,
4809 ) -> RusotoError<UpdateFunctionConfigurationError> {
4810 if let Some(err) = proto::json::Error::parse_rest(&res) {
4811 match err.typ.as_str() {
4812 "InvalidParameterValueException" => {
4813 return RusotoError::Service(
4814 UpdateFunctionConfigurationError::InvalidParameterValue(err.msg),
4815 )
4816 }
4817 "PreconditionFailedException" => {
4818 return RusotoError::Service(
4819 UpdateFunctionConfigurationError::PreconditionFailed(err.msg),
4820 )
4821 }
4822 "ResourceConflictException" => {
4823 return RusotoError::Service(
4824 UpdateFunctionConfigurationError::ResourceConflict(err.msg),
4825 )
4826 }
4827 "ResourceNotFoundException" => {
4828 return RusotoError::Service(
4829 UpdateFunctionConfigurationError::ResourceNotFound(err.msg),
4830 )
4831 }
4832 "ServiceException" => {
4833 return RusotoError::Service(UpdateFunctionConfigurationError::Service(err.msg))
4834 }
4835 "TooManyRequestsException" => {
4836 return RusotoError::Service(UpdateFunctionConfigurationError::TooManyRequests(
4837 err.msg,
4838 ))
4839 }
4840 "ValidationException" => return RusotoError::Validation(err.msg),
4841 _ => {}
4842 }
4843 }
4844 RusotoError::Unknown(res)
4845 }
4846}
4847impl fmt::Display for UpdateFunctionConfigurationError {
4848 #[allow(unused_variables)]
4849 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4850 match *self {
4851 UpdateFunctionConfigurationError::InvalidParameterValue(ref cause) => {
4852 write!(f, "{}", cause)
4853 }
4854 UpdateFunctionConfigurationError::PreconditionFailed(ref cause) => {
4855 write!(f, "{}", cause)
4856 }
4857 UpdateFunctionConfigurationError::ResourceConflict(ref cause) => write!(f, "{}", cause),
4858 UpdateFunctionConfigurationError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
4859 UpdateFunctionConfigurationError::Service(ref cause) => write!(f, "{}", cause),
4860 UpdateFunctionConfigurationError::TooManyRequests(ref cause) => write!(f, "{}", cause),
4861 }
4862 }
4863}
4864impl Error for UpdateFunctionConfigurationError {}
4865#[derive(Debug, PartialEq)]
4867pub enum UpdateFunctionEventInvokeConfigError {
4868 InvalidParameterValue(String),
4870 ResourceNotFound(String),
4872 Service(String),
4874 TooManyRequests(String),
4876}
4877
4878impl UpdateFunctionEventInvokeConfigError {
4879 pub fn from_response(
4880 res: BufferedHttpResponse,
4881 ) -> RusotoError<UpdateFunctionEventInvokeConfigError> {
4882 if let Some(err) = proto::json::Error::parse_rest(&res) {
4883 match err.typ.as_str() {
4884 "InvalidParameterValueException" => {
4885 return RusotoError::Service(
4886 UpdateFunctionEventInvokeConfigError::InvalidParameterValue(err.msg),
4887 )
4888 }
4889 "ResourceNotFoundException" => {
4890 return RusotoError::Service(
4891 UpdateFunctionEventInvokeConfigError::ResourceNotFound(err.msg),
4892 )
4893 }
4894 "ServiceException" => {
4895 return RusotoError::Service(UpdateFunctionEventInvokeConfigError::Service(
4896 err.msg,
4897 ))
4898 }
4899 "TooManyRequestsException" => {
4900 return RusotoError::Service(
4901 UpdateFunctionEventInvokeConfigError::TooManyRequests(err.msg),
4902 )
4903 }
4904 "ValidationException" => return RusotoError::Validation(err.msg),
4905 _ => {}
4906 }
4907 }
4908 RusotoError::Unknown(res)
4909 }
4910}
4911impl fmt::Display for UpdateFunctionEventInvokeConfigError {
4912 #[allow(unused_variables)]
4913 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
4914 match *self {
4915 UpdateFunctionEventInvokeConfigError::InvalidParameterValue(ref cause) => {
4916 write!(f, "{}", cause)
4917 }
4918 UpdateFunctionEventInvokeConfigError::ResourceNotFound(ref cause) => {
4919 write!(f, "{}", cause)
4920 }
4921 UpdateFunctionEventInvokeConfigError::Service(ref cause) => write!(f, "{}", cause),
4922 UpdateFunctionEventInvokeConfigError::TooManyRequests(ref cause) => {
4923 write!(f, "{}", cause)
4924 }
4925 }
4926 }
4927}
4928impl Error for UpdateFunctionEventInvokeConfigError {}
4929#[async_trait]
4931pub trait Lambda {
4932 async fn add_layer_version_permission(
4934 &self,
4935 input: AddLayerVersionPermissionRequest,
4936 ) -> Result<AddLayerVersionPermissionResponse, RusotoError<AddLayerVersionPermissionError>>;
4937
4938 async fn add_permission(
4940 &self,
4941 input: AddPermissionRequest,
4942 ) -> Result<AddPermissionResponse, RusotoError<AddPermissionError>>;
4943
4944 async fn create_alias(
4946 &self,
4947 input: CreateAliasRequest,
4948 ) -> Result<AliasConfiguration, RusotoError<CreateAliasError>>;
4949
4950 async fn create_event_source_mapping(
4952 &self,
4953 input: CreateEventSourceMappingRequest,
4954 ) -> Result<EventSourceMappingConfiguration, RusotoError<CreateEventSourceMappingError>>;
4955
4956 async fn create_function(
4958 &self,
4959 input: CreateFunctionRequest,
4960 ) -> Result<FunctionConfiguration, RusotoError<CreateFunctionError>>;
4961
4962 async fn delete_alias(
4964 &self,
4965 input: DeleteAliasRequest,
4966 ) -> Result<(), RusotoError<DeleteAliasError>>;
4967
4968 async fn delete_event_source_mapping(
4970 &self,
4971 input: DeleteEventSourceMappingRequest,
4972 ) -> Result<EventSourceMappingConfiguration, RusotoError<DeleteEventSourceMappingError>>;
4973
4974 async fn delete_function(
4976 &self,
4977 input: DeleteFunctionRequest,
4978 ) -> Result<(), RusotoError<DeleteFunctionError>>;
4979
4980 async fn delete_function_concurrency(
4982 &self,
4983 input: DeleteFunctionConcurrencyRequest,
4984 ) -> Result<(), RusotoError<DeleteFunctionConcurrencyError>>;
4985
4986 async fn delete_function_event_invoke_config(
4988 &self,
4989 input: DeleteFunctionEventInvokeConfigRequest,
4990 ) -> Result<(), RusotoError<DeleteFunctionEventInvokeConfigError>>;
4991
4992 async fn delete_layer_version(
4994 &self,
4995 input: DeleteLayerVersionRequest,
4996 ) -> Result<(), RusotoError<DeleteLayerVersionError>>;
4997
4998 async fn delete_provisioned_concurrency_config(
5000 &self,
5001 input: DeleteProvisionedConcurrencyConfigRequest,
5002 ) -> Result<(), RusotoError<DeleteProvisionedConcurrencyConfigError>>;
5003
5004 async fn get_account_settings(
5006 &self,
5007 ) -> Result<GetAccountSettingsResponse, RusotoError<GetAccountSettingsError>>;
5008
5009 async fn get_alias(
5011 &self,
5012 input: GetAliasRequest,
5013 ) -> Result<AliasConfiguration, RusotoError<GetAliasError>>;
5014
5015 async fn get_event_source_mapping(
5017 &self,
5018 input: GetEventSourceMappingRequest,
5019 ) -> Result<EventSourceMappingConfiguration, RusotoError<GetEventSourceMappingError>>;
5020
5021 async fn get_function(
5023 &self,
5024 input: GetFunctionRequest,
5025 ) -> Result<GetFunctionResponse, RusotoError<GetFunctionError>>;
5026
5027 async fn get_function_concurrency(
5029 &self,
5030 input: GetFunctionConcurrencyRequest,
5031 ) -> Result<GetFunctionConcurrencyResponse, RusotoError<GetFunctionConcurrencyError>>;
5032
5033 async fn get_function_configuration(
5035 &self,
5036 input: GetFunctionConfigurationRequest,
5037 ) -> Result<FunctionConfiguration, RusotoError<GetFunctionConfigurationError>>;
5038
5039 async fn get_function_event_invoke_config(
5041 &self,
5042 input: GetFunctionEventInvokeConfigRequest,
5043 ) -> Result<FunctionEventInvokeConfig, RusotoError<GetFunctionEventInvokeConfigError>>;
5044
5045 async fn get_layer_version(
5047 &self,
5048 input: GetLayerVersionRequest,
5049 ) -> Result<GetLayerVersionResponse, RusotoError<GetLayerVersionError>>;
5050
5051 async fn get_layer_version_by_arn(
5053 &self,
5054 input: GetLayerVersionByArnRequest,
5055 ) -> Result<GetLayerVersionResponse, RusotoError<GetLayerVersionByArnError>>;
5056
5057 async fn get_layer_version_policy(
5059 &self,
5060 input: GetLayerVersionPolicyRequest,
5061 ) -> Result<GetLayerVersionPolicyResponse, RusotoError<GetLayerVersionPolicyError>>;
5062
5063 async fn get_policy(
5065 &self,
5066 input: GetPolicyRequest,
5067 ) -> Result<GetPolicyResponse, RusotoError<GetPolicyError>>;
5068
5069 async fn get_provisioned_concurrency_config(
5071 &self,
5072 input: GetProvisionedConcurrencyConfigRequest,
5073 ) -> Result<
5074 GetProvisionedConcurrencyConfigResponse,
5075 RusotoError<GetProvisionedConcurrencyConfigError>,
5076 >;
5077
5078 async fn invoke(
5080 &self,
5081 input: InvocationRequest,
5082 ) -> Result<InvocationResponse, RusotoError<InvokeError>>;
5083
5084 async fn invoke_async(
5086 &self,
5087 input: InvokeAsyncRequest,
5088 ) -> Result<InvokeAsyncResponse, RusotoError<InvokeAsyncError>>;
5089
5090 async fn list_aliases(
5092 &self,
5093 input: ListAliasesRequest,
5094 ) -> Result<ListAliasesResponse, RusotoError<ListAliasesError>>;
5095
5096 async fn list_event_source_mappings(
5098 &self,
5099 input: ListEventSourceMappingsRequest,
5100 ) -> Result<ListEventSourceMappingsResponse, RusotoError<ListEventSourceMappingsError>>;
5101
5102 async fn list_function_event_invoke_configs(
5104 &self,
5105 input: ListFunctionEventInvokeConfigsRequest,
5106 ) -> Result<
5107 ListFunctionEventInvokeConfigsResponse,
5108 RusotoError<ListFunctionEventInvokeConfigsError>,
5109 >;
5110
5111 async fn list_functions(
5113 &self,
5114 input: ListFunctionsRequest,
5115 ) -> Result<ListFunctionsResponse, RusotoError<ListFunctionsError>>;
5116
5117 async fn list_layer_versions(
5119 &self,
5120 input: ListLayerVersionsRequest,
5121 ) -> Result<ListLayerVersionsResponse, RusotoError<ListLayerVersionsError>>;
5122
5123 async fn list_layers(
5125 &self,
5126 input: ListLayersRequest,
5127 ) -> Result<ListLayersResponse, RusotoError<ListLayersError>>;
5128
5129 async fn list_provisioned_concurrency_configs(
5131 &self,
5132 input: ListProvisionedConcurrencyConfigsRequest,
5133 ) -> Result<
5134 ListProvisionedConcurrencyConfigsResponse,
5135 RusotoError<ListProvisionedConcurrencyConfigsError>,
5136 >;
5137
5138 async fn list_tags(
5140 &self,
5141 input: ListTagsRequest,
5142 ) -> Result<ListTagsResponse, RusotoError<ListTagsError>>;
5143
5144 async fn list_versions_by_function(
5146 &self,
5147 input: ListVersionsByFunctionRequest,
5148 ) -> Result<ListVersionsByFunctionResponse, RusotoError<ListVersionsByFunctionError>>;
5149
5150 async fn publish_layer_version(
5152 &self,
5153 input: PublishLayerVersionRequest,
5154 ) -> Result<PublishLayerVersionResponse, RusotoError<PublishLayerVersionError>>;
5155
5156 async fn publish_version(
5158 &self,
5159 input: PublishVersionRequest,
5160 ) -> Result<FunctionConfiguration, RusotoError<PublishVersionError>>;
5161
5162 async fn put_function_concurrency(
5164 &self,
5165 input: PutFunctionConcurrencyRequest,
5166 ) -> Result<Concurrency, RusotoError<PutFunctionConcurrencyError>>;
5167
5168 async fn put_function_event_invoke_config(
5170 &self,
5171 input: PutFunctionEventInvokeConfigRequest,
5172 ) -> Result<FunctionEventInvokeConfig, RusotoError<PutFunctionEventInvokeConfigError>>;
5173
5174 async fn put_provisioned_concurrency_config(
5176 &self,
5177 input: PutProvisionedConcurrencyConfigRequest,
5178 ) -> Result<
5179 PutProvisionedConcurrencyConfigResponse,
5180 RusotoError<PutProvisionedConcurrencyConfigError>,
5181 >;
5182
5183 async fn remove_layer_version_permission(
5185 &self,
5186 input: RemoveLayerVersionPermissionRequest,
5187 ) -> Result<(), RusotoError<RemoveLayerVersionPermissionError>>;
5188
5189 async fn remove_permission(
5191 &self,
5192 input: RemovePermissionRequest,
5193 ) -> Result<(), RusotoError<RemovePermissionError>>;
5194
5195 async fn tag_resource(
5197 &self,
5198 input: TagResourceRequest,
5199 ) -> Result<(), RusotoError<TagResourceError>>;
5200
5201 async fn untag_resource(
5203 &self,
5204 input: UntagResourceRequest,
5205 ) -> Result<(), RusotoError<UntagResourceError>>;
5206
5207 async fn update_alias(
5209 &self,
5210 input: UpdateAliasRequest,
5211 ) -> Result<AliasConfiguration, RusotoError<UpdateAliasError>>;
5212
5213 async fn update_event_source_mapping(
5215 &self,
5216 input: UpdateEventSourceMappingRequest,
5217 ) -> Result<EventSourceMappingConfiguration, RusotoError<UpdateEventSourceMappingError>>;
5218
5219 async fn update_function_code(
5221 &self,
5222 input: UpdateFunctionCodeRequest,
5223 ) -> Result<FunctionConfiguration, RusotoError<UpdateFunctionCodeError>>;
5224
5225 async fn update_function_configuration(
5227 &self,
5228 input: UpdateFunctionConfigurationRequest,
5229 ) -> Result<FunctionConfiguration, RusotoError<UpdateFunctionConfigurationError>>;
5230
5231 async fn update_function_event_invoke_config(
5233 &self,
5234 input: UpdateFunctionEventInvokeConfigRequest,
5235 ) -> Result<FunctionEventInvokeConfig, RusotoError<UpdateFunctionEventInvokeConfigError>>;
5236}
5237#[derive(Clone)]
5239pub struct LambdaClient {
5240 client: Client,
5241 region: region::Region,
5242}
5243
5244impl LambdaClient {
5245 pub fn new(region: region::Region) -> LambdaClient {
5249 LambdaClient {
5250 client: Client::shared(),
5251 region,
5252 }
5253 }
5254
5255 pub fn new_with<P, D>(
5256 request_dispatcher: D,
5257 credentials_provider: P,
5258 region: region::Region,
5259 ) -> LambdaClient
5260 where
5261 P: ProvideAwsCredentials + Send + Sync + 'static,
5262 D: DispatchSignedRequest + Send + Sync + 'static,
5263 {
5264 LambdaClient {
5265 client: Client::new_with(credentials_provider, request_dispatcher),
5266 region,
5267 }
5268 }
5269
5270 pub fn new_with_client(client: Client, region: region::Region) -> LambdaClient {
5271 LambdaClient { client, region }
5272 }
5273}
5274
5275#[async_trait]
5276impl Lambda for LambdaClient {
5277 #[allow(unused_mut)]
5279 async fn add_layer_version_permission(
5280 &self,
5281 input: AddLayerVersionPermissionRequest,
5282 ) -> Result<AddLayerVersionPermissionResponse, RusotoError<AddLayerVersionPermissionError>>
5283 {
5284 let request_uri = format!(
5285 "/2018-10-31/layers/{layer_name}/versions/{version_number}/policy",
5286 layer_name = input.layer_name,
5287 version_number = input.version_number
5288 );
5289
5290 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
5291 request.set_content_type("application/x-amz-json-1.1".to_owned());
5292
5293 let encoded = Some(serde_json::to_vec(&input).unwrap());
5294 request.set_payload(encoded);
5295
5296 let mut params = Params::new();
5297 if let Some(ref x) = input.revision_id {
5298 params.put("RevisionId", x);
5299 }
5300 request.set_params(params);
5301
5302 let mut response = self
5303 .client
5304 .sign_and_dispatch(request)
5305 .await
5306 .map_err(RusotoError::from)?;
5307 if response.status.as_u16() == 201 {
5308 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5309 let result = proto::json::ResponsePayload::new(&response)
5310 .deserialize::<AddLayerVersionPermissionResponse, _>()?;
5311
5312 Ok(result)
5313 } else {
5314 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5315 Err(AddLayerVersionPermissionError::from_response(response))
5316 }
5317 }
5318
5319 #[allow(unused_mut)]
5321 async fn add_permission(
5322 &self,
5323 input: AddPermissionRequest,
5324 ) -> Result<AddPermissionResponse, RusotoError<AddPermissionError>> {
5325 let request_uri = format!(
5326 "/2015-03-31/functions/{function_name}/policy",
5327 function_name = input.function_name
5328 );
5329
5330 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
5331 request.set_content_type("application/x-amz-json-1.1".to_owned());
5332
5333 let encoded = Some(serde_json::to_vec(&input).unwrap());
5334 request.set_payload(encoded);
5335
5336 let mut params = Params::new();
5337 if let Some(ref x) = input.qualifier {
5338 params.put("Qualifier", x);
5339 }
5340 request.set_params(params);
5341
5342 let mut response = self
5343 .client
5344 .sign_and_dispatch(request)
5345 .await
5346 .map_err(RusotoError::from)?;
5347 if response.status.as_u16() == 201 {
5348 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5349 let result = proto::json::ResponsePayload::new(&response)
5350 .deserialize::<AddPermissionResponse, _>()?;
5351
5352 Ok(result)
5353 } else {
5354 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5355 Err(AddPermissionError::from_response(response))
5356 }
5357 }
5358
5359 #[allow(unused_mut)]
5361 async fn create_alias(
5362 &self,
5363 input: CreateAliasRequest,
5364 ) -> Result<AliasConfiguration, RusotoError<CreateAliasError>> {
5365 let request_uri = format!(
5366 "/2015-03-31/functions/{function_name}/aliases",
5367 function_name = input.function_name
5368 );
5369
5370 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
5371 request.set_content_type("application/x-amz-json-1.1".to_owned());
5372
5373 let encoded = Some(serde_json::to_vec(&input).unwrap());
5374 request.set_payload(encoded);
5375
5376 let mut response = self
5377 .client
5378 .sign_and_dispatch(request)
5379 .await
5380 .map_err(RusotoError::from)?;
5381 if response.status.as_u16() == 201 {
5382 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5383 let result = proto::json::ResponsePayload::new(&response)
5384 .deserialize::<AliasConfiguration, _>()?;
5385
5386 Ok(result)
5387 } else {
5388 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5389 Err(CreateAliasError::from_response(response))
5390 }
5391 }
5392
5393 #[allow(unused_mut)]
5395 async fn create_event_source_mapping(
5396 &self,
5397 input: CreateEventSourceMappingRequest,
5398 ) -> Result<EventSourceMappingConfiguration, RusotoError<CreateEventSourceMappingError>> {
5399 let request_uri = "/2015-03-31/event-source-mappings/";
5400
5401 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
5402 request.set_content_type("application/x-amz-json-1.1".to_owned());
5403
5404 let encoded = Some(serde_json::to_vec(&input).unwrap());
5405 request.set_payload(encoded);
5406
5407 let mut response = self
5408 .client
5409 .sign_and_dispatch(request)
5410 .await
5411 .map_err(RusotoError::from)?;
5412 if response.status.as_u16() == 202 {
5413 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5414 let result = proto::json::ResponsePayload::new(&response)
5415 .deserialize::<EventSourceMappingConfiguration, _>()?;
5416
5417 Ok(result)
5418 } else {
5419 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5420 Err(CreateEventSourceMappingError::from_response(response))
5421 }
5422 }
5423
5424 #[allow(unused_mut)]
5426 async fn create_function(
5427 &self,
5428 input: CreateFunctionRequest,
5429 ) -> Result<FunctionConfiguration, RusotoError<CreateFunctionError>> {
5430 let request_uri = "/2015-03-31/functions";
5431
5432 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
5433 request.set_content_type("application/x-amz-json-1.1".to_owned());
5434
5435 let encoded = Some(serde_json::to_vec(&input).unwrap());
5436 request.set_payload(encoded);
5437
5438 let mut response = self
5439 .client
5440 .sign_and_dispatch(request)
5441 .await
5442 .map_err(RusotoError::from)?;
5443 if response.status.as_u16() == 201 {
5444 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5445 let result = proto::json::ResponsePayload::new(&response)
5446 .deserialize::<FunctionConfiguration, _>()?;
5447
5448 Ok(result)
5449 } else {
5450 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5451 Err(CreateFunctionError::from_response(response))
5452 }
5453 }
5454
5455 #[allow(unused_mut)]
5457 async fn delete_alias(
5458 &self,
5459 input: DeleteAliasRequest,
5460 ) -> Result<(), RusotoError<DeleteAliasError>> {
5461 let request_uri = format!(
5462 "/2015-03-31/functions/{function_name}/aliases/{name}",
5463 function_name = input.function_name,
5464 name = input.name
5465 );
5466
5467 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
5468 request.set_content_type("application/x-amz-json-1.1".to_owned());
5469
5470 let mut response = self
5471 .client
5472 .sign_and_dispatch(request)
5473 .await
5474 .map_err(RusotoError::from)?;
5475 if response.status.as_u16() == 204 {
5476 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5477 let result = ::std::mem::drop(response);
5478
5479 Ok(result)
5480 } else {
5481 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5482 Err(DeleteAliasError::from_response(response))
5483 }
5484 }
5485
5486 #[allow(unused_mut)]
5488 async fn delete_event_source_mapping(
5489 &self,
5490 input: DeleteEventSourceMappingRequest,
5491 ) -> Result<EventSourceMappingConfiguration, RusotoError<DeleteEventSourceMappingError>> {
5492 let request_uri = format!(
5493 "/2015-03-31/event-source-mappings/{uuid}",
5494 uuid = input.uuid
5495 );
5496
5497 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
5498 request.set_content_type("application/x-amz-json-1.1".to_owned());
5499
5500 let mut response = self
5501 .client
5502 .sign_and_dispatch(request)
5503 .await
5504 .map_err(RusotoError::from)?;
5505 if response.status.as_u16() == 202 {
5506 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5507 let result = proto::json::ResponsePayload::new(&response)
5508 .deserialize::<EventSourceMappingConfiguration, _>()?;
5509
5510 Ok(result)
5511 } else {
5512 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5513 Err(DeleteEventSourceMappingError::from_response(response))
5514 }
5515 }
5516
5517 #[allow(unused_mut)]
5519 async fn delete_function(
5520 &self,
5521 input: DeleteFunctionRequest,
5522 ) -> Result<(), RusotoError<DeleteFunctionError>> {
5523 let request_uri = format!(
5524 "/2015-03-31/functions/{function_name}",
5525 function_name = input.function_name
5526 );
5527
5528 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
5529 request.set_content_type("application/x-amz-json-1.1".to_owned());
5530
5531 let mut params = Params::new();
5532 if let Some(ref x) = input.qualifier {
5533 params.put("Qualifier", x);
5534 }
5535 request.set_params(params);
5536
5537 let mut response = self
5538 .client
5539 .sign_and_dispatch(request)
5540 .await
5541 .map_err(RusotoError::from)?;
5542 if response.status.as_u16() == 204 {
5543 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5544 let result = ::std::mem::drop(response);
5545
5546 Ok(result)
5547 } else {
5548 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5549 Err(DeleteFunctionError::from_response(response))
5550 }
5551 }
5552
5553 #[allow(unused_mut)]
5555 async fn delete_function_concurrency(
5556 &self,
5557 input: DeleteFunctionConcurrencyRequest,
5558 ) -> Result<(), RusotoError<DeleteFunctionConcurrencyError>> {
5559 let request_uri = format!(
5560 "/2017-10-31/functions/{function_name}/concurrency",
5561 function_name = input.function_name
5562 );
5563
5564 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
5565 request.set_content_type("application/x-amz-json-1.1".to_owned());
5566
5567 let mut response = self
5568 .client
5569 .sign_and_dispatch(request)
5570 .await
5571 .map_err(RusotoError::from)?;
5572 if response.status.as_u16() == 204 {
5573 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5574 let result = ::std::mem::drop(response);
5575
5576 Ok(result)
5577 } else {
5578 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5579 Err(DeleteFunctionConcurrencyError::from_response(response))
5580 }
5581 }
5582
5583 #[allow(unused_mut)]
5585 async fn delete_function_event_invoke_config(
5586 &self,
5587 input: DeleteFunctionEventInvokeConfigRequest,
5588 ) -> Result<(), RusotoError<DeleteFunctionEventInvokeConfigError>> {
5589 let request_uri = format!(
5590 "/2019-09-25/functions/{function_name}/event-invoke-config",
5591 function_name = input.function_name
5592 );
5593
5594 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
5595 request.set_content_type("application/x-amz-json-1.1".to_owned());
5596
5597 let mut params = Params::new();
5598 if let Some(ref x) = input.qualifier {
5599 params.put("Qualifier", x);
5600 }
5601 request.set_params(params);
5602
5603 let mut response = self
5604 .client
5605 .sign_and_dispatch(request)
5606 .await
5607 .map_err(RusotoError::from)?;
5608 if response.status.as_u16() == 204 {
5609 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5610 let result = ::std::mem::drop(response);
5611
5612 Ok(result)
5613 } else {
5614 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5615 Err(DeleteFunctionEventInvokeConfigError::from_response(
5616 response,
5617 ))
5618 }
5619 }
5620
5621 #[allow(unused_mut)]
5623 async fn delete_layer_version(
5624 &self,
5625 input: DeleteLayerVersionRequest,
5626 ) -> Result<(), RusotoError<DeleteLayerVersionError>> {
5627 let request_uri = format!(
5628 "/2018-10-31/layers/{layer_name}/versions/{version_number}",
5629 layer_name = input.layer_name,
5630 version_number = input.version_number
5631 );
5632
5633 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
5634 request.set_content_type("application/x-amz-json-1.1".to_owned());
5635
5636 let mut response = self
5637 .client
5638 .sign_and_dispatch(request)
5639 .await
5640 .map_err(RusotoError::from)?;
5641 if response.status.as_u16() == 204 {
5642 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5643 let result = ::std::mem::drop(response);
5644
5645 Ok(result)
5646 } else {
5647 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5648 Err(DeleteLayerVersionError::from_response(response))
5649 }
5650 }
5651
5652 #[allow(unused_mut)]
5654 async fn delete_provisioned_concurrency_config(
5655 &self,
5656 input: DeleteProvisionedConcurrencyConfigRequest,
5657 ) -> Result<(), RusotoError<DeleteProvisionedConcurrencyConfigError>> {
5658 let request_uri = format!(
5659 "/2019-09-30/functions/{function_name}/provisioned-concurrency",
5660 function_name = input.function_name
5661 );
5662
5663 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
5664 request.set_content_type("application/x-amz-json-1.1".to_owned());
5665
5666 let mut params = Params::new();
5667 params.put("Qualifier", &input.qualifier);
5668 request.set_params(params);
5669
5670 let mut response = self
5671 .client
5672 .sign_and_dispatch(request)
5673 .await
5674 .map_err(RusotoError::from)?;
5675 if response.status.as_u16() == 204 {
5676 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5677 let result = ::std::mem::drop(response);
5678
5679 Ok(result)
5680 } else {
5681 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5682 Err(DeleteProvisionedConcurrencyConfigError::from_response(
5683 response,
5684 ))
5685 }
5686 }
5687
5688 #[allow(unused_mut)]
5690 async fn get_account_settings(
5691 &self,
5692 ) -> Result<GetAccountSettingsResponse, RusotoError<GetAccountSettingsError>> {
5693 let request_uri = "/2016-08-19/account-settings/";
5694
5695 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5696 request.set_content_type("application/x-amz-json-1.1".to_owned());
5697
5698 let mut response = self
5699 .client
5700 .sign_and_dispatch(request)
5701 .await
5702 .map_err(RusotoError::from)?;
5703 if response.status.as_u16() == 200 {
5704 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5705 let result = proto::json::ResponsePayload::new(&response)
5706 .deserialize::<GetAccountSettingsResponse, _>()?;
5707
5708 Ok(result)
5709 } else {
5710 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5711 Err(GetAccountSettingsError::from_response(response))
5712 }
5713 }
5714
5715 #[allow(unused_mut)]
5717 async fn get_alias(
5718 &self,
5719 input: GetAliasRequest,
5720 ) -> Result<AliasConfiguration, RusotoError<GetAliasError>> {
5721 let request_uri = format!(
5722 "/2015-03-31/functions/{function_name}/aliases/{name}",
5723 function_name = input.function_name,
5724 name = input.name
5725 );
5726
5727 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5728 request.set_content_type("application/x-amz-json-1.1".to_owned());
5729
5730 let mut response = self
5731 .client
5732 .sign_and_dispatch(request)
5733 .await
5734 .map_err(RusotoError::from)?;
5735 if response.status.as_u16() == 200 {
5736 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5737 let result = proto::json::ResponsePayload::new(&response)
5738 .deserialize::<AliasConfiguration, _>()?;
5739
5740 Ok(result)
5741 } else {
5742 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5743 Err(GetAliasError::from_response(response))
5744 }
5745 }
5746
5747 #[allow(unused_mut)]
5749 async fn get_event_source_mapping(
5750 &self,
5751 input: GetEventSourceMappingRequest,
5752 ) -> Result<EventSourceMappingConfiguration, RusotoError<GetEventSourceMappingError>> {
5753 let request_uri = format!(
5754 "/2015-03-31/event-source-mappings/{uuid}",
5755 uuid = input.uuid
5756 );
5757
5758 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5759 request.set_content_type("application/x-amz-json-1.1".to_owned());
5760
5761 let mut response = self
5762 .client
5763 .sign_and_dispatch(request)
5764 .await
5765 .map_err(RusotoError::from)?;
5766 if response.status.as_u16() == 200 {
5767 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5768 let result = proto::json::ResponsePayload::new(&response)
5769 .deserialize::<EventSourceMappingConfiguration, _>()?;
5770
5771 Ok(result)
5772 } else {
5773 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5774 Err(GetEventSourceMappingError::from_response(response))
5775 }
5776 }
5777
5778 #[allow(unused_mut)]
5780 async fn get_function(
5781 &self,
5782 input: GetFunctionRequest,
5783 ) -> Result<GetFunctionResponse, RusotoError<GetFunctionError>> {
5784 let request_uri = format!(
5785 "/2015-03-31/functions/{function_name}",
5786 function_name = input.function_name
5787 );
5788
5789 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5790 request.set_content_type("application/x-amz-json-1.1".to_owned());
5791
5792 let mut params = Params::new();
5793 if let Some(ref x) = input.qualifier {
5794 params.put("Qualifier", x);
5795 }
5796 request.set_params(params);
5797
5798 let mut response = self
5799 .client
5800 .sign_and_dispatch(request)
5801 .await
5802 .map_err(RusotoError::from)?;
5803 if response.status.as_u16() == 200 {
5804 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5805 let result = proto::json::ResponsePayload::new(&response)
5806 .deserialize::<GetFunctionResponse, _>()?;
5807
5808 Ok(result)
5809 } else {
5810 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5811 Err(GetFunctionError::from_response(response))
5812 }
5813 }
5814
5815 #[allow(unused_mut)]
5817 async fn get_function_concurrency(
5818 &self,
5819 input: GetFunctionConcurrencyRequest,
5820 ) -> Result<GetFunctionConcurrencyResponse, RusotoError<GetFunctionConcurrencyError>> {
5821 let request_uri = format!(
5822 "/2019-09-30/functions/{function_name}/concurrency",
5823 function_name = input.function_name
5824 );
5825
5826 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5827 request.set_content_type("application/x-amz-json-1.1".to_owned());
5828
5829 let mut response = self
5830 .client
5831 .sign_and_dispatch(request)
5832 .await
5833 .map_err(RusotoError::from)?;
5834 if response.status.as_u16() == 200 {
5835 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5836 let result = proto::json::ResponsePayload::new(&response)
5837 .deserialize::<GetFunctionConcurrencyResponse, _>()?;
5838
5839 Ok(result)
5840 } else {
5841 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5842 Err(GetFunctionConcurrencyError::from_response(response))
5843 }
5844 }
5845
5846 #[allow(unused_mut)]
5848 async fn get_function_configuration(
5849 &self,
5850 input: GetFunctionConfigurationRequest,
5851 ) -> Result<FunctionConfiguration, RusotoError<GetFunctionConfigurationError>> {
5852 let request_uri = format!(
5853 "/2015-03-31/functions/{function_name}/configuration",
5854 function_name = input.function_name
5855 );
5856
5857 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5858 request.set_content_type("application/x-amz-json-1.1".to_owned());
5859
5860 let mut params = Params::new();
5861 if let Some(ref x) = input.qualifier {
5862 params.put("Qualifier", x);
5863 }
5864 request.set_params(params);
5865
5866 let mut response = self
5867 .client
5868 .sign_and_dispatch(request)
5869 .await
5870 .map_err(RusotoError::from)?;
5871 if response.status.as_u16() == 200 {
5872 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5873 let result = proto::json::ResponsePayload::new(&response)
5874 .deserialize::<FunctionConfiguration, _>()?;
5875
5876 Ok(result)
5877 } else {
5878 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5879 Err(GetFunctionConfigurationError::from_response(response))
5880 }
5881 }
5882
5883 #[allow(unused_mut)]
5885 async fn get_function_event_invoke_config(
5886 &self,
5887 input: GetFunctionEventInvokeConfigRequest,
5888 ) -> Result<FunctionEventInvokeConfig, RusotoError<GetFunctionEventInvokeConfigError>> {
5889 let request_uri = format!(
5890 "/2019-09-25/functions/{function_name}/event-invoke-config",
5891 function_name = input.function_name
5892 );
5893
5894 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5895 request.set_content_type("application/x-amz-json-1.1".to_owned());
5896
5897 let mut params = Params::new();
5898 if let Some(ref x) = input.qualifier {
5899 params.put("Qualifier", x);
5900 }
5901 request.set_params(params);
5902
5903 let mut response = self
5904 .client
5905 .sign_and_dispatch(request)
5906 .await
5907 .map_err(RusotoError::from)?;
5908 if response.status.as_u16() == 200 {
5909 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5910 let result = proto::json::ResponsePayload::new(&response)
5911 .deserialize::<FunctionEventInvokeConfig, _>()?;
5912
5913 Ok(result)
5914 } else {
5915 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5916 Err(GetFunctionEventInvokeConfigError::from_response(response))
5917 }
5918 }
5919
5920 #[allow(unused_mut)]
5922 async fn get_layer_version(
5923 &self,
5924 input: GetLayerVersionRequest,
5925 ) -> Result<GetLayerVersionResponse, RusotoError<GetLayerVersionError>> {
5926 let request_uri = format!(
5927 "/2018-10-31/layers/{layer_name}/versions/{version_number}",
5928 layer_name = input.layer_name,
5929 version_number = input.version_number
5930 );
5931
5932 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5933 request.set_content_type("application/x-amz-json-1.1".to_owned());
5934
5935 let mut response = self
5936 .client
5937 .sign_and_dispatch(request)
5938 .await
5939 .map_err(RusotoError::from)?;
5940 if response.status.as_u16() == 200 {
5941 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5942 let result = proto::json::ResponsePayload::new(&response)
5943 .deserialize::<GetLayerVersionResponse, _>()?;
5944
5945 Ok(result)
5946 } else {
5947 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5948 Err(GetLayerVersionError::from_response(response))
5949 }
5950 }
5951
5952 #[allow(unused_mut)]
5954 async fn get_layer_version_by_arn(
5955 &self,
5956 input: GetLayerVersionByArnRequest,
5957 ) -> Result<GetLayerVersionResponse, RusotoError<GetLayerVersionByArnError>> {
5958 let request_uri = "/2018-10-31/layers";
5959
5960 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5961 request.set_content_type("application/x-amz-json-1.1".to_owned());
5962
5963 let mut params = Params::new();
5964 params.put("Arn", &input.arn);
5965 params.put("find", "LayerVersion");
5966 request.set_params(params);
5967
5968 let mut response = self
5969 .client
5970 .sign_and_dispatch(request)
5971 .await
5972 .map_err(RusotoError::from)?;
5973 if response.status.as_u16() == 200 {
5974 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5975 let result = proto::json::ResponsePayload::new(&response)
5976 .deserialize::<GetLayerVersionResponse, _>()?;
5977
5978 Ok(result)
5979 } else {
5980 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
5981 Err(GetLayerVersionByArnError::from_response(response))
5982 }
5983 }
5984
5985 #[allow(unused_mut)]
5987 async fn get_layer_version_policy(
5988 &self,
5989 input: GetLayerVersionPolicyRequest,
5990 ) -> Result<GetLayerVersionPolicyResponse, RusotoError<GetLayerVersionPolicyError>> {
5991 let request_uri = format!(
5992 "/2018-10-31/layers/{layer_name}/versions/{version_number}/policy",
5993 layer_name = input.layer_name,
5994 version_number = input.version_number
5995 );
5996
5997 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
5998 request.set_content_type("application/x-amz-json-1.1".to_owned());
5999
6000 let mut response = self
6001 .client
6002 .sign_and_dispatch(request)
6003 .await
6004 .map_err(RusotoError::from)?;
6005 if response.status.as_u16() == 200 {
6006 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6007 let result = proto::json::ResponsePayload::new(&response)
6008 .deserialize::<GetLayerVersionPolicyResponse, _>()?;
6009
6010 Ok(result)
6011 } else {
6012 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6013 Err(GetLayerVersionPolicyError::from_response(response))
6014 }
6015 }
6016
6017 #[allow(unused_mut)]
6019 async fn get_policy(
6020 &self,
6021 input: GetPolicyRequest,
6022 ) -> Result<GetPolicyResponse, RusotoError<GetPolicyError>> {
6023 let request_uri = format!(
6024 "/2015-03-31/functions/{function_name}/policy",
6025 function_name = input.function_name
6026 );
6027
6028 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6029 request.set_content_type("application/x-amz-json-1.1".to_owned());
6030
6031 let mut params = Params::new();
6032 if let Some(ref x) = input.qualifier {
6033 params.put("Qualifier", x);
6034 }
6035 request.set_params(params);
6036
6037 let mut response = self
6038 .client
6039 .sign_and_dispatch(request)
6040 .await
6041 .map_err(RusotoError::from)?;
6042 if response.status.as_u16() == 200 {
6043 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6044 let result = proto::json::ResponsePayload::new(&response)
6045 .deserialize::<GetPolicyResponse, _>()?;
6046
6047 Ok(result)
6048 } else {
6049 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6050 Err(GetPolicyError::from_response(response))
6051 }
6052 }
6053
6054 #[allow(unused_mut)]
6056 async fn get_provisioned_concurrency_config(
6057 &self,
6058 input: GetProvisionedConcurrencyConfigRequest,
6059 ) -> Result<
6060 GetProvisionedConcurrencyConfigResponse,
6061 RusotoError<GetProvisionedConcurrencyConfigError>,
6062 > {
6063 let request_uri = format!(
6064 "/2019-09-30/functions/{function_name}/provisioned-concurrency",
6065 function_name = input.function_name
6066 );
6067
6068 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6069 request.set_content_type("application/x-amz-json-1.1".to_owned());
6070
6071 let mut params = Params::new();
6072 params.put("Qualifier", &input.qualifier);
6073 request.set_params(params);
6074
6075 let mut response = self
6076 .client
6077 .sign_and_dispatch(request)
6078 .await
6079 .map_err(RusotoError::from)?;
6080 if response.status.as_u16() == 200 {
6081 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6082 let result = proto::json::ResponsePayload::new(&response)
6083 .deserialize::<GetProvisionedConcurrencyConfigResponse, _>()?;
6084
6085 Ok(result)
6086 } else {
6087 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6088 Err(GetProvisionedConcurrencyConfigError::from_response(
6089 response,
6090 ))
6091 }
6092 }
6093
6094 #[allow(unused_mut)]
6096 async fn invoke(
6097 &self,
6098 input: InvocationRequest,
6099 ) -> Result<InvocationResponse, RusotoError<InvokeError>> {
6100 let request_uri = format!(
6101 "/2015-03-31/functions/{function_name}/invocations",
6102 function_name = input.function_name
6103 );
6104
6105 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
6106 request.set_content_type("application/x-amz-json-1.1".to_owned());
6107
6108 let encoded = if let Some(ref payload) = input.payload {
6109 Some(payload.to_owned())
6110 } else {
6111 None
6112 };
6113 request.set_payload(encoded);
6114 request.add_optional_header("X-Amz-Client-Context", input.client_context.as_ref());
6115 request.add_optional_header("X-Amz-Invocation-Type", input.invocation_type.as_ref());
6116 request.add_optional_header("X-Amz-Log-Type", input.log_type.as_ref());
6117 let mut params = Params::new();
6118 if let Some(ref x) = input.qualifier {
6119 params.put("Qualifier", x);
6120 }
6121 request.set_params(params);
6122
6123 let mut response = self
6124 .client
6125 .sign_and_dispatch(request)
6126 .await
6127 .map_err(RusotoError::from)?;
6128 if response.status.is_success() {
6129 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6130
6131 let mut result = InvocationResponse::default();
6132 result.payload = Some(response.body);
6133
6134 result.executed_version = response.headers.remove("X-Amz-Executed-Version");
6135 result.function_error = response.headers.remove("X-Amz-Function-Error");
6136 result.log_result = response.headers.remove("X-Amz-Log-Result");
6137 result.status_code = Some(response.status.as_u16() as i64);
6138 Ok(result)
6139 } else {
6140 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6141 Err(InvokeError::from_response(response))
6142 }
6143 }
6144
6145 #[allow(unused_mut)]
6147 async fn invoke_async(
6148 &self,
6149 input: InvokeAsyncRequest,
6150 ) -> Result<InvokeAsyncResponse, RusotoError<InvokeAsyncError>> {
6151 let request_uri = format!(
6152 "/2014-11-13/functions/{function_name}/invoke-async/",
6153 function_name = input.function_name
6154 );
6155
6156 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
6157 request.set_content_type("application/x-amz-json-1.1".to_owned());
6158
6159 let encoded = Some(input.invoke_args.to_owned());
6160 request.set_payload(encoded);
6161
6162 let mut response = self
6163 .client
6164 .sign_and_dispatch(request)
6165 .await
6166 .map_err(RusotoError::from)?;
6167 if response.status.as_u16() == 202 {
6168 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6169 let mut result = proto::json::ResponsePayload::new(&response)
6170 .deserialize::<InvokeAsyncResponse, _>()?;
6171
6172 result.status = Some(response.status.as_u16() as i64);
6173 Ok(result)
6174 } else {
6175 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6176 Err(InvokeAsyncError::from_response(response))
6177 }
6178 }
6179
6180 #[allow(unused_mut)]
6182 async fn list_aliases(
6183 &self,
6184 input: ListAliasesRequest,
6185 ) -> Result<ListAliasesResponse, RusotoError<ListAliasesError>> {
6186 let request_uri = format!(
6187 "/2015-03-31/functions/{function_name}/aliases",
6188 function_name = input.function_name
6189 );
6190
6191 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6192 request.set_content_type("application/x-amz-json-1.1".to_owned());
6193
6194 let mut params = Params::new();
6195 if let Some(ref x) = input.function_version {
6196 params.put("FunctionVersion", x);
6197 }
6198 if let Some(ref x) = input.marker {
6199 params.put("Marker", x);
6200 }
6201 if let Some(ref x) = input.max_items {
6202 params.put("MaxItems", x);
6203 }
6204 request.set_params(params);
6205
6206 let mut response = self
6207 .client
6208 .sign_and_dispatch(request)
6209 .await
6210 .map_err(RusotoError::from)?;
6211 if response.status.as_u16() == 200 {
6212 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6213 let result = proto::json::ResponsePayload::new(&response)
6214 .deserialize::<ListAliasesResponse, _>()?;
6215
6216 Ok(result)
6217 } else {
6218 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6219 Err(ListAliasesError::from_response(response))
6220 }
6221 }
6222
6223 #[allow(unused_mut)]
6225 async fn list_event_source_mappings(
6226 &self,
6227 input: ListEventSourceMappingsRequest,
6228 ) -> Result<ListEventSourceMappingsResponse, RusotoError<ListEventSourceMappingsError>> {
6229 let request_uri = "/2015-03-31/event-source-mappings/";
6230
6231 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6232 request.set_content_type("application/x-amz-json-1.1".to_owned());
6233
6234 let mut params = Params::new();
6235 if let Some(ref x) = input.event_source_arn {
6236 params.put("EventSourceArn", x);
6237 }
6238 if let Some(ref x) = input.function_name {
6239 params.put("FunctionName", x);
6240 }
6241 if let Some(ref x) = input.marker {
6242 params.put("Marker", x);
6243 }
6244 if let Some(ref x) = input.max_items {
6245 params.put("MaxItems", x);
6246 }
6247 request.set_params(params);
6248
6249 let mut response = self
6250 .client
6251 .sign_and_dispatch(request)
6252 .await
6253 .map_err(RusotoError::from)?;
6254 if response.status.as_u16() == 200 {
6255 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6256 let result = proto::json::ResponsePayload::new(&response)
6257 .deserialize::<ListEventSourceMappingsResponse, _>()?;
6258
6259 Ok(result)
6260 } else {
6261 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6262 Err(ListEventSourceMappingsError::from_response(response))
6263 }
6264 }
6265
6266 #[allow(unused_mut)]
6268 async fn list_function_event_invoke_configs(
6269 &self,
6270 input: ListFunctionEventInvokeConfigsRequest,
6271 ) -> Result<
6272 ListFunctionEventInvokeConfigsResponse,
6273 RusotoError<ListFunctionEventInvokeConfigsError>,
6274 > {
6275 let request_uri = format!(
6276 "/2019-09-25/functions/{function_name}/event-invoke-config/list",
6277 function_name = input.function_name
6278 );
6279
6280 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6281 request.set_content_type("application/x-amz-json-1.1".to_owned());
6282
6283 let mut params = Params::new();
6284 if let Some(ref x) = input.marker {
6285 params.put("Marker", x);
6286 }
6287 if let Some(ref x) = input.max_items {
6288 params.put("MaxItems", x);
6289 }
6290 request.set_params(params);
6291
6292 let mut response = self
6293 .client
6294 .sign_and_dispatch(request)
6295 .await
6296 .map_err(RusotoError::from)?;
6297 if response.status.as_u16() == 200 {
6298 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6299 let result = proto::json::ResponsePayload::new(&response)
6300 .deserialize::<ListFunctionEventInvokeConfigsResponse, _>()?;
6301
6302 Ok(result)
6303 } else {
6304 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6305 Err(ListFunctionEventInvokeConfigsError::from_response(response))
6306 }
6307 }
6308
6309 #[allow(unused_mut)]
6311 async fn list_functions(
6312 &self,
6313 input: ListFunctionsRequest,
6314 ) -> Result<ListFunctionsResponse, RusotoError<ListFunctionsError>> {
6315 let request_uri = "/2015-03-31/functions/";
6316
6317 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6318 request.set_content_type("application/x-amz-json-1.1".to_owned());
6319
6320 let mut params = Params::new();
6321 if let Some(ref x) = input.function_version {
6322 params.put("FunctionVersion", x);
6323 }
6324 if let Some(ref x) = input.marker {
6325 params.put("Marker", x);
6326 }
6327 if let Some(ref x) = input.master_region {
6328 params.put("MasterRegion", x);
6329 }
6330 if let Some(ref x) = input.max_items {
6331 params.put("MaxItems", x);
6332 }
6333 request.set_params(params);
6334
6335 let mut response = self
6336 .client
6337 .sign_and_dispatch(request)
6338 .await
6339 .map_err(RusotoError::from)?;
6340 if response.status.as_u16() == 200 {
6341 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6342 let result = proto::json::ResponsePayload::new(&response)
6343 .deserialize::<ListFunctionsResponse, _>()?;
6344
6345 Ok(result)
6346 } else {
6347 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6348 Err(ListFunctionsError::from_response(response))
6349 }
6350 }
6351
6352 #[allow(unused_mut)]
6354 async fn list_layer_versions(
6355 &self,
6356 input: ListLayerVersionsRequest,
6357 ) -> Result<ListLayerVersionsResponse, RusotoError<ListLayerVersionsError>> {
6358 let request_uri = format!(
6359 "/2018-10-31/layers/{layer_name}/versions",
6360 layer_name = input.layer_name
6361 );
6362
6363 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6364 request.set_content_type("application/x-amz-json-1.1".to_owned());
6365
6366 let mut params = Params::new();
6367 if let Some(ref x) = input.compatible_runtime {
6368 params.put("CompatibleRuntime", x);
6369 }
6370 if let Some(ref x) = input.marker {
6371 params.put("Marker", x);
6372 }
6373 if let Some(ref x) = input.max_items {
6374 params.put("MaxItems", x);
6375 }
6376 request.set_params(params);
6377
6378 let mut response = self
6379 .client
6380 .sign_and_dispatch(request)
6381 .await
6382 .map_err(RusotoError::from)?;
6383 if response.status.as_u16() == 200 {
6384 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6385 let result = proto::json::ResponsePayload::new(&response)
6386 .deserialize::<ListLayerVersionsResponse, _>()?;
6387
6388 Ok(result)
6389 } else {
6390 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6391 Err(ListLayerVersionsError::from_response(response))
6392 }
6393 }
6394
6395 #[allow(unused_mut)]
6397 async fn list_layers(
6398 &self,
6399 input: ListLayersRequest,
6400 ) -> Result<ListLayersResponse, RusotoError<ListLayersError>> {
6401 let request_uri = "/2018-10-31/layers";
6402
6403 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6404 request.set_content_type("application/x-amz-json-1.1".to_owned());
6405
6406 let mut params = Params::new();
6407 if let Some(ref x) = input.compatible_runtime {
6408 params.put("CompatibleRuntime", x);
6409 }
6410 if let Some(ref x) = input.marker {
6411 params.put("Marker", x);
6412 }
6413 if let Some(ref x) = input.max_items {
6414 params.put("MaxItems", x);
6415 }
6416 request.set_params(params);
6417
6418 let mut response = self
6419 .client
6420 .sign_and_dispatch(request)
6421 .await
6422 .map_err(RusotoError::from)?;
6423 if response.status.as_u16() == 200 {
6424 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6425 let result = proto::json::ResponsePayload::new(&response)
6426 .deserialize::<ListLayersResponse, _>()?;
6427
6428 Ok(result)
6429 } else {
6430 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6431 Err(ListLayersError::from_response(response))
6432 }
6433 }
6434
6435 #[allow(unused_mut)]
6437 async fn list_provisioned_concurrency_configs(
6438 &self,
6439 input: ListProvisionedConcurrencyConfigsRequest,
6440 ) -> Result<
6441 ListProvisionedConcurrencyConfigsResponse,
6442 RusotoError<ListProvisionedConcurrencyConfigsError>,
6443 > {
6444 let request_uri = format!(
6445 "/2019-09-30/functions/{function_name}/provisioned-concurrency",
6446 function_name = input.function_name
6447 );
6448
6449 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6450 request.set_content_type("application/x-amz-json-1.1".to_owned());
6451
6452 let mut params = Params::new();
6453 if let Some(ref x) = input.marker {
6454 params.put("Marker", x);
6455 }
6456 if let Some(ref x) = input.max_items {
6457 params.put("MaxItems", x);
6458 }
6459 params.put("List", "ALL");
6460 request.set_params(params);
6461
6462 let mut response = self
6463 .client
6464 .sign_and_dispatch(request)
6465 .await
6466 .map_err(RusotoError::from)?;
6467 if response.status.as_u16() == 200 {
6468 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6469 let result = proto::json::ResponsePayload::new(&response)
6470 .deserialize::<ListProvisionedConcurrencyConfigsResponse, _>()?;
6471
6472 Ok(result)
6473 } else {
6474 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6475 Err(ListProvisionedConcurrencyConfigsError::from_response(
6476 response,
6477 ))
6478 }
6479 }
6480
6481 #[allow(unused_mut)]
6483 async fn list_tags(
6484 &self,
6485 input: ListTagsRequest,
6486 ) -> Result<ListTagsResponse, RusotoError<ListTagsError>> {
6487 let request_uri = format!("/2017-03-31/tags/{arn}", arn = input.resource);
6488
6489 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6490 request.set_content_type("application/x-amz-json-1.1".to_owned());
6491
6492 let mut response = self
6493 .client
6494 .sign_and_dispatch(request)
6495 .await
6496 .map_err(RusotoError::from)?;
6497 if response.status.is_success() {
6498 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6499 let result = proto::json::ResponsePayload::new(&response)
6500 .deserialize::<ListTagsResponse, _>()?;
6501
6502 Ok(result)
6503 } else {
6504 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6505 Err(ListTagsError::from_response(response))
6506 }
6507 }
6508
6509 #[allow(unused_mut)]
6511 async fn list_versions_by_function(
6512 &self,
6513 input: ListVersionsByFunctionRequest,
6514 ) -> Result<ListVersionsByFunctionResponse, RusotoError<ListVersionsByFunctionError>> {
6515 let request_uri = format!(
6516 "/2015-03-31/functions/{function_name}/versions",
6517 function_name = input.function_name
6518 );
6519
6520 let mut request = SignedRequest::new("GET", "lambda", &self.region, &request_uri);
6521 request.set_content_type("application/x-amz-json-1.1".to_owned());
6522
6523 let mut params = Params::new();
6524 if let Some(ref x) = input.marker {
6525 params.put("Marker", x);
6526 }
6527 if let Some(ref x) = input.max_items {
6528 params.put("MaxItems", x);
6529 }
6530 request.set_params(params);
6531
6532 let mut response = self
6533 .client
6534 .sign_and_dispatch(request)
6535 .await
6536 .map_err(RusotoError::from)?;
6537 if response.status.as_u16() == 200 {
6538 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6539 let result = proto::json::ResponsePayload::new(&response)
6540 .deserialize::<ListVersionsByFunctionResponse, _>()?;
6541
6542 Ok(result)
6543 } else {
6544 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6545 Err(ListVersionsByFunctionError::from_response(response))
6546 }
6547 }
6548
6549 #[allow(unused_mut)]
6551 async fn publish_layer_version(
6552 &self,
6553 input: PublishLayerVersionRequest,
6554 ) -> Result<PublishLayerVersionResponse, RusotoError<PublishLayerVersionError>> {
6555 let request_uri = format!(
6556 "/2018-10-31/layers/{layer_name}/versions",
6557 layer_name = input.layer_name
6558 );
6559
6560 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
6561 request.set_content_type("application/x-amz-json-1.1".to_owned());
6562
6563 let encoded = Some(serde_json::to_vec(&input).unwrap());
6564 request.set_payload(encoded);
6565
6566 let mut response = self
6567 .client
6568 .sign_and_dispatch(request)
6569 .await
6570 .map_err(RusotoError::from)?;
6571 if response.status.as_u16() == 201 {
6572 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6573 let result = proto::json::ResponsePayload::new(&response)
6574 .deserialize::<PublishLayerVersionResponse, _>()?;
6575
6576 Ok(result)
6577 } else {
6578 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6579 Err(PublishLayerVersionError::from_response(response))
6580 }
6581 }
6582
6583 #[allow(unused_mut)]
6585 async fn publish_version(
6586 &self,
6587 input: PublishVersionRequest,
6588 ) -> Result<FunctionConfiguration, RusotoError<PublishVersionError>> {
6589 let request_uri = format!(
6590 "/2015-03-31/functions/{function_name}/versions",
6591 function_name = input.function_name
6592 );
6593
6594 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
6595 request.set_content_type("application/x-amz-json-1.1".to_owned());
6596
6597 let encoded = Some(serde_json::to_vec(&input).unwrap());
6598 request.set_payload(encoded);
6599
6600 let mut response = self
6601 .client
6602 .sign_and_dispatch(request)
6603 .await
6604 .map_err(RusotoError::from)?;
6605 if response.status.as_u16() == 201 {
6606 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6607 let result = proto::json::ResponsePayload::new(&response)
6608 .deserialize::<FunctionConfiguration, _>()?;
6609
6610 Ok(result)
6611 } else {
6612 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6613 Err(PublishVersionError::from_response(response))
6614 }
6615 }
6616
6617 #[allow(unused_mut)]
6619 async fn put_function_concurrency(
6620 &self,
6621 input: PutFunctionConcurrencyRequest,
6622 ) -> Result<Concurrency, RusotoError<PutFunctionConcurrencyError>> {
6623 let request_uri = format!(
6624 "/2017-10-31/functions/{function_name}/concurrency",
6625 function_name = input.function_name
6626 );
6627
6628 let mut request = SignedRequest::new("PUT", "lambda", &self.region, &request_uri);
6629 request.set_content_type("application/x-amz-json-1.1".to_owned());
6630
6631 let encoded = Some(serde_json::to_vec(&input).unwrap());
6632 request.set_payload(encoded);
6633
6634 let mut response = self
6635 .client
6636 .sign_and_dispatch(request)
6637 .await
6638 .map_err(RusotoError::from)?;
6639 if response.status.as_u16() == 200 {
6640 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6641 let result =
6642 proto::json::ResponsePayload::new(&response).deserialize::<Concurrency, _>()?;
6643
6644 Ok(result)
6645 } else {
6646 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6647 Err(PutFunctionConcurrencyError::from_response(response))
6648 }
6649 }
6650
6651 #[allow(unused_mut)]
6653 async fn put_function_event_invoke_config(
6654 &self,
6655 input: PutFunctionEventInvokeConfigRequest,
6656 ) -> Result<FunctionEventInvokeConfig, RusotoError<PutFunctionEventInvokeConfigError>> {
6657 let request_uri = format!(
6658 "/2019-09-25/functions/{function_name}/event-invoke-config",
6659 function_name = input.function_name
6660 );
6661
6662 let mut request = SignedRequest::new("PUT", "lambda", &self.region, &request_uri);
6663 request.set_content_type("application/x-amz-json-1.1".to_owned());
6664
6665 let encoded = Some(serde_json::to_vec(&input).unwrap());
6666 request.set_payload(encoded);
6667
6668 let mut params = Params::new();
6669 if let Some(ref x) = input.qualifier {
6670 params.put("Qualifier", x);
6671 }
6672 request.set_params(params);
6673
6674 let mut response = self
6675 .client
6676 .sign_and_dispatch(request)
6677 .await
6678 .map_err(RusotoError::from)?;
6679 if response.status.as_u16() == 200 {
6680 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6681 let result = proto::json::ResponsePayload::new(&response)
6682 .deserialize::<FunctionEventInvokeConfig, _>()?;
6683
6684 Ok(result)
6685 } else {
6686 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6687 Err(PutFunctionEventInvokeConfigError::from_response(response))
6688 }
6689 }
6690
6691 #[allow(unused_mut)]
6693 async fn put_provisioned_concurrency_config(
6694 &self,
6695 input: PutProvisionedConcurrencyConfigRequest,
6696 ) -> Result<
6697 PutProvisionedConcurrencyConfigResponse,
6698 RusotoError<PutProvisionedConcurrencyConfigError>,
6699 > {
6700 let request_uri = format!(
6701 "/2019-09-30/functions/{function_name}/provisioned-concurrency",
6702 function_name = input.function_name
6703 );
6704
6705 let mut request = SignedRequest::new("PUT", "lambda", &self.region, &request_uri);
6706 request.set_content_type("application/x-amz-json-1.1".to_owned());
6707
6708 let encoded = Some(serde_json::to_vec(&input).unwrap());
6709 request.set_payload(encoded);
6710
6711 let mut params = Params::new();
6712 params.put("Qualifier", &input.qualifier);
6713 request.set_params(params);
6714
6715 let mut response = self
6716 .client
6717 .sign_and_dispatch(request)
6718 .await
6719 .map_err(RusotoError::from)?;
6720 if response.status.as_u16() == 202 {
6721 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6722 let result = proto::json::ResponsePayload::new(&response)
6723 .deserialize::<PutProvisionedConcurrencyConfigResponse, _>()?;
6724
6725 Ok(result)
6726 } else {
6727 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6728 Err(PutProvisionedConcurrencyConfigError::from_response(
6729 response,
6730 ))
6731 }
6732 }
6733
6734 #[allow(unused_mut)]
6736 async fn remove_layer_version_permission(
6737 &self,
6738 input: RemoveLayerVersionPermissionRequest,
6739 ) -> Result<(), RusotoError<RemoveLayerVersionPermissionError>> {
6740 let request_uri = format!(
6741 "/2018-10-31/layers/{layer_name}/versions/{version_number}/policy/{statement_id}",
6742 layer_name = input.layer_name,
6743 statement_id = input.statement_id,
6744 version_number = input.version_number
6745 );
6746
6747 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
6748 request.set_content_type("application/x-amz-json-1.1".to_owned());
6749
6750 let mut params = Params::new();
6751 if let Some(ref x) = input.revision_id {
6752 params.put("RevisionId", x);
6753 }
6754 request.set_params(params);
6755
6756 let mut response = self
6757 .client
6758 .sign_and_dispatch(request)
6759 .await
6760 .map_err(RusotoError::from)?;
6761 if response.status.as_u16() == 204 {
6762 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6763 let result = ::std::mem::drop(response);
6764
6765 Ok(result)
6766 } else {
6767 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6768 Err(RemoveLayerVersionPermissionError::from_response(response))
6769 }
6770 }
6771
6772 #[allow(unused_mut)]
6774 async fn remove_permission(
6775 &self,
6776 input: RemovePermissionRequest,
6777 ) -> Result<(), RusotoError<RemovePermissionError>> {
6778 let request_uri = format!(
6779 "/2015-03-31/functions/{function_name}/policy/{statement_id}",
6780 function_name = input.function_name,
6781 statement_id = input.statement_id
6782 );
6783
6784 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
6785 request.set_content_type("application/x-amz-json-1.1".to_owned());
6786
6787 let mut params = Params::new();
6788 if let Some(ref x) = input.qualifier {
6789 params.put("Qualifier", x);
6790 }
6791 if let Some(ref x) = input.revision_id {
6792 params.put("RevisionId", x);
6793 }
6794 request.set_params(params);
6795
6796 let mut response = self
6797 .client
6798 .sign_and_dispatch(request)
6799 .await
6800 .map_err(RusotoError::from)?;
6801 if response.status.as_u16() == 204 {
6802 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6803 let result = ::std::mem::drop(response);
6804
6805 Ok(result)
6806 } else {
6807 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6808 Err(RemovePermissionError::from_response(response))
6809 }
6810 }
6811
6812 #[allow(unused_mut)]
6814 async fn tag_resource(
6815 &self,
6816 input: TagResourceRequest,
6817 ) -> Result<(), RusotoError<TagResourceError>> {
6818 let request_uri = format!("/2017-03-31/tags/{arn}", arn = input.resource);
6819
6820 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
6821 request.set_content_type("application/x-amz-json-1.1".to_owned());
6822
6823 let encoded = Some(serde_json::to_vec(&input).unwrap());
6824 request.set_payload(encoded);
6825
6826 let mut response = self
6827 .client
6828 .sign_and_dispatch(request)
6829 .await
6830 .map_err(RusotoError::from)?;
6831 if response.status.as_u16() == 204 {
6832 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6833 let result = ::std::mem::drop(response);
6834
6835 Ok(result)
6836 } else {
6837 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6838 Err(TagResourceError::from_response(response))
6839 }
6840 }
6841
6842 #[allow(unused_mut)]
6844 async fn untag_resource(
6845 &self,
6846 input: UntagResourceRequest,
6847 ) -> Result<(), RusotoError<UntagResourceError>> {
6848 let request_uri = format!("/2017-03-31/tags/{arn}", arn = input.resource);
6849
6850 let mut request = SignedRequest::new("DELETE", "lambda", &self.region, &request_uri);
6851 request.set_content_type("application/x-amz-json-1.1".to_owned());
6852
6853 let mut params = Params::new();
6854 for item in input.tag_keys.iter() {
6855 params.put("tagKeys", item);
6856 }
6857 request.set_params(params);
6858
6859 let mut response = self
6860 .client
6861 .sign_and_dispatch(request)
6862 .await
6863 .map_err(RusotoError::from)?;
6864 if response.status.as_u16() == 204 {
6865 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6866 let result = ::std::mem::drop(response);
6867
6868 Ok(result)
6869 } else {
6870 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6871 Err(UntagResourceError::from_response(response))
6872 }
6873 }
6874
6875 #[allow(unused_mut)]
6877 async fn update_alias(
6878 &self,
6879 input: UpdateAliasRequest,
6880 ) -> Result<AliasConfiguration, RusotoError<UpdateAliasError>> {
6881 let request_uri = format!(
6882 "/2015-03-31/functions/{function_name}/aliases/{name}",
6883 function_name = input.function_name,
6884 name = input.name
6885 );
6886
6887 let mut request = SignedRequest::new("PUT", "lambda", &self.region, &request_uri);
6888 request.set_content_type("application/x-amz-json-1.1".to_owned());
6889
6890 let encoded = Some(serde_json::to_vec(&input).unwrap());
6891 request.set_payload(encoded);
6892
6893 let mut response = self
6894 .client
6895 .sign_and_dispatch(request)
6896 .await
6897 .map_err(RusotoError::from)?;
6898 if response.status.as_u16() == 200 {
6899 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6900 let result = proto::json::ResponsePayload::new(&response)
6901 .deserialize::<AliasConfiguration, _>()?;
6902
6903 Ok(result)
6904 } else {
6905 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6906 Err(UpdateAliasError::from_response(response))
6907 }
6908 }
6909
6910 #[allow(unused_mut)]
6912 async fn update_event_source_mapping(
6913 &self,
6914 input: UpdateEventSourceMappingRequest,
6915 ) -> Result<EventSourceMappingConfiguration, RusotoError<UpdateEventSourceMappingError>> {
6916 let request_uri = format!(
6917 "/2015-03-31/event-source-mappings/{uuid}",
6918 uuid = input.uuid
6919 );
6920
6921 let mut request = SignedRequest::new("PUT", "lambda", &self.region, &request_uri);
6922 request.set_content_type("application/x-amz-json-1.1".to_owned());
6923
6924 let encoded = Some(serde_json::to_vec(&input).unwrap());
6925 request.set_payload(encoded);
6926
6927 let mut response = self
6928 .client
6929 .sign_and_dispatch(request)
6930 .await
6931 .map_err(RusotoError::from)?;
6932 if response.status.as_u16() == 202 {
6933 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6934 let result = proto::json::ResponsePayload::new(&response)
6935 .deserialize::<EventSourceMappingConfiguration, _>()?;
6936
6937 Ok(result)
6938 } else {
6939 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6940 Err(UpdateEventSourceMappingError::from_response(response))
6941 }
6942 }
6943
6944 #[allow(unused_mut)]
6946 async fn update_function_code(
6947 &self,
6948 input: UpdateFunctionCodeRequest,
6949 ) -> Result<FunctionConfiguration, RusotoError<UpdateFunctionCodeError>> {
6950 let request_uri = format!(
6951 "/2015-03-31/functions/{function_name}/code",
6952 function_name = input.function_name
6953 );
6954
6955 let mut request = SignedRequest::new("PUT", "lambda", &self.region, &request_uri);
6956 request.set_content_type("application/x-amz-json-1.1".to_owned());
6957
6958 let encoded = Some(serde_json::to_vec(&input).unwrap());
6959 request.set_payload(encoded);
6960
6961 let mut response = self
6962 .client
6963 .sign_and_dispatch(request)
6964 .await
6965 .map_err(RusotoError::from)?;
6966 if response.status.as_u16() == 200 {
6967 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6968 let result = proto::json::ResponsePayload::new(&response)
6969 .deserialize::<FunctionConfiguration, _>()?;
6970
6971 Ok(result)
6972 } else {
6973 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
6974 Err(UpdateFunctionCodeError::from_response(response))
6975 }
6976 }
6977
6978 #[allow(unused_mut)]
6980 async fn update_function_configuration(
6981 &self,
6982 input: UpdateFunctionConfigurationRequest,
6983 ) -> Result<FunctionConfiguration, RusotoError<UpdateFunctionConfigurationError>> {
6984 let request_uri = format!(
6985 "/2015-03-31/functions/{function_name}/configuration",
6986 function_name = input.function_name
6987 );
6988
6989 let mut request = SignedRequest::new("PUT", "lambda", &self.region, &request_uri);
6990 request.set_content_type("application/x-amz-json-1.1".to_owned());
6991
6992 let encoded = Some(serde_json::to_vec(&input).unwrap());
6993 request.set_payload(encoded);
6994
6995 let mut response = self
6996 .client
6997 .sign_and_dispatch(request)
6998 .await
6999 .map_err(RusotoError::from)?;
7000 if response.status.as_u16() == 200 {
7001 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
7002 let result = proto::json::ResponsePayload::new(&response)
7003 .deserialize::<FunctionConfiguration, _>()?;
7004
7005 Ok(result)
7006 } else {
7007 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
7008 Err(UpdateFunctionConfigurationError::from_response(response))
7009 }
7010 }
7011
7012 #[allow(unused_mut)]
7014 async fn update_function_event_invoke_config(
7015 &self,
7016 input: UpdateFunctionEventInvokeConfigRequest,
7017 ) -> Result<FunctionEventInvokeConfig, RusotoError<UpdateFunctionEventInvokeConfigError>> {
7018 let request_uri = format!(
7019 "/2019-09-25/functions/{function_name}/event-invoke-config",
7020 function_name = input.function_name
7021 );
7022
7023 let mut request = SignedRequest::new("POST", "lambda", &self.region, &request_uri);
7024 request.set_content_type("application/x-amz-json-1.1".to_owned());
7025
7026 let encoded = Some(serde_json::to_vec(&input).unwrap());
7027 request.set_payload(encoded);
7028
7029 let mut params = Params::new();
7030 if let Some(ref x) = input.qualifier {
7031 params.put("Qualifier", x);
7032 }
7033 request.set_params(params);
7034
7035 let mut response = self
7036 .client
7037 .sign_and_dispatch(request)
7038 .await
7039 .map_err(RusotoError::from)?;
7040 if response.status.as_u16() == 200 {
7041 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
7042 let result = proto::json::ResponsePayload::new(&response)
7043 .deserialize::<FunctionEventInvokeConfig, _>()?;
7044
7045 Ok(result)
7046 } else {
7047 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
7048 Err(UpdateFunctionEventInvokeConfigError::from_response(
7049 response,
7050 ))
7051 }
7052 }
7053}