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 Addon {
32 #[serde(rename = "addonArn")]
34 #[serde(skip_serializing_if = "Option::is_none")]
35 pub addon_arn: Option<String>,
36 #[serde(rename = "addonName")]
38 #[serde(skip_serializing_if = "Option::is_none")]
39 pub addon_name: Option<String>,
40 #[serde(rename = "addonVersion")]
42 #[serde(skip_serializing_if = "Option::is_none")]
43 pub addon_version: Option<String>,
44 #[serde(rename = "clusterName")]
46 #[serde(skip_serializing_if = "Option::is_none")]
47 pub cluster_name: Option<String>,
48 #[serde(rename = "createdAt")]
50 #[serde(skip_serializing_if = "Option::is_none")]
51 pub created_at: Option<f64>,
52 #[serde(rename = "health")]
54 #[serde(skip_serializing_if = "Option::is_none")]
55 pub health: Option<AddonHealth>,
56 #[serde(rename = "modifiedAt")]
58 #[serde(skip_serializing_if = "Option::is_none")]
59 pub modified_at: Option<f64>,
60 #[serde(rename = "serviceAccountRoleArn")]
62 #[serde(skip_serializing_if = "Option::is_none")]
63 pub service_account_role_arn: Option<String>,
64 #[serde(rename = "status")]
66 #[serde(skip_serializing_if = "Option::is_none")]
67 pub status: Option<String>,
68 #[serde(rename = "tags")]
70 #[serde(skip_serializing_if = "Option::is_none")]
71 pub tags: Option<::std::collections::HashMap<String, String>>,
72}
73
74#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
76#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
77pub struct AddonHealth {
78 #[serde(rename = "issues")]
80 #[serde(skip_serializing_if = "Option::is_none")]
81 pub issues: Option<Vec<AddonIssue>>,
82}
83
84#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
86#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
87pub struct AddonInfo {
88 #[serde(rename = "addonName")]
90 #[serde(skip_serializing_if = "Option::is_none")]
91 pub addon_name: Option<String>,
92 #[serde(rename = "addonVersions")]
94 #[serde(skip_serializing_if = "Option::is_none")]
95 pub addon_versions: Option<Vec<AddonVersionInfo>>,
96 #[serde(rename = "type")]
98 #[serde(skip_serializing_if = "Option::is_none")]
99 pub type_: Option<String>,
100}
101
102#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
104#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
105pub struct AddonIssue {
106 #[serde(rename = "code")]
108 #[serde(skip_serializing_if = "Option::is_none")]
109 pub code: Option<String>,
110 #[serde(rename = "message")]
112 #[serde(skip_serializing_if = "Option::is_none")]
113 pub message: Option<String>,
114 #[serde(rename = "resourceIds")]
116 #[serde(skip_serializing_if = "Option::is_none")]
117 pub resource_ids: Option<Vec<String>>,
118}
119
120#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
122#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
123pub struct AddonVersionInfo {
124 #[serde(rename = "addonVersion")]
126 #[serde(skip_serializing_if = "Option::is_none")]
127 pub addon_version: Option<String>,
128 #[serde(rename = "architecture")]
130 #[serde(skip_serializing_if = "Option::is_none")]
131 pub architecture: Option<Vec<String>>,
132 #[serde(rename = "compatibilities")]
134 #[serde(skip_serializing_if = "Option::is_none")]
135 pub compatibilities: Option<Vec<Compatibility>>,
136}
137
138#[derive(Clone, Debug, Default, PartialEq, Serialize)]
139#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
140pub struct AssociateEncryptionConfigRequest {
141 #[serde(rename = "clientRequestToken")]
143 #[serde(skip_serializing_if = "Option::is_none")]
144 pub client_request_token: Option<String>,
145 #[serde(rename = "clusterName")]
147 pub cluster_name: String,
148 #[serde(rename = "encryptionConfig")]
150 pub encryption_config: Vec<EncryptionConfig>,
151}
152
153#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
154#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
155pub struct AssociateEncryptionConfigResponse {
156 #[serde(rename = "update")]
157 #[serde(skip_serializing_if = "Option::is_none")]
158 pub update: Option<Update>,
159}
160
161#[derive(Clone, Debug, Default, PartialEq, Serialize)]
162#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
163pub struct AssociateIdentityProviderConfigRequest {
164 #[serde(rename = "clientRequestToken")]
166 #[serde(skip_serializing_if = "Option::is_none")]
167 pub client_request_token: Option<String>,
168 #[serde(rename = "clusterName")]
170 pub cluster_name: String,
171 #[serde(rename = "oidc")]
173 pub oidc: OidcIdentityProviderConfigRequest,
174 #[serde(rename = "tags")]
176 #[serde(skip_serializing_if = "Option::is_none")]
177 pub tags: Option<::std::collections::HashMap<String, String>>,
178}
179
180#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
181#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
182pub struct AssociateIdentityProviderConfigResponse {
183 #[serde(rename = "tags")]
185 #[serde(skip_serializing_if = "Option::is_none")]
186 pub tags: Option<::std::collections::HashMap<String, String>>,
187 #[serde(rename = "update")]
188 #[serde(skip_serializing_if = "Option::is_none")]
189 pub update: Option<Update>,
190}
191
192#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
194#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
195pub struct AutoScalingGroup {
196 #[serde(rename = "name")]
198 #[serde(skip_serializing_if = "Option::is_none")]
199 pub name: Option<String>,
200}
201
202#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
204#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
205pub struct Certificate {
206 #[serde(rename = "data")]
208 #[serde(skip_serializing_if = "Option::is_none")]
209 pub data: Option<String>,
210}
211
212#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
214#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
215pub struct Cluster {
216 #[serde(rename = "arn")]
218 #[serde(skip_serializing_if = "Option::is_none")]
219 pub arn: Option<String>,
220 #[serde(rename = "certificateAuthority")]
222 #[serde(skip_serializing_if = "Option::is_none")]
223 pub certificate_authority: Option<Certificate>,
224 #[serde(rename = "clientRequestToken")]
226 #[serde(skip_serializing_if = "Option::is_none")]
227 pub client_request_token: Option<String>,
228 #[serde(rename = "createdAt")]
230 #[serde(skip_serializing_if = "Option::is_none")]
231 pub created_at: Option<f64>,
232 #[serde(rename = "encryptionConfig")]
234 #[serde(skip_serializing_if = "Option::is_none")]
235 pub encryption_config: Option<Vec<EncryptionConfig>>,
236 #[serde(rename = "endpoint")]
238 #[serde(skip_serializing_if = "Option::is_none")]
239 pub endpoint: Option<String>,
240 #[serde(rename = "identity")]
242 #[serde(skip_serializing_if = "Option::is_none")]
243 pub identity: Option<Identity>,
244 #[serde(rename = "kubernetesNetworkConfig")]
246 #[serde(skip_serializing_if = "Option::is_none")]
247 pub kubernetes_network_config: Option<KubernetesNetworkConfigResponse>,
248 #[serde(rename = "logging")]
250 #[serde(skip_serializing_if = "Option::is_none")]
251 pub logging: Option<Logging>,
252 #[serde(rename = "name")]
254 #[serde(skip_serializing_if = "Option::is_none")]
255 pub name: Option<String>,
256 #[serde(rename = "platformVersion")]
258 #[serde(skip_serializing_if = "Option::is_none")]
259 pub platform_version: Option<String>,
260 #[serde(rename = "resourcesVpcConfig")]
262 #[serde(skip_serializing_if = "Option::is_none")]
263 pub resources_vpc_config: Option<VpcConfigResponse>,
264 #[serde(rename = "roleArn")]
266 #[serde(skip_serializing_if = "Option::is_none")]
267 pub role_arn: Option<String>,
268 #[serde(rename = "status")]
270 #[serde(skip_serializing_if = "Option::is_none")]
271 pub status: Option<String>,
272 #[serde(rename = "tags")]
274 #[serde(skip_serializing_if = "Option::is_none")]
275 pub tags: Option<::std::collections::HashMap<String, String>>,
276 #[serde(rename = "version")]
278 #[serde(skip_serializing_if = "Option::is_none")]
279 pub version: Option<String>,
280}
281
282#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
284#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
285pub struct Compatibility {
286 #[serde(rename = "clusterVersion")]
288 #[serde(skip_serializing_if = "Option::is_none")]
289 pub cluster_version: Option<String>,
290 #[serde(rename = "defaultVersion")]
292 #[serde(skip_serializing_if = "Option::is_none")]
293 pub default_version: Option<bool>,
294 #[serde(rename = "platformVersions")]
296 #[serde(skip_serializing_if = "Option::is_none")]
297 pub platform_versions: Option<Vec<String>>,
298}
299
300#[derive(Clone, Debug, Default, PartialEq, Serialize)]
301#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
302pub struct CreateAddonRequest {
303 #[serde(rename = "addonName")]
305 pub addon_name: String,
306 #[serde(rename = "addonVersion")]
308 #[serde(skip_serializing_if = "Option::is_none")]
309 pub addon_version: Option<String>,
310 #[serde(rename = "clientRequestToken")]
312 #[serde(skip_serializing_if = "Option::is_none")]
313 pub client_request_token: Option<String>,
314 #[serde(rename = "clusterName")]
316 pub cluster_name: String,
317 #[serde(rename = "resolveConflicts")]
319 #[serde(skip_serializing_if = "Option::is_none")]
320 pub resolve_conflicts: Option<String>,
321 #[serde(rename = "serviceAccountRoleArn")]
323 #[serde(skip_serializing_if = "Option::is_none")]
324 pub service_account_role_arn: Option<String>,
325 #[serde(rename = "tags")]
327 #[serde(skip_serializing_if = "Option::is_none")]
328 pub tags: Option<::std::collections::HashMap<String, String>>,
329}
330
331#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
332#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
333pub struct CreateAddonResponse {
334 #[serde(rename = "addon")]
335 #[serde(skip_serializing_if = "Option::is_none")]
336 pub addon: Option<Addon>,
337}
338
339#[derive(Clone, Debug, Default, PartialEq, Serialize)]
340#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
341pub struct CreateClusterRequest {
342 #[serde(rename = "clientRequestToken")]
344 #[serde(skip_serializing_if = "Option::is_none")]
345 pub client_request_token: Option<String>,
346 #[serde(rename = "encryptionConfig")]
348 #[serde(skip_serializing_if = "Option::is_none")]
349 pub encryption_config: Option<Vec<EncryptionConfig>>,
350 #[serde(rename = "kubernetesNetworkConfig")]
352 #[serde(skip_serializing_if = "Option::is_none")]
353 pub kubernetes_network_config: Option<KubernetesNetworkConfigRequest>,
354 #[serde(rename = "logging")]
356 #[serde(skip_serializing_if = "Option::is_none")]
357 pub logging: Option<Logging>,
358 #[serde(rename = "name")]
360 pub name: String,
361 #[serde(rename = "resourcesVpcConfig")]
363 pub resources_vpc_config: VpcConfigRequest,
364 #[serde(rename = "roleArn")]
366 pub role_arn: String,
367 #[serde(rename = "tags")]
369 #[serde(skip_serializing_if = "Option::is_none")]
370 pub tags: Option<::std::collections::HashMap<String, String>>,
371 #[serde(rename = "version")]
373 #[serde(skip_serializing_if = "Option::is_none")]
374 pub version: Option<String>,
375}
376
377#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
378#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
379pub struct CreateClusterResponse {
380 #[serde(rename = "cluster")]
382 #[serde(skip_serializing_if = "Option::is_none")]
383 pub cluster: Option<Cluster>,
384}
385
386#[derive(Clone, Debug, Default, PartialEq, Serialize)]
387#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
388pub struct CreateFargateProfileRequest {
389 #[serde(rename = "clientRequestToken")]
391 #[serde(skip_serializing_if = "Option::is_none")]
392 pub client_request_token: Option<String>,
393 #[serde(rename = "clusterName")]
395 pub cluster_name: String,
396 #[serde(rename = "fargateProfileName")]
398 pub fargate_profile_name: String,
399 #[serde(rename = "podExecutionRoleArn")]
401 pub pod_execution_role_arn: String,
402 #[serde(rename = "selectors")]
404 #[serde(skip_serializing_if = "Option::is_none")]
405 pub selectors: Option<Vec<FargateProfileSelector>>,
406 #[serde(rename = "subnets")]
408 #[serde(skip_serializing_if = "Option::is_none")]
409 pub subnets: Option<Vec<String>>,
410 #[serde(rename = "tags")]
412 #[serde(skip_serializing_if = "Option::is_none")]
413 pub tags: Option<::std::collections::HashMap<String, String>>,
414}
415
416#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
417#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
418pub struct CreateFargateProfileResponse {
419 #[serde(rename = "fargateProfile")]
421 #[serde(skip_serializing_if = "Option::is_none")]
422 pub fargate_profile: Option<FargateProfile>,
423}
424
425#[derive(Clone, Debug, Default, PartialEq, Serialize)]
426#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
427pub struct CreateNodegroupRequest {
428 #[serde(rename = "amiType")]
430 #[serde(skip_serializing_if = "Option::is_none")]
431 pub ami_type: Option<String>,
432 #[serde(rename = "capacityType")]
434 #[serde(skip_serializing_if = "Option::is_none")]
435 pub capacity_type: Option<String>,
436 #[serde(rename = "clientRequestToken")]
438 #[serde(skip_serializing_if = "Option::is_none")]
439 pub client_request_token: Option<String>,
440 #[serde(rename = "clusterName")]
442 pub cluster_name: String,
443 #[serde(rename = "diskSize")]
445 #[serde(skip_serializing_if = "Option::is_none")]
446 pub disk_size: Option<i64>,
447 #[serde(rename = "instanceTypes")]
449 #[serde(skip_serializing_if = "Option::is_none")]
450 pub instance_types: Option<Vec<String>>,
451 #[serde(rename = "labels")]
453 #[serde(skip_serializing_if = "Option::is_none")]
454 pub labels: Option<::std::collections::HashMap<String, String>>,
455 #[serde(rename = "launchTemplate")]
457 #[serde(skip_serializing_if = "Option::is_none")]
458 pub launch_template: Option<LaunchTemplateSpecification>,
459 #[serde(rename = "nodeRole")]
461 pub node_role: String,
462 #[serde(rename = "nodegroupName")]
464 pub nodegroup_name: String,
465 #[serde(rename = "releaseVersion")]
467 #[serde(skip_serializing_if = "Option::is_none")]
468 pub release_version: Option<String>,
469 #[serde(rename = "remoteAccess")]
471 #[serde(skip_serializing_if = "Option::is_none")]
472 pub remote_access: Option<RemoteAccessConfig>,
473 #[serde(rename = "scalingConfig")]
475 #[serde(skip_serializing_if = "Option::is_none")]
476 pub scaling_config: Option<NodegroupScalingConfig>,
477 #[serde(rename = "subnets")]
479 pub subnets: Vec<String>,
480 #[serde(rename = "tags")]
482 #[serde(skip_serializing_if = "Option::is_none")]
483 pub tags: Option<::std::collections::HashMap<String, String>>,
484 #[serde(rename = "taints")]
486 #[serde(skip_serializing_if = "Option::is_none")]
487 pub taints: Option<Vec<Taint>>,
488 #[serde(rename = "updateConfig")]
489 #[serde(skip_serializing_if = "Option::is_none")]
490 pub update_config: Option<NodegroupUpdateConfig>,
491 #[serde(rename = "version")]
493 #[serde(skip_serializing_if = "Option::is_none")]
494 pub version: Option<String>,
495}
496
497#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
498#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
499pub struct CreateNodegroupResponse {
500 #[serde(rename = "nodegroup")]
502 #[serde(skip_serializing_if = "Option::is_none")]
503 pub nodegroup: Option<Nodegroup>,
504}
505
506#[derive(Clone, Debug, Default, PartialEq, Serialize)]
507#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
508pub struct DeleteAddonRequest {
509 #[serde(rename = "addonName")]
511 pub addon_name: String,
512 #[serde(rename = "clusterName")]
514 pub cluster_name: String,
515}
516
517#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
518#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
519pub struct DeleteAddonResponse {
520 #[serde(rename = "addon")]
521 #[serde(skip_serializing_if = "Option::is_none")]
522 pub addon: Option<Addon>,
523}
524
525#[derive(Clone, Debug, Default, PartialEq, Serialize)]
526#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
527pub struct DeleteClusterRequest {
528 #[serde(rename = "name")]
530 pub name: String,
531}
532
533#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
534#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
535pub struct DeleteClusterResponse {
536 #[serde(rename = "cluster")]
538 #[serde(skip_serializing_if = "Option::is_none")]
539 pub cluster: Option<Cluster>,
540}
541
542#[derive(Clone, Debug, Default, PartialEq, Serialize)]
543#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
544pub struct DeleteFargateProfileRequest {
545 #[serde(rename = "clusterName")]
547 pub cluster_name: String,
548 #[serde(rename = "fargateProfileName")]
550 pub fargate_profile_name: String,
551}
552
553#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
554#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
555pub struct DeleteFargateProfileResponse {
556 #[serde(rename = "fargateProfile")]
558 #[serde(skip_serializing_if = "Option::is_none")]
559 pub fargate_profile: Option<FargateProfile>,
560}
561
562#[derive(Clone, Debug, Default, PartialEq, Serialize)]
563#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
564pub struct DeleteNodegroupRequest {
565 #[serde(rename = "clusterName")]
567 pub cluster_name: String,
568 #[serde(rename = "nodegroupName")]
570 pub nodegroup_name: String,
571}
572
573#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
574#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
575pub struct DeleteNodegroupResponse {
576 #[serde(rename = "nodegroup")]
578 #[serde(skip_serializing_if = "Option::is_none")]
579 pub nodegroup: Option<Nodegroup>,
580}
581
582#[derive(Clone, Debug, Default, PartialEq, Serialize)]
583#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
584pub struct DescribeAddonRequest {
585 #[serde(rename = "addonName")]
587 pub addon_name: String,
588 #[serde(rename = "clusterName")]
590 pub cluster_name: String,
591}
592
593#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
594#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
595pub struct DescribeAddonResponse {
596 #[serde(rename = "addon")]
597 #[serde(skip_serializing_if = "Option::is_none")]
598 pub addon: Option<Addon>,
599}
600
601#[derive(Clone, Debug, Default, PartialEq, Serialize)]
602#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
603pub struct DescribeAddonVersionsRequest {
604 #[serde(rename = "addonName")]
606 #[serde(skip_serializing_if = "Option::is_none")]
607 pub addon_name: Option<String>,
608 #[serde(rename = "kubernetesVersion")]
610 #[serde(skip_serializing_if = "Option::is_none")]
611 pub kubernetes_version: Option<String>,
612 #[serde(rename = "maxResults")]
614 #[serde(skip_serializing_if = "Option::is_none")]
615 pub max_results: Option<i64>,
616 #[serde(rename = "nextToken")]
618 #[serde(skip_serializing_if = "Option::is_none")]
619 pub next_token: Option<String>,
620}
621
622#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
623#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
624pub struct DescribeAddonVersionsResponse {
625 #[serde(rename = "addons")]
627 #[serde(skip_serializing_if = "Option::is_none")]
628 pub addons: Option<Vec<AddonInfo>>,
629 #[serde(rename = "nextToken")]
631 #[serde(skip_serializing_if = "Option::is_none")]
632 pub next_token: Option<String>,
633}
634
635#[derive(Clone, Debug, Default, PartialEq, Serialize)]
636#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
637pub struct DescribeClusterRequest {
638 #[serde(rename = "name")]
640 pub name: String,
641}
642
643#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
644#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
645pub struct DescribeClusterResponse {
646 #[serde(rename = "cluster")]
648 #[serde(skip_serializing_if = "Option::is_none")]
649 pub cluster: Option<Cluster>,
650}
651
652#[derive(Clone, Debug, Default, PartialEq, Serialize)]
653#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
654pub struct DescribeFargateProfileRequest {
655 #[serde(rename = "clusterName")]
657 pub cluster_name: String,
658 #[serde(rename = "fargateProfileName")]
660 pub fargate_profile_name: String,
661}
662
663#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
664#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
665pub struct DescribeFargateProfileResponse {
666 #[serde(rename = "fargateProfile")]
668 #[serde(skip_serializing_if = "Option::is_none")]
669 pub fargate_profile: Option<FargateProfile>,
670}
671
672#[derive(Clone, Debug, Default, PartialEq, Serialize)]
673#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
674pub struct DescribeIdentityProviderConfigRequest {
675 #[serde(rename = "clusterName")]
677 pub cluster_name: String,
678 #[serde(rename = "identityProviderConfig")]
680 pub identity_provider_config: IdentityProviderConfig,
681}
682
683#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
684#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
685pub struct DescribeIdentityProviderConfigResponse {
686 #[serde(rename = "identityProviderConfig")]
688 #[serde(skip_serializing_if = "Option::is_none")]
689 pub identity_provider_config: Option<IdentityProviderConfigResponse>,
690}
691
692#[derive(Clone, Debug, Default, PartialEq, Serialize)]
693#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
694pub struct DescribeNodegroupRequest {
695 #[serde(rename = "clusterName")]
697 pub cluster_name: String,
698 #[serde(rename = "nodegroupName")]
700 pub nodegroup_name: String,
701}
702
703#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
704#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
705pub struct DescribeNodegroupResponse {
706 #[serde(rename = "nodegroup")]
708 #[serde(skip_serializing_if = "Option::is_none")]
709 pub nodegroup: Option<Nodegroup>,
710}
711
712#[derive(Clone, Debug, Default, PartialEq, Serialize)]
713#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
714pub struct DescribeUpdateRequest {
715 #[serde(rename = "addonName")]
717 #[serde(skip_serializing_if = "Option::is_none")]
718 pub addon_name: Option<String>,
719 #[serde(rename = "name")]
721 pub name: String,
722 #[serde(rename = "nodegroupName")]
724 #[serde(skip_serializing_if = "Option::is_none")]
725 pub nodegroup_name: Option<String>,
726 #[serde(rename = "updateId")]
728 pub update_id: String,
729}
730
731#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
732#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
733pub struct DescribeUpdateResponse {
734 #[serde(rename = "update")]
736 #[serde(skip_serializing_if = "Option::is_none")]
737 pub update: Option<Update>,
738}
739
740#[derive(Clone, Debug, Default, PartialEq, Serialize)]
741#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
742pub struct DisassociateIdentityProviderConfigRequest {
743 #[serde(rename = "clientRequestToken")]
745 #[serde(skip_serializing_if = "Option::is_none")]
746 pub client_request_token: Option<String>,
747 #[serde(rename = "clusterName")]
749 pub cluster_name: String,
750 #[serde(rename = "identityProviderConfig")]
752 pub identity_provider_config: IdentityProviderConfig,
753}
754
755#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
756#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
757pub struct DisassociateIdentityProviderConfigResponse {
758 #[serde(rename = "update")]
759 #[serde(skip_serializing_if = "Option::is_none")]
760 pub update: Option<Update>,
761}
762
763#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
765pub struct EncryptionConfig {
766 #[serde(rename = "provider")]
768 #[serde(skip_serializing_if = "Option::is_none")]
769 pub provider: Option<Provider>,
770 #[serde(rename = "resources")]
772 #[serde(skip_serializing_if = "Option::is_none")]
773 pub resources: Option<Vec<String>>,
774}
775
776#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
778#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
779pub struct ErrorDetail {
780 #[serde(rename = "errorCode")]
782 #[serde(skip_serializing_if = "Option::is_none")]
783 pub error_code: Option<String>,
784 #[serde(rename = "errorMessage")]
786 #[serde(skip_serializing_if = "Option::is_none")]
787 pub error_message: Option<String>,
788 #[serde(rename = "resourceIds")]
790 #[serde(skip_serializing_if = "Option::is_none")]
791 pub resource_ids: Option<Vec<String>>,
792}
793
794#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
796#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
797pub struct FargateProfile {
798 #[serde(rename = "clusterName")]
800 #[serde(skip_serializing_if = "Option::is_none")]
801 pub cluster_name: Option<String>,
802 #[serde(rename = "createdAt")]
804 #[serde(skip_serializing_if = "Option::is_none")]
805 pub created_at: Option<f64>,
806 #[serde(rename = "fargateProfileArn")]
808 #[serde(skip_serializing_if = "Option::is_none")]
809 pub fargate_profile_arn: Option<String>,
810 #[serde(rename = "fargateProfileName")]
812 #[serde(skip_serializing_if = "Option::is_none")]
813 pub fargate_profile_name: Option<String>,
814 #[serde(rename = "podExecutionRoleArn")]
816 #[serde(skip_serializing_if = "Option::is_none")]
817 pub pod_execution_role_arn: Option<String>,
818 #[serde(rename = "selectors")]
820 #[serde(skip_serializing_if = "Option::is_none")]
821 pub selectors: Option<Vec<FargateProfileSelector>>,
822 #[serde(rename = "status")]
824 #[serde(skip_serializing_if = "Option::is_none")]
825 pub status: Option<String>,
826 #[serde(rename = "subnets")]
828 #[serde(skip_serializing_if = "Option::is_none")]
829 pub subnets: Option<Vec<String>>,
830 #[serde(rename = "tags")]
832 #[serde(skip_serializing_if = "Option::is_none")]
833 pub tags: Option<::std::collections::HashMap<String, String>>,
834}
835
836#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
838pub struct FargateProfileSelector {
839 #[serde(rename = "labels")]
841 #[serde(skip_serializing_if = "Option::is_none")]
842 pub labels: Option<::std::collections::HashMap<String, String>>,
843 #[serde(rename = "namespace")]
845 #[serde(skip_serializing_if = "Option::is_none")]
846 pub namespace: Option<String>,
847}
848
849#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
851#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
852pub struct Identity {
853 #[serde(rename = "oidc")]
855 #[serde(skip_serializing_if = "Option::is_none")]
856 pub oidc: Option<OIDC>,
857}
858
859#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
861pub struct IdentityProviderConfig {
862 #[serde(rename = "name")]
864 pub name: String,
865 #[serde(rename = "type")]
867 pub type_: String,
868}
869
870#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
872#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
873pub struct IdentityProviderConfigResponse {
874 #[serde(rename = "oidc")]
876 #[serde(skip_serializing_if = "Option::is_none")]
877 pub oidc: Option<OidcIdentityProviderConfig>,
878}
879
880#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
882#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
883pub struct Issue {
884 #[serde(rename = "code")]
886 #[serde(skip_serializing_if = "Option::is_none")]
887 pub code: Option<String>,
888 #[serde(rename = "message")]
890 #[serde(skip_serializing_if = "Option::is_none")]
891 pub message: Option<String>,
892 #[serde(rename = "resourceIds")]
894 #[serde(skip_serializing_if = "Option::is_none")]
895 pub resource_ids: Option<Vec<String>>,
896}
897
898#[derive(Clone, Debug, Default, PartialEq, Serialize)]
900#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
901pub struct KubernetesNetworkConfigRequest {
902 #[serde(rename = "serviceIpv4Cidr")]
904 #[serde(skip_serializing_if = "Option::is_none")]
905 pub service_ipv_4_cidr: Option<String>,
906}
907
908#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
910#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
911pub struct KubernetesNetworkConfigResponse {
912 #[serde(rename = "serviceIpv4Cidr")]
914 #[serde(skip_serializing_if = "Option::is_none")]
915 pub service_ipv_4_cidr: Option<String>,
916}
917
918#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
920pub struct LaunchTemplateSpecification {
921 #[serde(rename = "id")]
923 #[serde(skip_serializing_if = "Option::is_none")]
924 pub id: Option<String>,
925 #[serde(rename = "name")]
927 #[serde(skip_serializing_if = "Option::is_none")]
928 pub name: Option<String>,
929 #[serde(rename = "version")]
931 #[serde(skip_serializing_if = "Option::is_none")]
932 pub version: Option<String>,
933}
934
935#[derive(Clone, Debug, Default, PartialEq, Serialize)]
936#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
937pub struct ListAddonsRequest {
938 #[serde(rename = "clusterName")]
940 pub cluster_name: String,
941 #[serde(rename = "maxResults")]
943 #[serde(skip_serializing_if = "Option::is_none")]
944 pub max_results: Option<i64>,
945 #[serde(rename = "nextToken")]
947 #[serde(skip_serializing_if = "Option::is_none")]
948 pub next_token: Option<String>,
949}
950
951#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
952#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
953pub struct ListAddonsResponse {
954 #[serde(rename = "addons")]
956 #[serde(skip_serializing_if = "Option::is_none")]
957 pub addons: Option<Vec<String>>,
958 #[serde(rename = "nextToken")]
960 #[serde(skip_serializing_if = "Option::is_none")]
961 pub next_token: Option<String>,
962}
963
964#[derive(Clone, Debug, Default, PartialEq, Serialize)]
965#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
966pub struct ListClustersRequest {
967 #[serde(rename = "maxResults")]
969 #[serde(skip_serializing_if = "Option::is_none")]
970 pub max_results: Option<i64>,
971 #[serde(rename = "nextToken")]
973 #[serde(skip_serializing_if = "Option::is_none")]
974 pub next_token: Option<String>,
975}
976
977#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
978#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
979pub struct ListClustersResponse {
980 #[serde(rename = "clusters")]
982 #[serde(skip_serializing_if = "Option::is_none")]
983 pub clusters: Option<Vec<String>>,
984 #[serde(rename = "nextToken")]
986 #[serde(skip_serializing_if = "Option::is_none")]
987 pub next_token: Option<String>,
988}
989
990#[derive(Clone, Debug, Default, PartialEq, Serialize)]
991#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
992pub struct ListFargateProfilesRequest {
993 #[serde(rename = "clusterName")]
995 pub cluster_name: String,
996 #[serde(rename = "maxResults")]
998 #[serde(skip_serializing_if = "Option::is_none")]
999 pub max_results: Option<i64>,
1000 #[serde(rename = "nextToken")]
1002 #[serde(skip_serializing_if = "Option::is_none")]
1003 pub next_token: Option<String>,
1004}
1005
1006#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1007#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1008pub struct ListFargateProfilesResponse {
1009 #[serde(rename = "fargateProfileNames")]
1011 #[serde(skip_serializing_if = "Option::is_none")]
1012 pub fargate_profile_names: Option<Vec<String>>,
1013 #[serde(rename = "nextToken")]
1015 #[serde(skip_serializing_if = "Option::is_none")]
1016 pub next_token: Option<String>,
1017}
1018
1019#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1020#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1021pub struct ListIdentityProviderConfigsRequest {
1022 #[serde(rename = "clusterName")]
1024 pub cluster_name: String,
1025 #[serde(rename = "maxResults")]
1027 #[serde(skip_serializing_if = "Option::is_none")]
1028 pub max_results: Option<i64>,
1029 #[serde(rename = "nextToken")]
1031 #[serde(skip_serializing_if = "Option::is_none")]
1032 pub next_token: Option<String>,
1033}
1034
1035#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1036#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1037pub struct ListIdentityProviderConfigsResponse {
1038 #[serde(rename = "identityProviderConfigs")]
1040 #[serde(skip_serializing_if = "Option::is_none")]
1041 pub identity_provider_configs: Option<Vec<IdentityProviderConfig>>,
1042 #[serde(rename = "nextToken")]
1044 #[serde(skip_serializing_if = "Option::is_none")]
1045 pub next_token: Option<String>,
1046}
1047
1048#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1049#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1050pub struct ListNodegroupsRequest {
1051 #[serde(rename = "clusterName")]
1053 pub cluster_name: String,
1054 #[serde(rename = "maxResults")]
1056 #[serde(skip_serializing_if = "Option::is_none")]
1057 pub max_results: Option<i64>,
1058 #[serde(rename = "nextToken")]
1060 #[serde(skip_serializing_if = "Option::is_none")]
1061 pub next_token: Option<String>,
1062}
1063
1064#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1065#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1066pub struct ListNodegroupsResponse {
1067 #[serde(rename = "nextToken")]
1069 #[serde(skip_serializing_if = "Option::is_none")]
1070 pub next_token: Option<String>,
1071 #[serde(rename = "nodegroups")]
1073 #[serde(skip_serializing_if = "Option::is_none")]
1074 pub nodegroups: Option<Vec<String>>,
1075}
1076
1077#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1078#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1079pub struct ListTagsForResourceRequest {
1080 #[serde(rename = "resourceArn")]
1082 pub resource_arn: String,
1083}
1084
1085#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1086#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1087pub struct ListTagsForResourceResponse {
1088 #[serde(rename = "tags")]
1090 #[serde(skip_serializing_if = "Option::is_none")]
1091 pub tags: Option<::std::collections::HashMap<String, String>>,
1092}
1093
1094#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1095#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1096pub struct ListUpdatesRequest {
1097 #[serde(rename = "addonName")]
1099 #[serde(skip_serializing_if = "Option::is_none")]
1100 pub addon_name: Option<String>,
1101 #[serde(rename = "maxResults")]
1103 #[serde(skip_serializing_if = "Option::is_none")]
1104 pub max_results: Option<i64>,
1105 #[serde(rename = "name")]
1107 pub name: String,
1108 #[serde(rename = "nextToken")]
1110 #[serde(skip_serializing_if = "Option::is_none")]
1111 pub next_token: Option<String>,
1112 #[serde(rename = "nodegroupName")]
1114 #[serde(skip_serializing_if = "Option::is_none")]
1115 pub nodegroup_name: Option<String>,
1116}
1117
1118#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1119#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1120pub struct ListUpdatesResponse {
1121 #[serde(rename = "nextToken")]
1123 #[serde(skip_serializing_if = "Option::is_none")]
1124 pub next_token: Option<String>,
1125 #[serde(rename = "updateIds")]
1127 #[serde(skip_serializing_if = "Option::is_none")]
1128 pub update_ids: Option<Vec<String>>,
1129}
1130
1131#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1133pub struct LogSetup {
1134 #[serde(rename = "enabled")]
1136 #[serde(skip_serializing_if = "Option::is_none")]
1137 pub enabled: Option<bool>,
1138 #[serde(rename = "types")]
1140 #[serde(skip_serializing_if = "Option::is_none")]
1141 pub types: Option<Vec<String>>,
1142}
1143
1144#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1146pub struct Logging {
1147 #[serde(rename = "clusterLogging")]
1149 #[serde(skip_serializing_if = "Option::is_none")]
1150 pub cluster_logging: Option<Vec<LogSetup>>,
1151}
1152
1153#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1155#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1156pub struct Nodegroup {
1157 #[serde(rename = "amiType")]
1159 #[serde(skip_serializing_if = "Option::is_none")]
1160 pub ami_type: Option<String>,
1161 #[serde(rename = "capacityType")]
1163 #[serde(skip_serializing_if = "Option::is_none")]
1164 pub capacity_type: Option<String>,
1165 #[serde(rename = "clusterName")]
1167 #[serde(skip_serializing_if = "Option::is_none")]
1168 pub cluster_name: Option<String>,
1169 #[serde(rename = "createdAt")]
1171 #[serde(skip_serializing_if = "Option::is_none")]
1172 pub created_at: Option<f64>,
1173 #[serde(rename = "diskSize")]
1175 #[serde(skip_serializing_if = "Option::is_none")]
1176 pub disk_size: Option<i64>,
1177 #[serde(rename = "health")]
1179 #[serde(skip_serializing_if = "Option::is_none")]
1180 pub health: Option<NodegroupHealth>,
1181 #[serde(rename = "instanceTypes")]
1183 #[serde(skip_serializing_if = "Option::is_none")]
1184 pub instance_types: Option<Vec<String>>,
1185 #[serde(rename = "labels")]
1187 #[serde(skip_serializing_if = "Option::is_none")]
1188 pub labels: Option<::std::collections::HashMap<String, String>>,
1189 #[serde(rename = "launchTemplate")]
1191 #[serde(skip_serializing_if = "Option::is_none")]
1192 pub launch_template: Option<LaunchTemplateSpecification>,
1193 #[serde(rename = "modifiedAt")]
1195 #[serde(skip_serializing_if = "Option::is_none")]
1196 pub modified_at: Option<f64>,
1197 #[serde(rename = "nodeRole")]
1199 #[serde(skip_serializing_if = "Option::is_none")]
1200 pub node_role: Option<String>,
1201 #[serde(rename = "nodegroupArn")]
1203 #[serde(skip_serializing_if = "Option::is_none")]
1204 pub nodegroup_arn: Option<String>,
1205 #[serde(rename = "nodegroupName")]
1207 #[serde(skip_serializing_if = "Option::is_none")]
1208 pub nodegroup_name: Option<String>,
1209 #[serde(rename = "releaseVersion")]
1211 #[serde(skip_serializing_if = "Option::is_none")]
1212 pub release_version: Option<String>,
1213 #[serde(rename = "remoteAccess")]
1215 #[serde(skip_serializing_if = "Option::is_none")]
1216 pub remote_access: Option<RemoteAccessConfig>,
1217 #[serde(rename = "resources")]
1219 #[serde(skip_serializing_if = "Option::is_none")]
1220 pub resources: Option<NodegroupResources>,
1221 #[serde(rename = "scalingConfig")]
1223 #[serde(skip_serializing_if = "Option::is_none")]
1224 pub scaling_config: Option<NodegroupScalingConfig>,
1225 #[serde(rename = "status")]
1227 #[serde(skip_serializing_if = "Option::is_none")]
1228 pub status: Option<String>,
1229 #[serde(rename = "subnets")]
1231 #[serde(skip_serializing_if = "Option::is_none")]
1232 pub subnets: Option<Vec<String>>,
1233 #[serde(rename = "tags")]
1235 #[serde(skip_serializing_if = "Option::is_none")]
1236 pub tags: Option<::std::collections::HashMap<String, String>>,
1237 #[serde(rename = "taints")]
1239 #[serde(skip_serializing_if = "Option::is_none")]
1240 pub taints: Option<Vec<Taint>>,
1241 #[serde(rename = "updateConfig")]
1242 #[serde(skip_serializing_if = "Option::is_none")]
1243 pub update_config: Option<NodegroupUpdateConfig>,
1244 #[serde(rename = "version")]
1246 #[serde(skip_serializing_if = "Option::is_none")]
1247 pub version: Option<String>,
1248}
1249
1250#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1252#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1253pub struct NodegroupHealth {
1254 #[serde(rename = "issues")]
1256 #[serde(skip_serializing_if = "Option::is_none")]
1257 pub issues: Option<Vec<Issue>>,
1258}
1259
1260#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1262#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1263pub struct NodegroupResources {
1264 #[serde(rename = "autoScalingGroups")]
1266 #[serde(skip_serializing_if = "Option::is_none")]
1267 pub auto_scaling_groups: Option<Vec<AutoScalingGroup>>,
1268 #[serde(rename = "remoteAccessSecurityGroup")]
1270 #[serde(skip_serializing_if = "Option::is_none")]
1271 pub remote_access_security_group: Option<String>,
1272}
1273
1274#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1276pub struct NodegroupScalingConfig {
1277 #[serde(rename = "desiredSize")]
1279 #[serde(skip_serializing_if = "Option::is_none")]
1280 pub desired_size: Option<i64>,
1281 #[serde(rename = "maxSize")]
1283 #[serde(skip_serializing_if = "Option::is_none")]
1284 pub max_size: Option<i64>,
1285 #[serde(rename = "minSize")]
1287 #[serde(skip_serializing_if = "Option::is_none")]
1288 pub min_size: Option<i64>,
1289}
1290
1291#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1292pub struct NodegroupUpdateConfig {
1293 #[serde(rename = "maxUnavailable")]
1294 #[serde(skip_serializing_if = "Option::is_none")]
1295 pub max_unavailable: Option<i64>,
1296 #[serde(rename = "maxUnavailablePercentage")]
1297 #[serde(skip_serializing_if = "Option::is_none")]
1298 pub max_unavailable_percentage: Option<i64>,
1299}
1300
1301#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1303#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1304pub struct OIDC {
1305 #[serde(rename = "issuer")]
1307 #[serde(skip_serializing_if = "Option::is_none")]
1308 pub issuer: Option<String>,
1309}
1310
1311#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1313#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1314pub struct OidcIdentityProviderConfig {
1315 #[serde(rename = "clientId")]
1317 #[serde(skip_serializing_if = "Option::is_none")]
1318 pub client_id: Option<String>,
1319 #[serde(rename = "clusterName")]
1321 #[serde(skip_serializing_if = "Option::is_none")]
1322 pub cluster_name: Option<String>,
1323 #[serde(rename = "groupsClaim")]
1325 #[serde(skip_serializing_if = "Option::is_none")]
1326 pub groups_claim: Option<String>,
1327 #[serde(rename = "groupsPrefix")]
1329 #[serde(skip_serializing_if = "Option::is_none")]
1330 pub groups_prefix: Option<String>,
1331 #[serde(rename = "identityProviderConfigArn")]
1333 #[serde(skip_serializing_if = "Option::is_none")]
1334 pub identity_provider_config_arn: Option<String>,
1335 #[serde(rename = "identityProviderConfigName")]
1337 #[serde(skip_serializing_if = "Option::is_none")]
1338 pub identity_provider_config_name: Option<String>,
1339 #[serde(rename = "issuerUrl")]
1341 #[serde(skip_serializing_if = "Option::is_none")]
1342 pub issuer_url: Option<String>,
1343 #[serde(rename = "requiredClaims")]
1345 #[serde(skip_serializing_if = "Option::is_none")]
1346 pub required_claims: Option<::std::collections::HashMap<String, String>>,
1347 #[serde(rename = "status")]
1349 #[serde(skip_serializing_if = "Option::is_none")]
1350 pub status: Option<String>,
1351 #[serde(rename = "tags")]
1353 #[serde(skip_serializing_if = "Option::is_none")]
1354 pub tags: Option<::std::collections::HashMap<String, String>>,
1355 #[serde(rename = "usernameClaim")]
1357 #[serde(skip_serializing_if = "Option::is_none")]
1358 pub username_claim: Option<String>,
1359 #[serde(rename = "usernamePrefix")]
1361 #[serde(skip_serializing_if = "Option::is_none")]
1362 pub username_prefix: Option<String>,
1363}
1364
1365#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1367#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1368pub struct OidcIdentityProviderConfigRequest {
1369 #[serde(rename = "clientId")]
1371 pub client_id: String,
1372 #[serde(rename = "groupsClaim")]
1374 #[serde(skip_serializing_if = "Option::is_none")]
1375 pub groups_claim: Option<String>,
1376 #[serde(rename = "groupsPrefix")]
1378 #[serde(skip_serializing_if = "Option::is_none")]
1379 pub groups_prefix: Option<String>,
1380 #[serde(rename = "identityProviderConfigName")]
1382 pub identity_provider_config_name: String,
1383 #[serde(rename = "issuerUrl")]
1385 pub issuer_url: String,
1386 #[serde(rename = "requiredClaims")]
1388 #[serde(skip_serializing_if = "Option::is_none")]
1389 pub required_claims: Option<::std::collections::HashMap<String, String>>,
1390 #[serde(rename = "usernameClaim")]
1392 #[serde(skip_serializing_if = "Option::is_none")]
1393 pub username_claim: Option<String>,
1394 #[serde(rename = "usernamePrefix")]
1396 #[serde(skip_serializing_if = "Option::is_none")]
1397 pub username_prefix: Option<String>,
1398}
1399
1400#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1402pub struct Provider {
1403 #[serde(rename = "keyArn")]
1405 #[serde(skip_serializing_if = "Option::is_none")]
1406 pub key_arn: Option<String>,
1407}
1408
1409#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1411pub struct RemoteAccessConfig {
1412 #[serde(rename = "ec2SshKey")]
1414 #[serde(skip_serializing_if = "Option::is_none")]
1415 pub ec_2_ssh_key: Option<String>,
1416 #[serde(rename = "sourceSecurityGroups")]
1418 #[serde(skip_serializing_if = "Option::is_none")]
1419 pub source_security_groups: Option<Vec<String>>,
1420}
1421
1422#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1423#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1424pub struct TagResourceRequest {
1425 #[serde(rename = "resourceArn")]
1427 pub resource_arn: String,
1428 #[serde(rename = "tags")]
1430 pub tags: ::std::collections::HashMap<String, String>,
1431}
1432
1433#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1434#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1435pub struct TagResourceResponse {}
1436
1437#[derive(Clone, Debug, Default, Deserialize, PartialEq, Serialize)]
1439pub struct Taint {
1440 #[serde(rename = "effect")]
1442 #[serde(skip_serializing_if = "Option::is_none")]
1443 pub effect: Option<String>,
1444 #[serde(rename = "key")]
1446 #[serde(skip_serializing_if = "Option::is_none")]
1447 pub key: Option<String>,
1448 #[serde(rename = "value")]
1450 #[serde(skip_serializing_if = "Option::is_none")]
1451 pub value: Option<String>,
1452}
1453
1454#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1455#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1456pub struct UntagResourceRequest {
1457 #[serde(rename = "resourceArn")]
1459 pub resource_arn: String,
1460 #[serde(rename = "tagKeys")]
1462 pub tag_keys: Vec<String>,
1463}
1464
1465#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1466#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1467pub struct UntagResourceResponse {}
1468
1469#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1471#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1472pub struct Update {
1473 #[serde(rename = "createdAt")]
1475 #[serde(skip_serializing_if = "Option::is_none")]
1476 pub created_at: Option<f64>,
1477 #[serde(rename = "errors")]
1479 #[serde(skip_serializing_if = "Option::is_none")]
1480 pub errors: Option<Vec<ErrorDetail>>,
1481 #[serde(rename = "id")]
1483 #[serde(skip_serializing_if = "Option::is_none")]
1484 pub id: Option<String>,
1485 #[serde(rename = "params")]
1487 #[serde(skip_serializing_if = "Option::is_none")]
1488 pub params: Option<Vec<UpdateParam>>,
1489 #[serde(rename = "status")]
1491 #[serde(skip_serializing_if = "Option::is_none")]
1492 pub status: Option<String>,
1493 #[serde(rename = "type")]
1495 #[serde(skip_serializing_if = "Option::is_none")]
1496 pub type_: Option<String>,
1497}
1498
1499#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1500#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1501pub struct UpdateAddonRequest {
1502 #[serde(rename = "addonName")]
1504 pub addon_name: String,
1505 #[serde(rename = "addonVersion")]
1507 #[serde(skip_serializing_if = "Option::is_none")]
1508 pub addon_version: Option<String>,
1509 #[serde(rename = "clientRequestToken")]
1511 #[serde(skip_serializing_if = "Option::is_none")]
1512 pub client_request_token: Option<String>,
1513 #[serde(rename = "clusterName")]
1515 pub cluster_name: String,
1516 #[serde(rename = "resolveConflicts")]
1518 #[serde(skip_serializing_if = "Option::is_none")]
1519 pub resolve_conflicts: Option<String>,
1520 #[serde(rename = "serviceAccountRoleArn")]
1522 #[serde(skip_serializing_if = "Option::is_none")]
1523 pub service_account_role_arn: Option<String>,
1524}
1525
1526#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1527#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1528pub struct UpdateAddonResponse {
1529 #[serde(rename = "update")]
1530 #[serde(skip_serializing_if = "Option::is_none")]
1531 pub update: Option<Update>,
1532}
1533
1534#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1535#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1536pub struct UpdateClusterConfigRequest {
1537 #[serde(rename = "clientRequestToken")]
1539 #[serde(skip_serializing_if = "Option::is_none")]
1540 pub client_request_token: Option<String>,
1541 #[serde(rename = "logging")]
1543 #[serde(skip_serializing_if = "Option::is_none")]
1544 pub logging: Option<Logging>,
1545 #[serde(rename = "name")]
1547 pub name: String,
1548 #[serde(rename = "resourcesVpcConfig")]
1549 #[serde(skip_serializing_if = "Option::is_none")]
1550 pub resources_vpc_config: Option<VpcConfigRequest>,
1551}
1552
1553#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1554#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1555pub struct UpdateClusterConfigResponse {
1556 #[serde(rename = "update")]
1557 #[serde(skip_serializing_if = "Option::is_none")]
1558 pub update: Option<Update>,
1559}
1560
1561#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1562#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1563pub struct UpdateClusterVersionRequest {
1564 #[serde(rename = "clientRequestToken")]
1566 #[serde(skip_serializing_if = "Option::is_none")]
1567 pub client_request_token: Option<String>,
1568 #[serde(rename = "name")]
1570 pub name: String,
1571 #[serde(rename = "version")]
1573 pub version: String,
1574}
1575
1576#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1577#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1578pub struct UpdateClusterVersionResponse {
1579 #[serde(rename = "update")]
1581 #[serde(skip_serializing_if = "Option::is_none")]
1582 pub update: Option<Update>,
1583}
1584
1585#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1587#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1588pub struct UpdateLabelsPayload {
1589 #[serde(rename = "addOrUpdateLabels")]
1591 #[serde(skip_serializing_if = "Option::is_none")]
1592 pub add_or_update_labels: Option<::std::collections::HashMap<String, String>>,
1593 #[serde(rename = "removeLabels")]
1595 #[serde(skip_serializing_if = "Option::is_none")]
1596 pub remove_labels: Option<Vec<String>>,
1597}
1598
1599#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1600#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1601pub struct UpdateNodegroupConfigRequest {
1602 #[serde(rename = "clientRequestToken")]
1604 #[serde(skip_serializing_if = "Option::is_none")]
1605 pub client_request_token: Option<String>,
1606 #[serde(rename = "clusterName")]
1608 pub cluster_name: String,
1609 #[serde(rename = "labels")]
1611 #[serde(skip_serializing_if = "Option::is_none")]
1612 pub labels: Option<UpdateLabelsPayload>,
1613 #[serde(rename = "nodegroupName")]
1615 pub nodegroup_name: String,
1616 #[serde(rename = "scalingConfig")]
1618 #[serde(skip_serializing_if = "Option::is_none")]
1619 pub scaling_config: Option<NodegroupScalingConfig>,
1620 #[serde(rename = "taints")]
1622 #[serde(skip_serializing_if = "Option::is_none")]
1623 pub taints: Option<UpdateTaintsPayload>,
1624 #[serde(rename = "updateConfig")]
1625 #[serde(skip_serializing_if = "Option::is_none")]
1626 pub update_config: Option<NodegroupUpdateConfig>,
1627}
1628
1629#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1630#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1631pub struct UpdateNodegroupConfigResponse {
1632 #[serde(rename = "update")]
1633 #[serde(skip_serializing_if = "Option::is_none")]
1634 pub update: Option<Update>,
1635}
1636
1637#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1638#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1639pub struct UpdateNodegroupVersionRequest {
1640 #[serde(rename = "clientRequestToken")]
1642 #[serde(skip_serializing_if = "Option::is_none")]
1643 pub client_request_token: Option<String>,
1644 #[serde(rename = "clusterName")]
1646 pub cluster_name: String,
1647 #[serde(rename = "force")]
1649 #[serde(skip_serializing_if = "Option::is_none")]
1650 pub force: Option<bool>,
1651 #[serde(rename = "launchTemplate")]
1653 #[serde(skip_serializing_if = "Option::is_none")]
1654 pub launch_template: Option<LaunchTemplateSpecification>,
1655 #[serde(rename = "nodegroupName")]
1657 pub nodegroup_name: String,
1658 #[serde(rename = "releaseVersion")]
1660 #[serde(skip_serializing_if = "Option::is_none")]
1661 pub release_version: Option<String>,
1662 #[serde(rename = "version")]
1664 #[serde(skip_serializing_if = "Option::is_none")]
1665 pub version: Option<String>,
1666}
1667
1668#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1669#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1670pub struct UpdateNodegroupVersionResponse {
1671 #[serde(rename = "update")]
1672 #[serde(skip_serializing_if = "Option::is_none")]
1673 pub update: Option<Update>,
1674}
1675
1676#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1678#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1679pub struct UpdateParam {
1680 #[serde(rename = "type")]
1682 #[serde(skip_serializing_if = "Option::is_none")]
1683 pub type_: Option<String>,
1684 #[serde(rename = "value")]
1686 #[serde(skip_serializing_if = "Option::is_none")]
1687 pub value: Option<String>,
1688}
1689
1690#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1692#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1693pub struct UpdateTaintsPayload {
1694 #[serde(rename = "addOrUpdateTaints")]
1696 #[serde(skip_serializing_if = "Option::is_none")]
1697 pub add_or_update_taints: Option<Vec<Taint>>,
1698 #[serde(rename = "removeTaints")]
1700 #[serde(skip_serializing_if = "Option::is_none")]
1701 pub remove_taints: Option<Vec<Taint>>,
1702}
1703
1704#[derive(Clone, Debug, Default, PartialEq, Serialize)]
1706#[cfg_attr(feature = "deserialize_structs", derive(Deserialize))]
1707pub struct VpcConfigRequest {
1708 #[serde(rename = "endpointPrivateAccess")]
1710 #[serde(skip_serializing_if = "Option::is_none")]
1711 pub endpoint_private_access: Option<bool>,
1712 #[serde(rename = "endpointPublicAccess")]
1714 #[serde(skip_serializing_if = "Option::is_none")]
1715 pub endpoint_public_access: Option<bool>,
1716 #[serde(rename = "publicAccessCidrs")]
1718 #[serde(skip_serializing_if = "Option::is_none")]
1719 pub public_access_cidrs: Option<Vec<String>>,
1720 #[serde(rename = "securityGroupIds")]
1722 #[serde(skip_serializing_if = "Option::is_none")]
1723 pub security_group_ids: Option<Vec<String>>,
1724 #[serde(rename = "subnetIds")]
1726 #[serde(skip_serializing_if = "Option::is_none")]
1727 pub subnet_ids: Option<Vec<String>>,
1728}
1729
1730#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
1732#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
1733pub struct VpcConfigResponse {
1734 #[serde(rename = "clusterSecurityGroupId")]
1736 #[serde(skip_serializing_if = "Option::is_none")]
1737 pub cluster_security_group_id: Option<String>,
1738 #[serde(rename = "endpointPrivateAccess")]
1740 #[serde(skip_serializing_if = "Option::is_none")]
1741 pub endpoint_private_access: Option<bool>,
1742 #[serde(rename = "endpointPublicAccess")]
1744 #[serde(skip_serializing_if = "Option::is_none")]
1745 pub endpoint_public_access: Option<bool>,
1746 #[serde(rename = "publicAccessCidrs")]
1748 #[serde(skip_serializing_if = "Option::is_none")]
1749 pub public_access_cidrs: Option<Vec<String>>,
1750 #[serde(rename = "securityGroupIds")]
1752 #[serde(skip_serializing_if = "Option::is_none")]
1753 pub security_group_ids: Option<Vec<String>>,
1754 #[serde(rename = "subnetIds")]
1756 #[serde(skip_serializing_if = "Option::is_none")]
1757 pub subnet_ids: Option<Vec<String>>,
1758 #[serde(rename = "vpcId")]
1760 #[serde(skip_serializing_if = "Option::is_none")]
1761 pub vpc_id: Option<String>,
1762}
1763
1764#[derive(Debug, PartialEq)]
1766pub enum AssociateEncryptionConfigError {
1767 Client(String),
1769 InvalidParameter(String),
1771 InvalidRequest(String),
1773 ResourceInUse(String),
1775 ResourceNotFound(String),
1777 Server(String),
1779}
1780
1781impl AssociateEncryptionConfigError {
1782 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<AssociateEncryptionConfigError> {
1783 if let Some(err) = proto::json::Error::parse_rest(&res) {
1784 match err.typ.as_str() {
1785 "ClientException" => {
1786 return RusotoError::Service(AssociateEncryptionConfigError::Client(err.msg))
1787 }
1788 "InvalidParameterException" => {
1789 return RusotoError::Service(AssociateEncryptionConfigError::InvalidParameter(
1790 err.msg,
1791 ))
1792 }
1793 "InvalidRequestException" => {
1794 return RusotoError::Service(AssociateEncryptionConfigError::InvalidRequest(
1795 err.msg,
1796 ))
1797 }
1798 "ResourceInUseException" => {
1799 return RusotoError::Service(AssociateEncryptionConfigError::ResourceInUse(
1800 err.msg,
1801 ))
1802 }
1803 "ResourceNotFoundException" => {
1804 return RusotoError::Service(AssociateEncryptionConfigError::ResourceNotFound(
1805 err.msg,
1806 ))
1807 }
1808 "ServerException" => {
1809 return RusotoError::Service(AssociateEncryptionConfigError::Server(err.msg))
1810 }
1811 "ValidationException" => return RusotoError::Validation(err.msg),
1812 _ => {}
1813 }
1814 }
1815 RusotoError::Unknown(res)
1816 }
1817}
1818impl fmt::Display for AssociateEncryptionConfigError {
1819 #[allow(unused_variables)]
1820 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
1821 match *self {
1822 AssociateEncryptionConfigError::Client(ref cause) => write!(f, "{}", cause),
1823 AssociateEncryptionConfigError::InvalidParameter(ref cause) => write!(f, "{}", cause),
1824 AssociateEncryptionConfigError::InvalidRequest(ref cause) => write!(f, "{}", cause),
1825 AssociateEncryptionConfigError::ResourceInUse(ref cause) => write!(f, "{}", cause),
1826 AssociateEncryptionConfigError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
1827 AssociateEncryptionConfigError::Server(ref cause) => write!(f, "{}", cause),
1828 }
1829 }
1830}
1831impl Error for AssociateEncryptionConfigError {}
1832#[derive(Debug, PartialEq)]
1834pub enum AssociateIdentityProviderConfigError {
1835 Client(String),
1837 InvalidParameter(String),
1839 InvalidRequest(String),
1841 ResourceInUse(String),
1843 ResourceNotFound(String),
1845 Server(String),
1847}
1848
1849impl AssociateIdentityProviderConfigError {
1850 pub fn from_response(
1851 res: BufferedHttpResponse,
1852 ) -> RusotoError<AssociateIdentityProviderConfigError> {
1853 if let Some(err) = proto::json::Error::parse_rest(&res) {
1854 match err.typ.as_str() {
1855 "ClientException" => {
1856 return RusotoError::Service(AssociateIdentityProviderConfigError::Client(
1857 err.msg,
1858 ))
1859 }
1860 "InvalidParameterException" => {
1861 return RusotoError::Service(
1862 AssociateIdentityProviderConfigError::InvalidParameter(err.msg),
1863 )
1864 }
1865 "InvalidRequestException" => {
1866 return RusotoError::Service(
1867 AssociateIdentityProviderConfigError::InvalidRequest(err.msg),
1868 )
1869 }
1870 "ResourceInUseException" => {
1871 return RusotoError::Service(
1872 AssociateIdentityProviderConfigError::ResourceInUse(err.msg),
1873 )
1874 }
1875 "ResourceNotFoundException" => {
1876 return RusotoError::Service(
1877 AssociateIdentityProviderConfigError::ResourceNotFound(err.msg),
1878 )
1879 }
1880 "ServerException" => {
1881 return RusotoError::Service(AssociateIdentityProviderConfigError::Server(
1882 err.msg,
1883 ))
1884 }
1885 "ValidationException" => return RusotoError::Validation(err.msg),
1886 _ => {}
1887 }
1888 }
1889 RusotoError::Unknown(res)
1890 }
1891}
1892impl fmt::Display for AssociateIdentityProviderConfigError {
1893 #[allow(unused_variables)]
1894 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
1895 match *self {
1896 AssociateIdentityProviderConfigError::Client(ref cause) => write!(f, "{}", cause),
1897 AssociateIdentityProviderConfigError::InvalidParameter(ref cause) => {
1898 write!(f, "{}", cause)
1899 }
1900 AssociateIdentityProviderConfigError::InvalidRequest(ref cause) => {
1901 write!(f, "{}", cause)
1902 }
1903 AssociateIdentityProviderConfigError::ResourceInUse(ref cause) => {
1904 write!(f, "{}", cause)
1905 }
1906 AssociateIdentityProviderConfigError::ResourceNotFound(ref cause) => {
1907 write!(f, "{}", cause)
1908 }
1909 AssociateIdentityProviderConfigError::Server(ref cause) => write!(f, "{}", cause),
1910 }
1911 }
1912}
1913impl Error for AssociateIdentityProviderConfigError {}
1914#[derive(Debug, PartialEq)]
1916pub enum CreateAddonError {
1917 Client(String),
1919 InvalidParameter(String),
1921 InvalidRequest(String),
1923 ResourceInUse(String),
1925 ResourceNotFound(String),
1927 Server(String),
1929}
1930
1931impl CreateAddonError {
1932 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateAddonError> {
1933 if let Some(err) = proto::json::Error::parse_rest(&res) {
1934 match err.typ.as_str() {
1935 "ClientException" => {
1936 return RusotoError::Service(CreateAddonError::Client(err.msg))
1937 }
1938 "InvalidParameterException" => {
1939 return RusotoError::Service(CreateAddonError::InvalidParameter(err.msg))
1940 }
1941 "InvalidRequestException" => {
1942 return RusotoError::Service(CreateAddonError::InvalidRequest(err.msg))
1943 }
1944 "ResourceInUseException" => {
1945 return RusotoError::Service(CreateAddonError::ResourceInUse(err.msg))
1946 }
1947 "ResourceNotFoundException" => {
1948 return RusotoError::Service(CreateAddonError::ResourceNotFound(err.msg))
1949 }
1950 "ServerException" => {
1951 return RusotoError::Service(CreateAddonError::Server(err.msg))
1952 }
1953 "ValidationException" => return RusotoError::Validation(err.msg),
1954 _ => {}
1955 }
1956 }
1957 RusotoError::Unknown(res)
1958 }
1959}
1960impl fmt::Display for CreateAddonError {
1961 #[allow(unused_variables)]
1962 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
1963 match *self {
1964 CreateAddonError::Client(ref cause) => write!(f, "{}", cause),
1965 CreateAddonError::InvalidParameter(ref cause) => write!(f, "{}", cause),
1966 CreateAddonError::InvalidRequest(ref cause) => write!(f, "{}", cause),
1967 CreateAddonError::ResourceInUse(ref cause) => write!(f, "{}", cause),
1968 CreateAddonError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
1969 CreateAddonError::Server(ref cause) => write!(f, "{}", cause),
1970 }
1971 }
1972}
1973impl Error for CreateAddonError {}
1974#[derive(Debug, PartialEq)]
1976pub enum CreateClusterError {
1977 Client(String),
1979 InvalidParameter(String),
1981 ResourceInUse(String),
1983 ResourceLimitExceeded(String),
1985 Server(String),
1987 ServiceUnavailable(String),
1989 UnsupportedAvailabilityZone(String),
1991}
1992
1993impl CreateClusterError {
1994 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateClusterError> {
1995 if let Some(err) = proto::json::Error::parse_rest(&res) {
1996 match err.typ.as_str() {
1997 "ClientException" => {
1998 return RusotoError::Service(CreateClusterError::Client(err.msg))
1999 }
2000 "InvalidParameterException" => {
2001 return RusotoError::Service(CreateClusterError::InvalidParameter(err.msg))
2002 }
2003 "ResourceInUseException" => {
2004 return RusotoError::Service(CreateClusterError::ResourceInUse(err.msg))
2005 }
2006 "ResourceLimitExceededException" => {
2007 return RusotoError::Service(CreateClusterError::ResourceLimitExceeded(err.msg))
2008 }
2009 "ServerException" => {
2010 return RusotoError::Service(CreateClusterError::Server(err.msg))
2011 }
2012 "ServiceUnavailableException" => {
2013 return RusotoError::Service(CreateClusterError::ServiceUnavailable(err.msg))
2014 }
2015 "UnsupportedAvailabilityZoneException" => {
2016 return RusotoError::Service(CreateClusterError::UnsupportedAvailabilityZone(
2017 err.msg,
2018 ))
2019 }
2020 "ValidationException" => return RusotoError::Validation(err.msg),
2021 _ => {}
2022 }
2023 }
2024 RusotoError::Unknown(res)
2025 }
2026}
2027impl fmt::Display for CreateClusterError {
2028 #[allow(unused_variables)]
2029 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2030 match *self {
2031 CreateClusterError::Client(ref cause) => write!(f, "{}", cause),
2032 CreateClusterError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2033 CreateClusterError::ResourceInUse(ref cause) => write!(f, "{}", cause),
2034 CreateClusterError::ResourceLimitExceeded(ref cause) => write!(f, "{}", cause),
2035 CreateClusterError::Server(ref cause) => write!(f, "{}", cause),
2036 CreateClusterError::ServiceUnavailable(ref cause) => write!(f, "{}", cause),
2037 CreateClusterError::UnsupportedAvailabilityZone(ref cause) => write!(f, "{}", cause),
2038 }
2039 }
2040}
2041impl Error for CreateClusterError {}
2042#[derive(Debug, PartialEq)]
2044pub enum CreateFargateProfileError {
2045 Client(String),
2047 InvalidParameter(String),
2049 InvalidRequest(String),
2051 ResourceLimitExceeded(String),
2053 Server(String),
2055 UnsupportedAvailabilityZone(String),
2057}
2058
2059impl CreateFargateProfileError {
2060 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateFargateProfileError> {
2061 if let Some(err) = proto::json::Error::parse_rest(&res) {
2062 match err.typ.as_str() {
2063 "ClientException" => {
2064 return RusotoError::Service(CreateFargateProfileError::Client(err.msg))
2065 }
2066 "InvalidParameterException" => {
2067 return RusotoError::Service(CreateFargateProfileError::InvalidParameter(
2068 err.msg,
2069 ))
2070 }
2071 "InvalidRequestException" => {
2072 return RusotoError::Service(CreateFargateProfileError::InvalidRequest(err.msg))
2073 }
2074 "ResourceLimitExceededException" => {
2075 return RusotoError::Service(CreateFargateProfileError::ResourceLimitExceeded(
2076 err.msg,
2077 ))
2078 }
2079 "ServerException" => {
2080 return RusotoError::Service(CreateFargateProfileError::Server(err.msg))
2081 }
2082 "UnsupportedAvailabilityZoneException" => {
2083 return RusotoError::Service(
2084 CreateFargateProfileError::UnsupportedAvailabilityZone(err.msg),
2085 )
2086 }
2087 "ValidationException" => return RusotoError::Validation(err.msg),
2088 _ => {}
2089 }
2090 }
2091 RusotoError::Unknown(res)
2092 }
2093}
2094impl fmt::Display for CreateFargateProfileError {
2095 #[allow(unused_variables)]
2096 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2097 match *self {
2098 CreateFargateProfileError::Client(ref cause) => write!(f, "{}", cause),
2099 CreateFargateProfileError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2100 CreateFargateProfileError::InvalidRequest(ref cause) => write!(f, "{}", cause),
2101 CreateFargateProfileError::ResourceLimitExceeded(ref cause) => write!(f, "{}", cause),
2102 CreateFargateProfileError::Server(ref cause) => write!(f, "{}", cause),
2103 CreateFargateProfileError::UnsupportedAvailabilityZone(ref cause) => {
2104 write!(f, "{}", cause)
2105 }
2106 }
2107 }
2108}
2109impl Error for CreateFargateProfileError {}
2110#[derive(Debug, PartialEq)]
2112pub enum CreateNodegroupError {
2113 Client(String),
2115 InvalidParameter(String),
2117 InvalidRequest(String),
2119 ResourceInUse(String),
2121 ResourceLimitExceeded(String),
2123 Server(String),
2125 ServiceUnavailable(String),
2127}
2128
2129impl CreateNodegroupError {
2130 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<CreateNodegroupError> {
2131 if let Some(err) = proto::json::Error::parse_rest(&res) {
2132 match err.typ.as_str() {
2133 "ClientException" => {
2134 return RusotoError::Service(CreateNodegroupError::Client(err.msg))
2135 }
2136 "InvalidParameterException" => {
2137 return RusotoError::Service(CreateNodegroupError::InvalidParameter(err.msg))
2138 }
2139 "InvalidRequestException" => {
2140 return RusotoError::Service(CreateNodegroupError::InvalidRequest(err.msg))
2141 }
2142 "ResourceInUseException" => {
2143 return RusotoError::Service(CreateNodegroupError::ResourceInUse(err.msg))
2144 }
2145 "ResourceLimitExceededException" => {
2146 return RusotoError::Service(CreateNodegroupError::ResourceLimitExceeded(
2147 err.msg,
2148 ))
2149 }
2150 "ServerException" => {
2151 return RusotoError::Service(CreateNodegroupError::Server(err.msg))
2152 }
2153 "ServiceUnavailableException" => {
2154 return RusotoError::Service(CreateNodegroupError::ServiceUnavailable(err.msg))
2155 }
2156 "ValidationException" => return RusotoError::Validation(err.msg),
2157 _ => {}
2158 }
2159 }
2160 RusotoError::Unknown(res)
2161 }
2162}
2163impl fmt::Display for CreateNodegroupError {
2164 #[allow(unused_variables)]
2165 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2166 match *self {
2167 CreateNodegroupError::Client(ref cause) => write!(f, "{}", cause),
2168 CreateNodegroupError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2169 CreateNodegroupError::InvalidRequest(ref cause) => write!(f, "{}", cause),
2170 CreateNodegroupError::ResourceInUse(ref cause) => write!(f, "{}", cause),
2171 CreateNodegroupError::ResourceLimitExceeded(ref cause) => write!(f, "{}", cause),
2172 CreateNodegroupError::Server(ref cause) => write!(f, "{}", cause),
2173 CreateNodegroupError::ServiceUnavailable(ref cause) => write!(f, "{}", cause),
2174 }
2175 }
2176}
2177impl Error for CreateNodegroupError {}
2178#[derive(Debug, PartialEq)]
2180pub enum DeleteAddonError {
2181 Client(String),
2183 InvalidParameter(String),
2185 InvalidRequest(String),
2187 ResourceNotFound(String),
2189 Server(String),
2191}
2192
2193impl DeleteAddonError {
2194 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteAddonError> {
2195 if let Some(err) = proto::json::Error::parse_rest(&res) {
2196 match err.typ.as_str() {
2197 "ClientException" => {
2198 return RusotoError::Service(DeleteAddonError::Client(err.msg))
2199 }
2200 "InvalidParameterException" => {
2201 return RusotoError::Service(DeleteAddonError::InvalidParameter(err.msg))
2202 }
2203 "InvalidRequestException" => {
2204 return RusotoError::Service(DeleteAddonError::InvalidRequest(err.msg))
2205 }
2206 "ResourceNotFoundException" => {
2207 return RusotoError::Service(DeleteAddonError::ResourceNotFound(err.msg))
2208 }
2209 "ServerException" => {
2210 return RusotoError::Service(DeleteAddonError::Server(err.msg))
2211 }
2212 "ValidationException" => return RusotoError::Validation(err.msg),
2213 _ => {}
2214 }
2215 }
2216 RusotoError::Unknown(res)
2217 }
2218}
2219impl fmt::Display for DeleteAddonError {
2220 #[allow(unused_variables)]
2221 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2222 match *self {
2223 DeleteAddonError::Client(ref cause) => write!(f, "{}", cause),
2224 DeleteAddonError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2225 DeleteAddonError::InvalidRequest(ref cause) => write!(f, "{}", cause),
2226 DeleteAddonError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2227 DeleteAddonError::Server(ref cause) => write!(f, "{}", cause),
2228 }
2229 }
2230}
2231impl Error for DeleteAddonError {}
2232#[derive(Debug, PartialEq)]
2234pub enum DeleteClusterError {
2235 Client(String),
2237 ResourceInUse(String),
2239 ResourceNotFound(String),
2241 Server(String),
2243 ServiceUnavailable(String),
2245}
2246
2247impl DeleteClusterError {
2248 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteClusterError> {
2249 if let Some(err) = proto::json::Error::parse_rest(&res) {
2250 match err.typ.as_str() {
2251 "ClientException" => {
2252 return RusotoError::Service(DeleteClusterError::Client(err.msg))
2253 }
2254 "ResourceInUseException" => {
2255 return RusotoError::Service(DeleteClusterError::ResourceInUse(err.msg))
2256 }
2257 "ResourceNotFoundException" => {
2258 return RusotoError::Service(DeleteClusterError::ResourceNotFound(err.msg))
2259 }
2260 "ServerException" => {
2261 return RusotoError::Service(DeleteClusterError::Server(err.msg))
2262 }
2263 "ServiceUnavailableException" => {
2264 return RusotoError::Service(DeleteClusterError::ServiceUnavailable(err.msg))
2265 }
2266 "ValidationException" => return RusotoError::Validation(err.msg),
2267 _ => {}
2268 }
2269 }
2270 RusotoError::Unknown(res)
2271 }
2272}
2273impl fmt::Display for DeleteClusterError {
2274 #[allow(unused_variables)]
2275 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2276 match *self {
2277 DeleteClusterError::Client(ref cause) => write!(f, "{}", cause),
2278 DeleteClusterError::ResourceInUse(ref cause) => write!(f, "{}", cause),
2279 DeleteClusterError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2280 DeleteClusterError::Server(ref cause) => write!(f, "{}", cause),
2281 DeleteClusterError::ServiceUnavailable(ref cause) => write!(f, "{}", cause),
2282 }
2283 }
2284}
2285impl Error for DeleteClusterError {}
2286#[derive(Debug, PartialEq)]
2288pub enum DeleteFargateProfileError {
2289 Client(String),
2291 InvalidParameter(String),
2293 ResourceNotFound(String),
2295 Server(String),
2297}
2298
2299impl DeleteFargateProfileError {
2300 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteFargateProfileError> {
2301 if let Some(err) = proto::json::Error::parse_rest(&res) {
2302 match err.typ.as_str() {
2303 "ClientException" => {
2304 return RusotoError::Service(DeleteFargateProfileError::Client(err.msg))
2305 }
2306 "InvalidParameterException" => {
2307 return RusotoError::Service(DeleteFargateProfileError::InvalidParameter(
2308 err.msg,
2309 ))
2310 }
2311 "ResourceNotFoundException" => {
2312 return RusotoError::Service(DeleteFargateProfileError::ResourceNotFound(
2313 err.msg,
2314 ))
2315 }
2316 "ServerException" => {
2317 return RusotoError::Service(DeleteFargateProfileError::Server(err.msg))
2318 }
2319 "ValidationException" => return RusotoError::Validation(err.msg),
2320 _ => {}
2321 }
2322 }
2323 RusotoError::Unknown(res)
2324 }
2325}
2326impl fmt::Display for DeleteFargateProfileError {
2327 #[allow(unused_variables)]
2328 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2329 match *self {
2330 DeleteFargateProfileError::Client(ref cause) => write!(f, "{}", cause),
2331 DeleteFargateProfileError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2332 DeleteFargateProfileError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2333 DeleteFargateProfileError::Server(ref cause) => write!(f, "{}", cause),
2334 }
2335 }
2336}
2337impl Error for DeleteFargateProfileError {}
2338#[derive(Debug, PartialEq)]
2340pub enum DeleteNodegroupError {
2341 Client(String),
2343 InvalidParameter(String),
2345 ResourceInUse(String),
2347 ResourceNotFound(String),
2349 Server(String),
2351 ServiceUnavailable(String),
2353}
2354
2355impl DeleteNodegroupError {
2356 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DeleteNodegroupError> {
2357 if let Some(err) = proto::json::Error::parse_rest(&res) {
2358 match err.typ.as_str() {
2359 "ClientException" => {
2360 return RusotoError::Service(DeleteNodegroupError::Client(err.msg))
2361 }
2362 "InvalidParameterException" => {
2363 return RusotoError::Service(DeleteNodegroupError::InvalidParameter(err.msg))
2364 }
2365 "ResourceInUseException" => {
2366 return RusotoError::Service(DeleteNodegroupError::ResourceInUse(err.msg))
2367 }
2368 "ResourceNotFoundException" => {
2369 return RusotoError::Service(DeleteNodegroupError::ResourceNotFound(err.msg))
2370 }
2371 "ServerException" => {
2372 return RusotoError::Service(DeleteNodegroupError::Server(err.msg))
2373 }
2374 "ServiceUnavailableException" => {
2375 return RusotoError::Service(DeleteNodegroupError::ServiceUnavailable(err.msg))
2376 }
2377 "ValidationException" => return RusotoError::Validation(err.msg),
2378 _ => {}
2379 }
2380 }
2381 RusotoError::Unknown(res)
2382 }
2383}
2384impl fmt::Display for DeleteNodegroupError {
2385 #[allow(unused_variables)]
2386 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2387 match *self {
2388 DeleteNodegroupError::Client(ref cause) => write!(f, "{}", cause),
2389 DeleteNodegroupError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2390 DeleteNodegroupError::ResourceInUse(ref cause) => write!(f, "{}", cause),
2391 DeleteNodegroupError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2392 DeleteNodegroupError::Server(ref cause) => write!(f, "{}", cause),
2393 DeleteNodegroupError::ServiceUnavailable(ref cause) => write!(f, "{}", cause),
2394 }
2395 }
2396}
2397impl Error for DeleteNodegroupError {}
2398#[derive(Debug, PartialEq)]
2400pub enum DescribeAddonError {
2401 Client(String),
2403 InvalidParameter(String),
2405 InvalidRequest(String),
2407 ResourceNotFound(String),
2409 Server(String),
2411}
2412
2413impl DescribeAddonError {
2414 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeAddonError> {
2415 if let Some(err) = proto::json::Error::parse_rest(&res) {
2416 match err.typ.as_str() {
2417 "ClientException" => {
2418 return RusotoError::Service(DescribeAddonError::Client(err.msg))
2419 }
2420 "InvalidParameterException" => {
2421 return RusotoError::Service(DescribeAddonError::InvalidParameter(err.msg))
2422 }
2423 "InvalidRequestException" => {
2424 return RusotoError::Service(DescribeAddonError::InvalidRequest(err.msg))
2425 }
2426 "ResourceNotFoundException" => {
2427 return RusotoError::Service(DescribeAddonError::ResourceNotFound(err.msg))
2428 }
2429 "ServerException" => {
2430 return RusotoError::Service(DescribeAddonError::Server(err.msg))
2431 }
2432 "ValidationException" => return RusotoError::Validation(err.msg),
2433 _ => {}
2434 }
2435 }
2436 RusotoError::Unknown(res)
2437 }
2438}
2439impl fmt::Display for DescribeAddonError {
2440 #[allow(unused_variables)]
2441 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2442 match *self {
2443 DescribeAddonError::Client(ref cause) => write!(f, "{}", cause),
2444 DescribeAddonError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2445 DescribeAddonError::InvalidRequest(ref cause) => write!(f, "{}", cause),
2446 DescribeAddonError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2447 DescribeAddonError::Server(ref cause) => write!(f, "{}", cause),
2448 }
2449 }
2450}
2451impl Error for DescribeAddonError {}
2452#[derive(Debug, PartialEq)]
2454pub enum DescribeAddonVersionsError {
2455 InvalidParameter(String),
2457 ResourceNotFound(String),
2459 Server(String),
2461}
2462
2463impl DescribeAddonVersionsError {
2464 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeAddonVersionsError> {
2465 if let Some(err) = proto::json::Error::parse_rest(&res) {
2466 match err.typ.as_str() {
2467 "InvalidParameterException" => {
2468 return RusotoError::Service(DescribeAddonVersionsError::InvalidParameter(
2469 err.msg,
2470 ))
2471 }
2472 "ResourceNotFoundException" => {
2473 return RusotoError::Service(DescribeAddonVersionsError::ResourceNotFound(
2474 err.msg,
2475 ))
2476 }
2477 "ServerException" => {
2478 return RusotoError::Service(DescribeAddonVersionsError::Server(err.msg))
2479 }
2480 "ValidationException" => return RusotoError::Validation(err.msg),
2481 _ => {}
2482 }
2483 }
2484 RusotoError::Unknown(res)
2485 }
2486}
2487impl fmt::Display for DescribeAddonVersionsError {
2488 #[allow(unused_variables)]
2489 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2490 match *self {
2491 DescribeAddonVersionsError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2492 DescribeAddonVersionsError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2493 DescribeAddonVersionsError::Server(ref cause) => write!(f, "{}", cause),
2494 }
2495 }
2496}
2497impl Error for DescribeAddonVersionsError {}
2498#[derive(Debug, PartialEq)]
2500pub enum DescribeClusterError {
2501 Client(String),
2503 ResourceNotFound(String),
2505 Server(String),
2507 ServiceUnavailable(String),
2509}
2510
2511impl DescribeClusterError {
2512 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeClusterError> {
2513 if let Some(err) = proto::json::Error::parse_rest(&res) {
2514 match err.typ.as_str() {
2515 "ClientException" => {
2516 return RusotoError::Service(DescribeClusterError::Client(err.msg))
2517 }
2518 "ResourceNotFoundException" => {
2519 return RusotoError::Service(DescribeClusterError::ResourceNotFound(err.msg))
2520 }
2521 "ServerException" => {
2522 return RusotoError::Service(DescribeClusterError::Server(err.msg))
2523 }
2524 "ServiceUnavailableException" => {
2525 return RusotoError::Service(DescribeClusterError::ServiceUnavailable(err.msg))
2526 }
2527 "ValidationException" => return RusotoError::Validation(err.msg),
2528 _ => {}
2529 }
2530 }
2531 RusotoError::Unknown(res)
2532 }
2533}
2534impl fmt::Display for DescribeClusterError {
2535 #[allow(unused_variables)]
2536 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2537 match *self {
2538 DescribeClusterError::Client(ref cause) => write!(f, "{}", cause),
2539 DescribeClusterError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2540 DescribeClusterError::Server(ref cause) => write!(f, "{}", cause),
2541 DescribeClusterError::ServiceUnavailable(ref cause) => write!(f, "{}", cause),
2542 }
2543 }
2544}
2545impl Error for DescribeClusterError {}
2546#[derive(Debug, PartialEq)]
2548pub enum DescribeFargateProfileError {
2549 Client(String),
2551 InvalidParameter(String),
2553 ResourceNotFound(String),
2555 Server(String),
2557}
2558
2559impl DescribeFargateProfileError {
2560 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeFargateProfileError> {
2561 if let Some(err) = proto::json::Error::parse_rest(&res) {
2562 match err.typ.as_str() {
2563 "ClientException" => {
2564 return RusotoError::Service(DescribeFargateProfileError::Client(err.msg))
2565 }
2566 "InvalidParameterException" => {
2567 return RusotoError::Service(DescribeFargateProfileError::InvalidParameter(
2568 err.msg,
2569 ))
2570 }
2571 "ResourceNotFoundException" => {
2572 return RusotoError::Service(DescribeFargateProfileError::ResourceNotFound(
2573 err.msg,
2574 ))
2575 }
2576 "ServerException" => {
2577 return RusotoError::Service(DescribeFargateProfileError::Server(err.msg))
2578 }
2579 "ValidationException" => return RusotoError::Validation(err.msg),
2580 _ => {}
2581 }
2582 }
2583 RusotoError::Unknown(res)
2584 }
2585}
2586impl fmt::Display for DescribeFargateProfileError {
2587 #[allow(unused_variables)]
2588 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2589 match *self {
2590 DescribeFargateProfileError::Client(ref cause) => write!(f, "{}", cause),
2591 DescribeFargateProfileError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2592 DescribeFargateProfileError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2593 DescribeFargateProfileError::Server(ref cause) => write!(f, "{}", cause),
2594 }
2595 }
2596}
2597impl Error for DescribeFargateProfileError {}
2598#[derive(Debug, PartialEq)]
2600pub enum DescribeIdentityProviderConfigError {
2601 Client(String),
2603 InvalidParameter(String),
2605 ResourceNotFound(String),
2607 Server(String),
2609 ServiceUnavailable(String),
2611}
2612
2613impl DescribeIdentityProviderConfigError {
2614 pub fn from_response(
2615 res: BufferedHttpResponse,
2616 ) -> RusotoError<DescribeIdentityProviderConfigError> {
2617 if let Some(err) = proto::json::Error::parse_rest(&res) {
2618 match err.typ.as_str() {
2619 "ClientException" => {
2620 return RusotoError::Service(DescribeIdentityProviderConfigError::Client(
2621 err.msg,
2622 ))
2623 }
2624 "InvalidParameterException" => {
2625 return RusotoError::Service(
2626 DescribeIdentityProviderConfigError::InvalidParameter(err.msg),
2627 )
2628 }
2629 "ResourceNotFoundException" => {
2630 return RusotoError::Service(
2631 DescribeIdentityProviderConfigError::ResourceNotFound(err.msg),
2632 )
2633 }
2634 "ServerException" => {
2635 return RusotoError::Service(DescribeIdentityProviderConfigError::Server(
2636 err.msg,
2637 ))
2638 }
2639 "ServiceUnavailableException" => {
2640 return RusotoError::Service(
2641 DescribeIdentityProviderConfigError::ServiceUnavailable(err.msg),
2642 )
2643 }
2644 "ValidationException" => return RusotoError::Validation(err.msg),
2645 _ => {}
2646 }
2647 }
2648 RusotoError::Unknown(res)
2649 }
2650}
2651impl fmt::Display for DescribeIdentityProviderConfigError {
2652 #[allow(unused_variables)]
2653 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2654 match *self {
2655 DescribeIdentityProviderConfigError::Client(ref cause) => write!(f, "{}", cause),
2656 DescribeIdentityProviderConfigError::InvalidParameter(ref cause) => {
2657 write!(f, "{}", cause)
2658 }
2659 DescribeIdentityProviderConfigError::ResourceNotFound(ref cause) => {
2660 write!(f, "{}", cause)
2661 }
2662 DescribeIdentityProviderConfigError::Server(ref cause) => write!(f, "{}", cause),
2663 DescribeIdentityProviderConfigError::ServiceUnavailable(ref cause) => {
2664 write!(f, "{}", cause)
2665 }
2666 }
2667 }
2668}
2669impl Error for DescribeIdentityProviderConfigError {}
2670#[derive(Debug, PartialEq)]
2672pub enum DescribeNodegroupError {
2673 Client(String),
2675 InvalidParameter(String),
2677 ResourceNotFound(String),
2679 Server(String),
2681 ServiceUnavailable(String),
2683}
2684
2685impl DescribeNodegroupError {
2686 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeNodegroupError> {
2687 if let Some(err) = proto::json::Error::parse_rest(&res) {
2688 match err.typ.as_str() {
2689 "ClientException" => {
2690 return RusotoError::Service(DescribeNodegroupError::Client(err.msg))
2691 }
2692 "InvalidParameterException" => {
2693 return RusotoError::Service(DescribeNodegroupError::InvalidParameter(err.msg))
2694 }
2695 "ResourceNotFoundException" => {
2696 return RusotoError::Service(DescribeNodegroupError::ResourceNotFound(err.msg))
2697 }
2698 "ServerException" => {
2699 return RusotoError::Service(DescribeNodegroupError::Server(err.msg))
2700 }
2701 "ServiceUnavailableException" => {
2702 return RusotoError::Service(DescribeNodegroupError::ServiceUnavailable(
2703 err.msg,
2704 ))
2705 }
2706 "ValidationException" => return RusotoError::Validation(err.msg),
2707 _ => {}
2708 }
2709 }
2710 RusotoError::Unknown(res)
2711 }
2712}
2713impl fmt::Display for DescribeNodegroupError {
2714 #[allow(unused_variables)]
2715 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2716 match *self {
2717 DescribeNodegroupError::Client(ref cause) => write!(f, "{}", cause),
2718 DescribeNodegroupError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2719 DescribeNodegroupError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2720 DescribeNodegroupError::Server(ref cause) => write!(f, "{}", cause),
2721 DescribeNodegroupError::ServiceUnavailable(ref cause) => write!(f, "{}", cause),
2722 }
2723 }
2724}
2725impl Error for DescribeNodegroupError {}
2726#[derive(Debug, PartialEq)]
2728pub enum DescribeUpdateError {
2729 Client(String),
2731 InvalidParameter(String),
2733 ResourceNotFound(String),
2735 Server(String),
2737}
2738
2739impl DescribeUpdateError {
2740 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<DescribeUpdateError> {
2741 if let Some(err) = proto::json::Error::parse_rest(&res) {
2742 match err.typ.as_str() {
2743 "ClientException" => {
2744 return RusotoError::Service(DescribeUpdateError::Client(err.msg))
2745 }
2746 "InvalidParameterException" => {
2747 return RusotoError::Service(DescribeUpdateError::InvalidParameter(err.msg))
2748 }
2749 "ResourceNotFoundException" => {
2750 return RusotoError::Service(DescribeUpdateError::ResourceNotFound(err.msg))
2751 }
2752 "ServerException" => {
2753 return RusotoError::Service(DescribeUpdateError::Server(err.msg))
2754 }
2755 "ValidationException" => return RusotoError::Validation(err.msg),
2756 _ => {}
2757 }
2758 }
2759 RusotoError::Unknown(res)
2760 }
2761}
2762impl fmt::Display for DescribeUpdateError {
2763 #[allow(unused_variables)]
2764 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2765 match *self {
2766 DescribeUpdateError::Client(ref cause) => write!(f, "{}", cause),
2767 DescribeUpdateError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2768 DescribeUpdateError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2769 DescribeUpdateError::Server(ref cause) => write!(f, "{}", cause),
2770 }
2771 }
2772}
2773impl Error for DescribeUpdateError {}
2774#[derive(Debug, PartialEq)]
2776pub enum DisassociateIdentityProviderConfigError {
2777 Client(String),
2779 InvalidParameter(String),
2781 InvalidRequest(String),
2783 ResourceInUse(String),
2785 ResourceNotFound(String),
2787 Server(String),
2789}
2790
2791impl DisassociateIdentityProviderConfigError {
2792 pub fn from_response(
2793 res: BufferedHttpResponse,
2794 ) -> RusotoError<DisassociateIdentityProviderConfigError> {
2795 if let Some(err) = proto::json::Error::parse_rest(&res) {
2796 match err.typ.as_str() {
2797 "ClientException" => {
2798 return RusotoError::Service(DisassociateIdentityProviderConfigError::Client(
2799 err.msg,
2800 ))
2801 }
2802 "InvalidParameterException" => {
2803 return RusotoError::Service(
2804 DisassociateIdentityProviderConfigError::InvalidParameter(err.msg),
2805 )
2806 }
2807 "InvalidRequestException" => {
2808 return RusotoError::Service(
2809 DisassociateIdentityProviderConfigError::InvalidRequest(err.msg),
2810 )
2811 }
2812 "ResourceInUseException" => {
2813 return RusotoError::Service(
2814 DisassociateIdentityProviderConfigError::ResourceInUse(err.msg),
2815 )
2816 }
2817 "ResourceNotFoundException" => {
2818 return RusotoError::Service(
2819 DisassociateIdentityProviderConfigError::ResourceNotFound(err.msg),
2820 )
2821 }
2822 "ServerException" => {
2823 return RusotoError::Service(DisassociateIdentityProviderConfigError::Server(
2824 err.msg,
2825 ))
2826 }
2827 "ValidationException" => return RusotoError::Validation(err.msg),
2828 _ => {}
2829 }
2830 }
2831 RusotoError::Unknown(res)
2832 }
2833}
2834impl fmt::Display for DisassociateIdentityProviderConfigError {
2835 #[allow(unused_variables)]
2836 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2837 match *self {
2838 DisassociateIdentityProviderConfigError::Client(ref cause) => write!(f, "{}", cause),
2839 DisassociateIdentityProviderConfigError::InvalidParameter(ref cause) => {
2840 write!(f, "{}", cause)
2841 }
2842 DisassociateIdentityProviderConfigError::InvalidRequest(ref cause) => {
2843 write!(f, "{}", cause)
2844 }
2845 DisassociateIdentityProviderConfigError::ResourceInUse(ref cause) => {
2846 write!(f, "{}", cause)
2847 }
2848 DisassociateIdentityProviderConfigError::ResourceNotFound(ref cause) => {
2849 write!(f, "{}", cause)
2850 }
2851 DisassociateIdentityProviderConfigError::Server(ref cause) => write!(f, "{}", cause),
2852 }
2853 }
2854}
2855impl Error for DisassociateIdentityProviderConfigError {}
2856#[derive(Debug, PartialEq)]
2858pub enum ListAddonsError {
2859 Client(String),
2861 InvalidParameter(String),
2863 InvalidRequest(String),
2865 ResourceNotFound(String),
2867 Server(String),
2869}
2870
2871impl ListAddonsError {
2872 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListAddonsError> {
2873 if let Some(err) = proto::json::Error::parse_rest(&res) {
2874 match err.typ.as_str() {
2875 "ClientException" => return RusotoError::Service(ListAddonsError::Client(err.msg)),
2876 "InvalidParameterException" => {
2877 return RusotoError::Service(ListAddonsError::InvalidParameter(err.msg))
2878 }
2879 "InvalidRequestException" => {
2880 return RusotoError::Service(ListAddonsError::InvalidRequest(err.msg))
2881 }
2882 "ResourceNotFoundException" => {
2883 return RusotoError::Service(ListAddonsError::ResourceNotFound(err.msg))
2884 }
2885 "ServerException" => return RusotoError::Service(ListAddonsError::Server(err.msg)),
2886 "ValidationException" => return RusotoError::Validation(err.msg),
2887 _ => {}
2888 }
2889 }
2890 RusotoError::Unknown(res)
2891 }
2892}
2893impl fmt::Display for ListAddonsError {
2894 #[allow(unused_variables)]
2895 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2896 match *self {
2897 ListAddonsError::Client(ref cause) => write!(f, "{}", cause),
2898 ListAddonsError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2899 ListAddonsError::InvalidRequest(ref cause) => write!(f, "{}", cause),
2900 ListAddonsError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
2901 ListAddonsError::Server(ref cause) => write!(f, "{}", cause),
2902 }
2903 }
2904}
2905impl Error for ListAddonsError {}
2906#[derive(Debug, PartialEq)]
2908pub enum ListClustersError {
2909 Client(String),
2911 InvalidParameter(String),
2913 Server(String),
2915 ServiceUnavailable(String),
2917}
2918
2919impl ListClustersError {
2920 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListClustersError> {
2921 if let Some(err) = proto::json::Error::parse_rest(&res) {
2922 match err.typ.as_str() {
2923 "ClientException" => {
2924 return RusotoError::Service(ListClustersError::Client(err.msg))
2925 }
2926 "InvalidParameterException" => {
2927 return RusotoError::Service(ListClustersError::InvalidParameter(err.msg))
2928 }
2929 "ServerException" => {
2930 return RusotoError::Service(ListClustersError::Server(err.msg))
2931 }
2932 "ServiceUnavailableException" => {
2933 return RusotoError::Service(ListClustersError::ServiceUnavailable(err.msg))
2934 }
2935 "ValidationException" => return RusotoError::Validation(err.msg),
2936 _ => {}
2937 }
2938 }
2939 RusotoError::Unknown(res)
2940 }
2941}
2942impl fmt::Display for ListClustersError {
2943 #[allow(unused_variables)]
2944 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2945 match *self {
2946 ListClustersError::Client(ref cause) => write!(f, "{}", cause),
2947 ListClustersError::InvalidParameter(ref cause) => write!(f, "{}", cause),
2948 ListClustersError::Server(ref cause) => write!(f, "{}", cause),
2949 ListClustersError::ServiceUnavailable(ref cause) => write!(f, "{}", cause),
2950 }
2951 }
2952}
2953impl Error for ListClustersError {}
2954#[derive(Debug, PartialEq)]
2956pub enum ListFargateProfilesError {
2957 Client(String),
2959 InvalidParameter(String),
2961 ResourceNotFound(String),
2963 Server(String),
2965}
2966
2967impl ListFargateProfilesError {
2968 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListFargateProfilesError> {
2969 if let Some(err) = proto::json::Error::parse_rest(&res) {
2970 match err.typ.as_str() {
2971 "ClientException" => {
2972 return RusotoError::Service(ListFargateProfilesError::Client(err.msg))
2973 }
2974 "InvalidParameterException" => {
2975 return RusotoError::Service(ListFargateProfilesError::InvalidParameter(
2976 err.msg,
2977 ))
2978 }
2979 "ResourceNotFoundException" => {
2980 return RusotoError::Service(ListFargateProfilesError::ResourceNotFound(
2981 err.msg,
2982 ))
2983 }
2984 "ServerException" => {
2985 return RusotoError::Service(ListFargateProfilesError::Server(err.msg))
2986 }
2987 "ValidationException" => return RusotoError::Validation(err.msg),
2988 _ => {}
2989 }
2990 }
2991 RusotoError::Unknown(res)
2992 }
2993}
2994impl fmt::Display for ListFargateProfilesError {
2995 #[allow(unused_variables)]
2996 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
2997 match *self {
2998 ListFargateProfilesError::Client(ref cause) => write!(f, "{}", cause),
2999 ListFargateProfilesError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3000 ListFargateProfilesError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3001 ListFargateProfilesError::Server(ref cause) => write!(f, "{}", cause),
3002 }
3003 }
3004}
3005impl Error for ListFargateProfilesError {}
3006#[derive(Debug, PartialEq)]
3008pub enum ListIdentityProviderConfigsError {
3009 Client(String),
3011 InvalidParameter(String),
3013 ResourceNotFound(String),
3015 Server(String),
3017 ServiceUnavailable(String),
3019}
3020
3021impl ListIdentityProviderConfigsError {
3022 pub fn from_response(
3023 res: BufferedHttpResponse,
3024 ) -> RusotoError<ListIdentityProviderConfigsError> {
3025 if let Some(err) = proto::json::Error::parse_rest(&res) {
3026 match err.typ.as_str() {
3027 "ClientException" => {
3028 return RusotoError::Service(ListIdentityProviderConfigsError::Client(err.msg))
3029 }
3030 "InvalidParameterException" => {
3031 return RusotoError::Service(
3032 ListIdentityProviderConfigsError::InvalidParameter(err.msg),
3033 )
3034 }
3035 "ResourceNotFoundException" => {
3036 return RusotoError::Service(
3037 ListIdentityProviderConfigsError::ResourceNotFound(err.msg),
3038 )
3039 }
3040 "ServerException" => {
3041 return RusotoError::Service(ListIdentityProviderConfigsError::Server(err.msg))
3042 }
3043 "ServiceUnavailableException" => {
3044 return RusotoError::Service(
3045 ListIdentityProviderConfigsError::ServiceUnavailable(err.msg),
3046 )
3047 }
3048 "ValidationException" => return RusotoError::Validation(err.msg),
3049 _ => {}
3050 }
3051 }
3052 RusotoError::Unknown(res)
3053 }
3054}
3055impl fmt::Display for ListIdentityProviderConfigsError {
3056 #[allow(unused_variables)]
3057 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3058 match *self {
3059 ListIdentityProviderConfigsError::Client(ref cause) => write!(f, "{}", cause),
3060 ListIdentityProviderConfigsError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3061 ListIdentityProviderConfigsError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3062 ListIdentityProviderConfigsError::Server(ref cause) => write!(f, "{}", cause),
3063 ListIdentityProviderConfigsError::ServiceUnavailable(ref cause) => {
3064 write!(f, "{}", cause)
3065 }
3066 }
3067 }
3068}
3069impl Error for ListIdentityProviderConfigsError {}
3070#[derive(Debug, PartialEq)]
3072pub enum ListNodegroupsError {
3073 Client(String),
3075 InvalidParameter(String),
3077 ResourceNotFound(String),
3079 Server(String),
3081 ServiceUnavailable(String),
3083}
3084
3085impl ListNodegroupsError {
3086 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListNodegroupsError> {
3087 if let Some(err) = proto::json::Error::parse_rest(&res) {
3088 match err.typ.as_str() {
3089 "ClientException" => {
3090 return RusotoError::Service(ListNodegroupsError::Client(err.msg))
3091 }
3092 "InvalidParameterException" => {
3093 return RusotoError::Service(ListNodegroupsError::InvalidParameter(err.msg))
3094 }
3095 "ResourceNotFoundException" => {
3096 return RusotoError::Service(ListNodegroupsError::ResourceNotFound(err.msg))
3097 }
3098 "ServerException" => {
3099 return RusotoError::Service(ListNodegroupsError::Server(err.msg))
3100 }
3101 "ServiceUnavailableException" => {
3102 return RusotoError::Service(ListNodegroupsError::ServiceUnavailable(err.msg))
3103 }
3104 "ValidationException" => return RusotoError::Validation(err.msg),
3105 _ => {}
3106 }
3107 }
3108 RusotoError::Unknown(res)
3109 }
3110}
3111impl fmt::Display for ListNodegroupsError {
3112 #[allow(unused_variables)]
3113 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3114 match *self {
3115 ListNodegroupsError::Client(ref cause) => write!(f, "{}", cause),
3116 ListNodegroupsError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3117 ListNodegroupsError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3118 ListNodegroupsError::Server(ref cause) => write!(f, "{}", cause),
3119 ListNodegroupsError::ServiceUnavailable(ref cause) => write!(f, "{}", cause),
3120 }
3121 }
3122}
3123impl Error for ListNodegroupsError {}
3124#[derive(Debug, PartialEq)]
3126pub enum ListTagsForResourceError {
3127 BadRequest(String),
3129 NotFound(String),
3131}
3132
3133impl ListTagsForResourceError {
3134 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListTagsForResourceError> {
3135 if let Some(err) = proto::json::Error::parse_rest(&res) {
3136 match err.typ.as_str() {
3137 "BadRequestException" => {
3138 return RusotoError::Service(ListTagsForResourceError::BadRequest(err.msg))
3139 }
3140 "NotFoundException" => {
3141 return RusotoError::Service(ListTagsForResourceError::NotFound(err.msg))
3142 }
3143 "ValidationException" => return RusotoError::Validation(err.msg),
3144 _ => {}
3145 }
3146 }
3147 RusotoError::Unknown(res)
3148 }
3149}
3150impl fmt::Display for ListTagsForResourceError {
3151 #[allow(unused_variables)]
3152 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3153 match *self {
3154 ListTagsForResourceError::BadRequest(ref cause) => write!(f, "{}", cause),
3155 ListTagsForResourceError::NotFound(ref cause) => write!(f, "{}", cause),
3156 }
3157 }
3158}
3159impl Error for ListTagsForResourceError {}
3160#[derive(Debug, PartialEq)]
3162pub enum ListUpdatesError {
3163 Client(String),
3165 InvalidParameter(String),
3167 ResourceNotFound(String),
3169 Server(String),
3171}
3172
3173impl ListUpdatesError {
3174 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<ListUpdatesError> {
3175 if let Some(err) = proto::json::Error::parse_rest(&res) {
3176 match err.typ.as_str() {
3177 "ClientException" => {
3178 return RusotoError::Service(ListUpdatesError::Client(err.msg))
3179 }
3180 "InvalidParameterException" => {
3181 return RusotoError::Service(ListUpdatesError::InvalidParameter(err.msg))
3182 }
3183 "ResourceNotFoundException" => {
3184 return RusotoError::Service(ListUpdatesError::ResourceNotFound(err.msg))
3185 }
3186 "ServerException" => {
3187 return RusotoError::Service(ListUpdatesError::Server(err.msg))
3188 }
3189 "ValidationException" => return RusotoError::Validation(err.msg),
3190 _ => {}
3191 }
3192 }
3193 RusotoError::Unknown(res)
3194 }
3195}
3196impl fmt::Display for ListUpdatesError {
3197 #[allow(unused_variables)]
3198 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3199 match *self {
3200 ListUpdatesError::Client(ref cause) => write!(f, "{}", cause),
3201 ListUpdatesError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3202 ListUpdatesError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3203 ListUpdatesError::Server(ref cause) => write!(f, "{}", cause),
3204 }
3205 }
3206}
3207impl Error for ListUpdatesError {}
3208#[derive(Debug, PartialEq)]
3210pub enum TagResourceError {
3211 BadRequest(String),
3213 NotFound(String),
3215}
3216
3217impl TagResourceError {
3218 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<TagResourceError> {
3219 if let Some(err) = proto::json::Error::parse_rest(&res) {
3220 match err.typ.as_str() {
3221 "BadRequestException" => {
3222 return RusotoError::Service(TagResourceError::BadRequest(err.msg))
3223 }
3224 "NotFoundException" => {
3225 return RusotoError::Service(TagResourceError::NotFound(err.msg))
3226 }
3227 "ValidationException" => return RusotoError::Validation(err.msg),
3228 _ => {}
3229 }
3230 }
3231 RusotoError::Unknown(res)
3232 }
3233}
3234impl fmt::Display for TagResourceError {
3235 #[allow(unused_variables)]
3236 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3237 match *self {
3238 TagResourceError::BadRequest(ref cause) => write!(f, "{}", cause),
3239 TagResourceError::NotFound(ref cause) => write!(f, "{}", cause),
3240 }
3241 }
3242}
3243impl Error for TagResourceError {}
3244#[derive(Debug, PartialEq)]
3246pub enum UntagResourceError {
3247 BadRequest(String),
3249 NotFound(String),
3251}
3252
3253impl UntagResourceError {
3254 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UntagResourceError> {
3255 if let Some(err) = proto::json::Error::parse_rest(&res) {
3256 match err.typ.as_str() {
3257 "BadRequestException" => {
3258 return RusotoError::Service(UntagResourceError::BadRequest(err.msg))
3259 }
3260 "NotFoundException" => {
3261 return RusotoError::Service(UntagResourceError::NotFound(err.msg))
3262 }
3263 "ValidationException" => return RusotoError::Validation(err.msg),
3264 _ => {}
3265 }
3266 }
3267 RusotoError::Unknown(res)
3268 }
3269}
3270impl fmt::Display for UntagResourceError {
3271 #[allow(unused_variables)]
3272 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3273 match *self {
3274 UntagResourceError::BadRequest(ref cause) => write!(f, "{}", cause),
3275 UntagResourceError::NotFound(ref cause) => write!(f, "{}", cause),
3276 }
3277 }
3278}
3279impl Error for UntagResourceError {}
3280#[derive(Debug, PartialEq)]
3282pub enum UpdateAddonError {
3283 Client(String),
3285 InvalidParameter(String),
3287 InvalidRequest(String),
3289 ResourceInUse(String),
3291 ResourceNotFound(String),
3293 Server(String),
3295}
3296
3297impl UpdateAddonError {
3298 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UpdateAddonError> {
3299 if let Some(err) = proto::json::Error::parse_rest(&res) {
3300 match err.typ.as_str() {
3301 "ClientException" => {
3302 return RusotoError::Service(UpdateAddonError::Client(err.msg))
3303 }
3304 "InvalidParameterException" => {
3305 return RusotoError::Service(UpdateAddonError::InvalidParameter(err.msg))
3306 }
3307 "InvalidRequestException" => {
3308 return RusotoError::Service(UpdateAddonError::InvalidRequest(err.msg))
3309 }
3310 "ResourceInUseException" => {
3311 return RusotoError::Service(UpdateAddonError::ResourceInUse(err.msg))
3312 }
3313 "ResourceNotFoundException" => {
3314 return RusotoError::Service(UpdateAddonError::ResourceNotFound(err.msg))
3315 }
3316 "ServerException" => {
3317 return RusotoError::Service(UpdateAddonError::Server(err.msg))
3318 }
3319 "ValidationException" => return RusotoError::Validation(err.msg),
3320 _ => {}
3321 }
3322 }
3323 RusotoError::Unknown(res)
3324 }
3325}
3326impl fmt::Display for UpdateAddonError {
3327 #[allow(unused_variables)]
3328 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3329 match *self {
3330 UpdateAddonError::Client(ref cause) => write!(f, "{}", cause),
3331 UpdateAddonError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3332 UpdateAddonError::InvalidRequest(ref cause) => write!(f, "{}", cause),
3333 UpdateAddonError::ResourceInUse(ref cause) => write!(f, "{}", cause),
3334 UpdateAddonError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3335 UpdateAddonError::Server(ref cause) => write!(f, "{}", cause),
3336 }
3337 }
3338}
3339impl Error for UpdateAddonError {}
3340#[derive(Debug, PartialEq)]
3342pub enum UpdateClusterConfigError {
3343 Client(String),
3345 InvalidParameter(String),
3347 InvalidRequest(String),
3349 ResourceInUse(String),
3351 ResourceNotFound(String),
3353 Server(String),
3355}
3356
3357impl UpdateClusterConfigError {
3358 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UpdateClusterConfigError> {
3359 if let Some(err) = proto::json::Error::parse_rest(&res) {
3360 match err.typ.as_str() {
3361 "ClientException" => {
3362 return RusotoError::Service(UpdateClusterConfigError::Client(err.msg))
3363 }
3364 "InvalidParameterException" => {
3365 return RusotoError::Service(UpdateClusterConfigError::InvalidParameter(
3366 err.msg,
3367 ))
3368 }
3369 "InvalidRequestException" => {
3370 return RusotoError::Service(UpdateClusterConfigError::InvalidRequest(err.msg))
3371 }
3372 "ResourceInUseException" => {
3373 return RusotoError::Service(UpdateClusterConfigError::ResourceInUse(err.msg))
3374 }
3375 "ResourceNotFoundException" => {
3376 return RusotoError::Service(UpdateClusterConfigError::ResourceNotFound(
3377 err.msg,
3378 ))
3379 }
3380 "ServerException" => {
3381 return RusotoError::Service(UpdateClusterConfigError::Server(err.msg))
3382 }
3383 "ValidationException" => return RusotoError::Validation(err.msg),
3384 _ => {}
3385 }
3386 }
3387 RusotoError::Unknown(res)
3388 }
3389}
3390impl fmt::Display for UpdateClusterConfigError {
3391 #[allow(unused_variables)]
3392 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3393 match *self {
3394 UpdateClusterConfigError::Client(ref cause) => write!(f, "{}", cause),
3395 UpdateClusterConfigError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3396 UpdateClusterConfigError::InvalidRequest(ref cause) => write!(f, "{}", cause),
3397 UpdateClusterConfigError::ResourceInUse(ref cause) => write!(f, "{}", cause),
3398 UpdateClusterConfigError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3399 UpdateClusterConfigError::Server(ref cause) => write!(f, "{}", cause),
3400 }
3401 }
3402}
3403impl Error for UpdateClusterConfigError {}
3404#[derive(Debug, PartialEq)]
3406pub enum UpdateClusterVersionError {
3407 Client(String),
3409 InvalidParameter(String),
3411 InvalidRequest(String),
3413 ResourceInUse(String),
3415 ResourceNotFound(String),
3417 Server(String),
3419}
3420
3421impl UpdateClusterVersionError {
3422 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UpdateClusterVersionError> {
3423 if let Some(err) = proto::json::Error::parse_rest(&res) {
3424 match err.typ.as_str() {
3425 "ClientException" => {
3426 return RusotoError::Service(UpdateClusterVersionError::Client(err.msg))
3427 }
3428 "InvalidParameterException" => {
3429 return RusotoError::Service(UpdateClusterVersionError::InvalidParameter(
3430 err.msg,
3431 ))
3432 }
3433 "InvalidRequestException" => {
3434 return RusotoError::Service(UpdateClusterVersionError::InvalidRequest(err.msg))
3435 }
3436 "ResourceInUseException" => {
3437 return RusotoError::Service(UpdateClusterVersionError::ResourceInUse(err.msg))
3438 }
3439 "ResourceNotFoundException" => {
3440 return RusotoError::Service(UpdateClusterVersionError::ResourceNotFound(
3441 err.msg,
3442 ))
3443 }
3444 "ServerException" => {
3445 return RusotoError::Service(UpdateClusterVersionError::Server(err.msg))
3446 }
3447 "ValidationException" => return RusotoError::Validation(err.msg),
3448 _ => {}
3449 }
3450 }
3451 RusotoError::Unknown(res)
3452 }
3453}
3454impl fmt::Display for UpdateClusterVersionError {
3455 #[allow(unused_variables)]
3456 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3457 match *self {
3458 UpdateClusterVersionError::Client(ref cause) => write!(f, "{}", cause),
3459 UpdateClusterVersionError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3460 UpdateClusterVersionError::InvalidRequest(ref cause) => write!(f, "{}", cause),
3461 UpdateClusterVersionError::ResourceInUse(ref cause) => write!(f, "{}", cause),
3462 UpdateClusterVersionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3463 UpdateClusterVersionError::Server(ref cause) => write!(f, "{}", cause),
3464 }
3465 }
3466}
3467impl Error for UpdateClusterVersionError {}
3468#[derive(Debug, PartialEq)]
3470pub enum UpdateNodegroupConfigError {
3471 Client(String),
3473 InvalidParameter(String),
3475 InvalidRequest(String),
3477 ResourceInUse(String),
3479 ResourceNotFound(String),
3481 Server(String),
3483}
3484
3485impl UpdateNodegroupConfigError {
3486 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UpdateNodegroupConfigError> {
3487 if let Some(err) = proto::json::Error::parse_rest(&res) {
3488 match err.typ.as_str() {
3489 "ClientException" => {
3490 return RusotoError::Service(UpdateNodegroupConfigError::Client(err.msg))
3491 }
3492 "InvalidParameterException" => {
3493 return RusotoError::Service(UpdateNodegroupConfigError::InvalidParameter(
3494 err.msg,
3495 ))
3496 }
3497 "InvalidRequestException" => {
3498 return RusotoError::Service(UpdateNodegroupConfigError::InvalidRequest(
3499 err.msg,
3500 ))
3501 }
3502 "ResourceInUseException" => {
3503 return RusotoError::Service(UpdateNodegroupConfigError::ResourceInUse(err.msg))
3504 }
3505 "ResourceNotFoundException" => {
3506 return RusotoError::Service(UpdateNodegroupConfigError::ResourceNotFound(
3507 err.msg,
3508 ))
3509 }
3510 "ServerException" => {
3511 return RusotoError::Service(UpdateNodegroupConfigError::Server(err.msg))
3512 }
3513 "ValidationException" => return RusotoError::Validation(err.msg),
3514 _ => {}
3515 }
3516 }
3517 RusotoError::Unknown(res)
3518 }
3519}
3520impl fmt::Display for UpdateNodegroupConfigError {
3521 #[allow(unused_variables)]
3522 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3523 match *self {
3524 UpdateNodegroupConfigError::Client(ref cause) => write!(f, "{}", cause),
3525 UpdateNodegroupConfigError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3526 UpdateNodegroupConfigError::InvalidRequest(ref cause) => write!(f, "{}", cause),
3527 UpdateNodegroupConfigError::ResourceInUse(ref cause) => write!(f, "{}", cause),
3528 UpdateNodegroupConfigError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3529 UpdateNodegroupConfigError::Server(ref cause) => write!(f, "{}", cause),
3530 }
3531 }
3532}
3533impl Error for UpdateNodegroupConfigError {}
3534#[derive(Debug, PartialEq)]
3536pub enum UpdateNodegroupVersionError {
3537 Client(String),
3539 InvalidParameter(String),
3541 InvalidRequest(String),
3543 ResourceInUse(String),
3545 ResourceNotFound(String),
3547 Server(String),
3549}
3550
3551impl UpdateNodegroupVersionError {
3552 pub fn from_response(res: BufferedHttpResponse) -> RusotoError<UpdateNodegroupVersionError> {
3553 if let Some(err) = proto::json::Error::parse_rest(&res) {
3554 match err.typ.as_str() {
3555 "ClientException" => {
3556 return RusotoError::Service(UpdateNodegroupVersionError::Client(err.msg))
3557 }
3558 "InvalidParameterException" => {
3559 return RusotoError::Service(UpdateNodegroupVersionError::InvalidParameter(
3560 err.msg,
3561 ))
3562 }
3563 "InvalidRequestException" => {
3564 return RusotoError::Service(UpdateNodegroupVersionError::InvalidRequest(
3565 err.msg,
3566 ))
3567 }
3568 "ResourceInUseException" => {
3569 return RusotoError::Service(UpdateNodegroupVersionError::ResourceInUse(
3570 err.msg,
3571 ))
3572 }
3573 "ResourceNotFoundException" => {
3574 return RusotoError::Service(UpdateNodegroupVersionError::ResourceNotFound(
3575 err.msg,
3576 ))
3577 }
3578 "ServerException" => {
3579 return RusotoError::Service(UpdateNodegroupVersionError::Server(err.msg))
3580 }
3581 "ValidationException" => return RusotoError::Validation(err.msg),
3582 _ => {}
3583 }
3584 }
3585 RusotoError::Unknown(res)
3586 }
3587}
3588impl fmt::Display for UpdateNodegroupVersionError {
3589 #[allow(unused_variables)]
3590 fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
3591 match *self {
3592 UpdateNodegroupVersionError::Client(ref cause) => write!(f, "{}", cause),
3593 UpdateNodegroupVersionError::InvalidParameter(ref cause) => write!(f, "{}", cause),
3594 UpdateNodegroupVersionError::InvalidRequest(ref cause) => write!(f, "{}", cause),
3595 UpdateNodegroupVersionError::ResourceInUse(ref cause) => write!(f, "{}", cause),
3596 UpdateNodegroupVersionError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
3597 UpdateNodegroupVersionError::Server(ref cause) => write!(f, "{}", cause),
3598 }
3599 }
3600}
3601impl Error for UpdateNodegroupVersionError {}
3602#[async_trait]
3604pub trait Eks {
3605 async fn associate_encryption_config(
3607 &self,
3608 input: AssociateEncryptionConfigRequest,
3609 ) -> Result<AssociateEncryptionConfigResponse, RusotoError<AssociateEncryptionConfigError>>;
3610
3611 async fn associate_identity_provider_config(
3613 &self,
3614 input: AssociateIdentityProviderConfigRequest,
3615 ) -> Result<
3616 AssociateIdentityProviderConfigResponse,
3617 RusotoError<AssociateIdentityProviderConfigError>,
3618 >;
3619
3620 async fn create_addon(
3622 &self,
3623 input: CreateAddonRequest,
3624 ) -> Result<CreateAddonResponse, RusotoError<CreateAddonError>>;
3625
3626 async fn create_cluster(
3628 &self,
3629 input: CreateClusterRequest,
3630 ) -> Result<CreateClusterResponse, RusotoError<CreateClusterError>>;
3631
3632 async fn create_fargate_profile(
3634 &self,
3635 input: CreateFargateProfileRequest,
3636 ) -> Result<CreateFargateProfileResponse, RusotoError<CreateFargateProfileError>>;
3637
3638 async fn create_nodegroup(
3640 &self,
3641 input: CreateNodegroupRequest,
3642 ) -> Result<CreateNodegroupResponse, RusotoError<CreateNodegroupError>>;
3643
3644 async fn delete_addon(
3646 &self,
3647 input: DeleteAddonRequest,
3648 ) -> Result<DeleteAddonResponse, RusotoError<DeleteAddonError>>;
3649
3650 async fn delete_cluster(
3652 &self,
3653 input: DeleteClusterRequest,
3654 ) -> Result<DeleteClusterResponse, RusotoError<DeleteClusterError>>;
3655
3656 async fn delete_fargate_profile(
3658 &self,
3659 input: DeleteFargateProfileRequest,
3660 ) -> Result<DeleteFargateProfileResponse, RusotoError<DeleteFargateProfileError>>;
3661
3662 async fn delete_nodegroup(
3664 &self,
3665 input: DeleteNodegroupRequest,
3666 ) -> Result<DeleteNodegroupResponse, RusotoError<DeleteNodegroupError>>;
3667
3668 async fn describe_addon(
3670 &self,
3671 input: DescribeAddonRequest,
3672 ) -> Result<DescribeAddonResponse, RusotoError<DescribeAddonError>>;
3673
3674 async fn describe_addon_versions(
3676 &self,
3677 input: DescribeAddonVersionsRequest,
3678 ) -> Result<DescribeAddonVersionsResponse, RusotoError<DescribeAddonVersionsError>>;
3679
3680 async fn describe_cluster(
3682 &self,
3683 input: DescribeClusterRequest,
3684 ) -> Result<DescribeClusterResponse, RusotoError<DescribeClusterError>>;
3685
3686 async fn describe_fargate_profile(
3688 &self,
3689 input: DescribeFargateProfileRequest,
3690 ) -> Result<DescribeFargateProfileResponse, RusotoError<DescribeFargateProfileError>>;
3691
3692 async fn describe_identity_provider_config(
3694 &self,
3695 input: DescribeIdentityProviderConfigRequest,
3696 ) -> Result<
3697 DescribeIdentityProviderConfigResponse,
3698 RusotoError<DescribeIdentityProviderConfigError>,
3699 >;
3700
3701 async fn describe_nodegroup(
3703 &self,
3704 input: DescribeNodegroupRequest,
3705 ) -> Result<DescribeNodegroupResponse, RusotoError<DescribeNodegroupError>>;
3706
3707 async fn describe_update(
3709 &self,
3710 input: DescribeUpdateRequest,
3711 ) -> Result<DescribeUpdateResponse, RusotoError<DescribeUpdateError>>;
3712
3713 async fn disassociate_identity_provider_config(
3715 &self,
3716 input: DisassociateIdentityProviderConfigRequest,
3717 ) -> Result<
3718 DisassociateIdentityProviderConfigResponse,
3719 RusotoError<DisassociateIdentityProviderConfigError>,
3720 >;
3721
3722 async fn list_addons(
3724 &self,
3725 input: ListAddonsRequest,
3726 ) -> Result<ListAddonsResponse, RusotoError<ListAddonsError>>;
3727
3728 async fn list_clusters(
3730 &self,
3731 input: ListClustersRequest,
3732 ) -> Result<ListClustersResponse, RusotoError<ListClustersError>>;
3733
3734 async fn list_fargate_profiles(
3736 &self,
3737 input: ListFargateProfilesRequest,
3738 ) -> Result<ListFargateProfilesResponse, RusotoError<ListFargateProfilesError>>;
3739
3740 async fn list_identity_provider_configs(
3742 &self,
3743 input: ListIdentityProviderConfigsRequest,
3744 ) -> Result<ListIdentityProviderConfigsResponse, RusotoError<ListIdentityProviderConfigsError>>;
3745
3746 async fn list_nodegroups(
3748 &self,
3749 input: ListNodegroupsRequest,
3750 ) -> Result<ListNodegroupsResponse, RusotoError<ListNodegroupsError>>;
3751
3752 async fn list_tags_for_resource(
3754 &self,
3755 input: ListTagsForResourceRequest,
3756 ) -> Result<ListTagsForResourceResponse, RusotoError<ListTagsForResourceError>>;
3757
3758 async fn list_updates(
3760 &self,
3761 input: ListUpdatesRequest,
3762 ) -> Result<ListUpdatesResponse, RusotoError<ListUpdatesError>>;
3763
3764 async fn tag_resource(
3766 &self,
3767 input: TagResourceRequest,
3768 ) -> Result<TagResourceResponse, RusotoError<TagResourceError>>;
3769
3770 async fn untag_resource(
3772 &self,
3773 input: UntagResourceRequest,
3774 ) -> Result<UntagResourceResponse, RusotoError<UntagResourceError>>;
3775
3776 async fn update_addon(
3778 &self,
3779 input: UpdateAddonRequest,
3780 ) -> Result<UpdateAddonResponse, RusotoError<UpdateAddonError>>;
3781
3782 async fn update_cluster_config(
3784 &self,
3785 input: UpdateClusterConfigRequest,
3786 ) -> Result<UpdateClusterConfigResponse, RusotoError<UpdateClusterConfigError>>;
3787
3788 async fn update_cluster_version(
3790 &self,
3791 input: UpdateClusterVersionRequest,
3792 ) -> Result<UpdateClusterVersionResponse, RusotoError<UpdateClusterVersionError>>;
3793
3794 async fn update_nodegroup_config(
3796 &self,
3797 input: UpdateNodegroupConfigRequest,
3798 ) -> Result<UpdateNodegroupConfigResponse, RusotoError<UpdateNodegroupConfigError>>;
3799
3800 async fn update_nodegroup_version(
3802 &self,
3803 input: UpdateNodegroupVersionRequest,
3804 ) -> Result<UpdateNodegroupVersionResponse, RusotoError<UpdateNodegroupVersionError>>;
3805}
3806#[derive(Clone)]
3808pub struct EksClient {
3809 client: Client,
3810 region: region::Region,
3811}
3812
3813impl EksClient {
3814 pub fn new(region: region::Region) -> EksClient {
3818 EksClient {
3819 client: Client::shared(),
3820 region,
3821 }
3822 }
3823
3824 pub fn new_with<P, D>(
3825 request_dispatcher: D,
3826 credentials_provider: P,
3827 region: region::Region,
3828 ) -> EksClient
3829 where
3830 P: ProvideAwsCredentials + Send + Sync + 'static,
3831 D: DispatchSignedRequest + Send + Sync + 'static,
3832 {
3833 EksClient {
3834 client: Client::new_with(credentials_provider, request_dispatcher),
3835 region,
3836 }
3837 }
3838
3839 pub fn new_with_client(client: Client, region: region::Region) -> EksClient {
3840 EksClient { client, region }
3841 }
3842}
3843
3844#[async_trait]
3845impl Eks for EksClient {
3846 #[allow(unused_mut)]
3848 async fn associate_encryption_config(
3849 &self,
3850 input: AssociateEncryptionConfigRequest,
3851 ) -> Result<AssociateEncryptionConfigResponse, RusotoError<AssociateEncryptionConfigError>>
3852 {
3853 let request_uri = format!(
3854 "/clusters/{name}/encryption-config/associate",
3855 name = input.cluster_name
3856 );
3857
3858 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
3859 request.set_content_type("application/x-amz-json-1.1".to_owned());
3860
3861 let encoded = Some(serde_json::to_vec(&input).unwrap());
3862 request.set_payload(encoded);
3863
3864 let mut response = self
3865 .client
3866 .sign_and_dispatch(request)
3867 .await
3868 .map_err(RusotoError::from)?;
3869 if response.status.is_success() {
3870 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
3871 let result = proto::json::ResponsePayload::new(&response)
3872 .deserialize::<AssociateEncryptionConfigResponse, _>()?;
3873
3874 Ok(result)
3875 } else {
3876 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
3877 Err(AssociateEncryptionConfigError::from_response(response))
3878 }
3879 }
3880
3881 #[allow(unused_mut)]
3883 async fn associate_identity_provider_config(
3884 &self,
3885 input: AssociateIdentityProviderConfigRequest,
3886 ) -> Result<
3887 AssociateIdentityProviderConfigResponse,
3888 RusotoError<AssociateIdentityProviderConfigError>,
3889 > {
3890 let request_uri = format!(
3891 "/clusters/{name}/identity-provider-configs/associate",
3892 name = input.cluster_name
3893 );
3894
3895 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
3896 request.set_content_type("application/x-amz-json-1.1".to_owned());
3897
3898 let encoded = Some(serde_json::to_vec(&input).unwrap());
3899 request.set_payload(encoded);
3900
3901 let mut response = self
3902 .client
3903 .sign_and_dispatch(request)
3904 .await
3905 .map_err(RusotoError::from)?;
3906 if response.status.is_success() {
3907 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
3908 let result = proto::json::ResponsePayload::new(&response)
3909 .deserialize::<AssociateIdentityProviderConfigResponse, _>()?;
3910
3911 Ok(result)
3912 } else {
3913 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
3914 Err(AssociateIdentityProviderConfigError::from_response(
3915 response,
3916 ))
3917 }
3918 }
3919
3920 #[allow(unused_mut)]
3922 async fn create_addon(
3923 &self,
3924 input: CreateAddonRequest,
3925 ) -> Result<CreateAddonResponse, RusotoError<CreateAddonError>> {
3926 let request_uri = format!("/clusters/{name}/addons", name = input.cluster_name);
3927
3928 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
3929 request.set_content_type("application/x-amz-json-1.1".to_owned());
3930
3931 let encoded = Some(serde_json::to_vec(&input).unwrap());
3932 request.set_payload(encoded);
3933
3934 let mut response = self
3935 .client
3936 .sign_and_dispatch(request)
3937 .await
3938 .map_err(RusotoError::from)?;
3939 if response.status.is_success() {
3940 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
3941 let result = proto::json::ResponsePayload::new(&response)
3942 .deserialize::<CreateAddonResponse, _>()?;
3943
3944 Ok(result)
3945 } else {
3946 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
3947 Err(CreateAddonError::from_response(response))
3948 }
3949 }
3950
3951 #[allow(unused_mut)]
3953 async fn create_cluster(
3954 &self,
3955 input: CreateClusterRequest,
3956 ) -> Result<CreateClusterResponse, RusotoError<CreateClusterError>> {
3957 let request_uri = "/clusters";
3958
3959 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
3960 request.set_content_type("application/x-amz-json-1.1".to_owned());
3961
3962 let encoded = Some(serde_json::to_vec(&input).unwrap());
3963 request.set_payload(encoded);
3964
3965 let mut response = self
3966 .client
3967 .sign_and_dispatch(request)
3968 .await
3969 .map_err(RusotoError::from)?;
3970 if response.status.is_success() {
3971 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
3972 let result = proto::json::ResponsePayload::new(&response)
3973 .deserialize::<CreateClusterResponse, _>()?;
3974
3975 Ok(result)
3976 } else {
3977 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
3978 Err(CreateClusterError::from_response(response))
3979 }
3980 }
3981
3982 #[allow(unused_mut)]
3984 async fn create_fargate_profile(
3985 &self,
3986 input: CreateFargateProfileRequest,
3987 ) -> Result<CreateFargateProfileResponse, RusotoError<CreateFargateProfileError>> {
3988 let request_uri = format!(
3989 "/clusters/{name}/fargate-profiles",
3990 name = input.cluster_name
3991 );
3992
3993 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
3994 request.set_content_type("application/x-amz-json-1.1".to_owned());
3995
3996 let encoded = Some(serde_json::to_vec(&input).unwrap());
3997 request.set_payload(encoded);
3998
3999 let mut response = self
4000 .client
4001 .sign_and_dispatch(request)
4002 .await
4003 .map_err(RusotoError::from)?;
4004 if response.status.is_success() {
4005 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4006 let result = proto::json::ResponsePayload::new(&response)
4007 .deserialize::<CreateFargateProfileResponse, _>()?;
4008
4009 Ok(result)
4010 } else {
4011 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4012 Err(CreateFargateProfileError::from_response(response))
4013 }
4014 }
4015
4016 #[allow(unused_mut)]
4018 async fn create_nodegroup(
4019 &self,
4020 input: CreateNodegroupRequest,
4021 ) -> Result<CreateNodegroupResponse, RusotoError<CreateNodegroupError>> {
4022 let request_uri = format!("/clusters/{name}/node-groups", name = input.cluster_name);
4023
4024 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4025 request.set_content_type("application/x-amz-json-1.1".to_owned());
4026
4027 let encoded = Some(serde_json::to_vec(&input).unwrap());
4028 request.set_payload(encoded);
4029
4030 let mut response = self
4031 .client
4032 .sign_and_dispatch(request)
4033 .await
4034 .map_err(RusotoError::from)?;
4035 if response.status.is_success() {
4036 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4037 let result = proto::json::ResponsePayload::new(&response)
4038 .deserialize::<CreateNodegroupResponse, _>()?;
4039
4040 Ok(result)
4041 } else {
4042 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4043 Err(CreateNodegroupError::from_response(response))
4044 }
4045 }
4046
4047 #[allow(unused_mut)]
4049 async fn delete_addon(
4050 &self,
4051 input: DeleteAddonRequest,
4052 ) -> Result<DeleteAddonResponse, RusotoError<DeleteAddonError>> {
4053 let request_uri = format!(
4054 "/clusters/{name}/addons/{addon_name}",
4055 addon_name = input.addon_name,
4056 name = input.cluster_name
4057 );
4058
4059 let mut request = SignedRequest::new("DELETE", "eks", &self.region, &request_uri);
4060 request.set_content_type("application/x-amz-json-1.1".to_owned());
4061
4062 let mut response = self
4063 .client
4064 .sign_and_dispatch(request)
4065 .await
4066 .map_err(RusotoError::from)?;
4067 if response.status.is_success() {
4068 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4069 let result = proto::json::ResponsePayload::new(&response)
4070 .deserialize::<DeleteAddonResponse, _>()?;
4071
4072 Ok(result)
4073 } else {
4074 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4075 Err(DeleteAddonError::from_response(response))
4076 }
4077 }
4078
4079 #[allow(unused_mut)]
4081 async fn delete_cluster(
4082 &self,
4083 input: DeleteClusterRequest,
4084 ) -> Result<DeleteClusterResponse, RusotoError<DeleteClusterError>> {
4085 let request_uri = format!("/clusters/{name}", name = input.name);
4086
4087 let mut request = SignedRequest::new("DELETE", "eks", &self.region, &request_uri);
4088 request.set_content_type("application/x-amz-json-1.1".to_owned());
4089
4090 let mut response = self
4091 .client
4092 .sign_and_dispatch(request)
4093 .await
4094 .map_err(RusotoError::from)?;
4095 if response.status.is_success() {
4096 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4097 let result = proto::json::ResponsePayload::new(&response)
4098 .deserialize::<DeleteClusterResponse, _>()?;
4099
4100 Ok(result)
4101 } else {
4102 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4103 Err(DeleteClusterError::from_response(response))
4104 }
4105 }
4106
4107 #[allow(unused_mut)]
4109 async fn delete_fargate_profile(
4110 &self,
4111 input: DeleteFargateProfileRequest,
4112 ) -> Result<DeleteFargateProfileResponse, RusotoError<DeleteFargateProfileError>> {
4113 let request_uri = format!(
4114 "/clusters/{name}/fargate-profiles/{fargate_profile_name}",
4115 name = input.cluster_name,
4116 fargate_profile_name = input.fargate_profile_name
4117 );
4118
4119 let mut request = SignedRequest::new("DELETE", "eks", &self.region, &request_uri);
4120 request.set_content_type("application/x-amz-json-1.1".to_owned());
4121
4122 let mut response = self
4123 .client
4124 .sign_and_dispatch(request)
4125 .await
4126 .map_err(RusotoError::from)?;
4127 if response.status.is_success() {
4128 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4129 let result = proto::json::ResponsePayload::new(&response)
4130 .deserialize::<DeleteFargateProfileResponse, _>()?;
4131
4132 Ok(result)
4133 } else {
4134 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4135 Err(DeleteFargateProfileError::from_response(response))
4136 }
4137 }
4138
4139 #[allow(unused_mut)]
4141 async fn delete_nodegroup(
4142 &self,
4143 input: DeleteNodegroupRequest,
4144 ) -> Result<DeleteNodegroupResponse, RusotoError<DeleteNodegroupError>> {
4145 let request_uri = format!(
4146 "/clusters/{name}/node-groups/{nodegroup_name}",
4147 name = input.cluster_name,
4148 nodegroup_name = input.nodegroup_name
4149 );
4150
4151 let mut request = SignedRequest::new("DELETE", "eks", &self.region, &request_uri);
4152 request.set_content_type("application/x-amz-json-1.1".to_owned());
4153
4154 let mut response = self
4155 .client
4156 .sign_and_dispatch(request)
4157 .await
4158 .map_err(RusotoError::from)?;
4159 if response.status.is_success() {
4160 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4161 let result = proto::json::ResponsePayload::new(&response)
4162 .deserialize::<DeleteNodegroupResponse, _>()?;
4163
4164 Ok(result)
4165 } else {
4166 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4167 Err(DeleteNodegroupError::from_response(response))
4168 }
4169 }
4170
4171 #[allow(unused_mut)]
4173 async fn describe_addon(
4174 &self,
4175 input: DescribeAddonRequest,
4176 ) -> Result<DescribeAddonResponse, RusotoError<DescribeAddonError>> {
4177 let request_uri = format!(
4178 "/clusters/{name}/addons/{addon_name}",
4179 addon_name = input.addon_name,
4180 name = input.cluster_name
4181 );
4182
4183 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4184 request.set_content_type("application/x-amz-json-1.1".to_owned());
4185
4186 let mut response = self
4187 .client
4188 .sign_and_dispatch(request)
4189 .await
4190 .map_err(RusotoError::from)?;
4191 if response.status.is_success() {
4192 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4193 let result = proto::json::ResponsePayload::new(&response)
4194 .deserialize::<DescribeAddonResponse, _>()?;
4195
4196 Ok(result)
4197 } else {
4198 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4199 Err(DescribeAddonError::from_response(response))
4200 }
4201 }
4202
4203 #[allow(unused_mut)]
4205 async fn describe_addon_versions(
4206 &self,
4207 input: DescribeAddonVersionsRequest,
4208 ) -> Result<DescribeAddonVersionsResponse, RusotoError<DescribeAddonVersionsError>> {
4209 let request_uri = "/addons/supported-versions";
4210
4211 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4212 request.set_content_type("application/x-amz-json-1.1".to_owned());
4213
4214 let mut params = Params::new();
4215 if let Some(ref x) = input.addon_name {
4216 params.put("addonName", x);
4217 }
4218 if let Some(ref x) = input.kubernetes_version {
4219 params.put("kubernetesVersion", x);
4220 }
4221 if let Some(ref x) = input.max_results {
4222 params.put("maxResults", x);
4223 }
4224 if let Some(ref x) = input.next_token {
4225 params.put("nextToken", x);
4226 }
4227 request.set_params(params);
4228
4229 let mut response = self
4230 .client
4231 .sign_and_dispatch(request)
4232 .await
4233 .map_err(RusotoError::from)?;
4234 if response.status.is_success() {
4235 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4236 let result = proto::json::ResponsePayload::new(&response)
4237 .deserialize::<DescribeAddonVersionsResponse, _>()?;
4238
4239 Ok(result)
4240 } else {
4241 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4242 Err(DescribeAddonVersionsError::from_response(response))
4243 }
4244 }
4245
4246 #[allow(unused_mut)]
4248 async fn describe_cluster(
4249 &self,
4250 input: DescribeClusterRequest,
4251 ) -> Result<DescribeClusterResponse, RusotoError<DescribeClusterError>> {
4252 let request_uri = format!("/clusters/{name}", name = input.name);
4253
4254 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4255 request.set_content_type("application/x-amz-json-1.1".to_owned());
4256
4257 let mut response = self
4258 .client
4259 .sign_and_dispatch(request)
4260 .await
4261 .map_err(RusotoError::from)?;
4262 if response.status.is_success() {
4263 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4264 let result = proto::json::ResponsePayload::new(&response)
4265 .deserialize::<DescribeClusterResponse, _>()?;
4266
4267 Ok(result)
4268 } else {
4269 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4270 Err(DescribeClusterError::from_response(response))
4271 }
4272 }
4273
4274 #[allow(unused_mut)]
4276 async fn describe_fargate_profile(
4277 &self,
4278 input: DescribeFargateProfileRequest,
4279 ) -> Result<DescribeFargateProfileResponse, RusotoError<DescribeFargateProfileError>> {
4280 let request_uri = format!(
4281 "/clusters/{name}/fargate-profiles/{fargate_profile_name}",
4282 name = input.cluster_name,
4283 fargate_profile_name = input.fargate_profile_name
4284 );
4285
4286 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4287 request.set_content_type("application/x-amz-json-1.1".to_owned());
4288
4289 let mut response = self
4290 .client
4291 .sign_and_dispatch(request)
4292 .await
4293 .map_err(RusotoError::from)?;
4294 if response.status.is_success() {
4295 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4296 let result = proto::json::ResponsePayload::new(&response)
4297 .deserialize::<DescribeFargateProfileResponse, _>()?;
4298
4299 Ok(result)
4300 } else {
4301 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4302 Err(DescribeFargateProfileError::from_response(response))
4303 }
4304 }
4305
4306 #[allow(unused_mut)]
4308 async fn describe_identity_provider_config(
4309 &self,
4310 input: DescribeIdentityProviderConfigRequest,
4311 ) -> Result<
4312 DescribeIdentityProviderConfigResponse,
4313 RusotoError<DescribeIdentityProviderConfigError>,
4314 > {
4315 let request_uri = format!(
4316 "/clusters/{name}/identity-provider-configs/describe",
4317 name = input.cluster_name
4318 );
4319
4320 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4321 request.set_content_type("application/x-amz-json-1.1".to_owned());
4322
4323 let encoded = Some(serde_json::to_vec(&input).unwrap());
4324 request.set_payload(encoded);
4325
4326 let mut response = self
4327 .client
4328 .sign_and_dispatch(request)
4329 .await
4330 .map_err(RusotoError::from)?;
4331 if response.status.is_success() {
4332 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4333 let result = proto::json::ResponsePayload::new(&response)
4334 .deserialize::<DescribeIdentityProviderConfigResponse, _>()?;
4335
4336 Ok(result)
4337 } else {
4338 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4339 Err(DescribeIdentityProviderConfigError::from_response(response))
4340 }
4341 }
4342
4343 #[allow(unused_mut)]
4345 async fn describe_nodegroup(
4346 &self,
4347 input: DescribeNodegroupRequest,
4348 ) -> Result<DescribeNodegroupResponse, RusotoError<DescribeNodegroupError>> {
4349 let request_uri = format!(
4350 "/clusters/{name}/node-groups/{nodegroup_name}",
4351 name = input.cluster_name,
4352 nodegroup_name = input.nodegroup_name
4353 );
4354
4355 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4356 request.set_content_type("application/x-amz-json-1.1".to_owned());
4357
4358 let mut response = self
4359 .client
4360 .sign_and_dispatch(request)
4361 .await
4362 .map_err(RusotoError::from)?;
4363 if response.status.is_success() {
4364 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4365 let result = proto::json::ResponsePayload::new(&response)
4366 .deserialize::<DescribeNodegroupResponse, _>()?;
4367
4368 Ok(result)
4369 } else {
4370 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4371 Err(DescribeNodegroupError::from_response(response))
4372 }
4373 }
4374
4375 #[allow(unused_mut)]
4377 async fn describe_update(
4378 &self,
4379 input: DescribeUpdateRequest,
4380 ) -> Result<DescribeUpdateResponse, RusotoError<DescribeUpdateError>> {
4381 let request_uri = format!(
4382 "/clusters/{name}/updates/{update_id}",
4383 name = input.name,
4384 update_id = input.update_id
4385 );
4386
4387 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4388 request.set_content_type("application/x-amz-json-1.1".to_owned());
4389
4390 let mut params = Params::new();
4391 if let Some(ref x) = input.addon_name {
4392 params.put("addonName", x);
4393 }
4394 if let Some(ref x) = input.nodegroup_name {
4395 params.put("nodegroupName", x);
4396 }
4397 request.set_params(params);
4398
4399 let mut response = self
4400 .client
4401 .sign_and_dispatch(request)
4402 .await
4403 .map_err(RusotoError::from)?;
4404 if response.status.is_success() {
4405 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4406 let result = proto::json::ResponsePayload::new(&response)
4407 .deserialize::<DescribeUpdateResponse, _>()?;
4408
4409 Ok(result)
4410 } else {
4411 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4412 Err(DescribeUpdateError::from_response(response))
4413 }
4414 }
4415
4416 #[allow(unused_mut)]
4418 async fn disassociate_identity_provider_config(
4419 &self,
4420 input: DisassociateIdentityProviderConfigRequest,
4421 ) -> Result<
4422 DisassociateIdentityProviderConfigResponse,
4423 RusotoError<DisassociateIdentityProviderConfigError>,
4424 > {
4425 let request_uri = format!(
4426 "/clusters/{name}/identity-provider-configs/disassociate",
4427 name = input.cluster_name
4428 );
4429
4430 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4431 request.set_content_type("application/x-amz-json-1.1".to_owned());
4432
4433 let encoded = Some(serde_json::to_vec(&input).unwrap());
4434 request.set_payload(encoded);
4435
4436 let mut response = self
4437 .client
4438 .sign_and_dispatch(request)
4439 .await
4440 .map_err(RusotoError::from)?;
4441 if response.status.is_success() {
4442 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4443 let result = proto::json::ResponsePayload::new(&response)
4444 .deserialize::<DisassociateIdentityProviderConfigResponse, _>()?;
4445
4446 Ok(result)
4447 } else {
4448 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4449 Err(DisassociateIdentityProviderConfigError::from_response(
4450 response,
4451 ))
4452 }
4453 }
4454
4455 #[allow(unused_mut)]
4457 async fn list_addons(
4458 &self,
4459 input: ListAddonsRequest,
4460 ) -> Result<ListAddonsResponse, RusotoError<ListAddonsError>> {
4461 let request_uri = format!("/clusters/{name}/addons", name = input.cluster_name);
4462
4463 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4464 request.set_content_type("application/x-amz-json-1.1".to_owned());
4465
4466 let mut params = Params::new();
4467 if let Some(ref x) = input.max_results {
4468 params.put("maxResults", x);
4469 }
4470 if let Some(ref x) = input.next_token {
4471 params.put("nextToken", x);
4472 }
4473 request.set_params(params);
4474
4475 let mut response = self
4476 .client
4477 .sign_and_dispatch(request)
4478 .await
4479 .map_err(RusotoError::from)?;
4480 if response.status.is_success() {
4481 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4482 let result = proto::json::ResponsePayload::new(&response)
4483 .deserialize::<ListAddonsResponse, _>()?;
4484
4485 Ok(result)
4486 } else {
4487 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4488 Err(ListAddonsError::from_response(response))
4489 }
4490 }
4491
4492 #[allow(unused_mut)]
4494 async fn list_clusters(
4495 &self,
4496 input: ListClustersRequest,
4497 ) -> Result<ListClustersResponse, RusotoError<ListClustersError>> {
4498 let request_uri = "/clusters";
4499
4500 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4501 request.set_content_type("application/x-amz-json-1.1".to_owned());
4502
4503 let mut params = Params::new();
4504 if let Some(ref x) = input.max_results {
4505 params.put("maxResults", x);
4506 }
4507 if let Some(ref x) = input.next_token {
4508 params.put("nextToken", x);
4509 }
4510 request.set_params(params);
4511
4512 let mut response = self
4513 .client
4514 .sign_and_dispatch(request)
4515 .await
4516 .map_err(RusotoError::from)?;
4517 if response.status.is_success() {
4518 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4519 let result = proto::json::ResponsePayload::new(&response)
4520 .deserialize::<ListClustersResponse, _>()?;
4521
4522 Ok(result)
4523 } else {
4524 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4525 Err(ListClustersError::from_response(response))
4526 }
4527 }
4528
4529 #[allow(unused_mut)]
4531 async fn list_fargate_profiles(
4532 &self,
4533 input: ListFargateProfilesRequest,
4534 ) -> Result<ListFargateProfilesResponse, RusotoError<ListFargateProfilesError>> {
4535 let request_uri = format!(
4536 "/clusters/{name}/fargate-profiles",
4537 name = input.cluster_name
4538 );
4539
4540 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4541 request.set_content_type("application/x-amz-json-1.1".to_owned());
4542
4543 let mut params = Params::new();
4544 if let Some(ref x) = input.max_results {
4545 params.put("maxResults", x);
4546 }
4547 if let Some(ref x) = input.next_token {
4548 params.put("nextToken", x);
4549 }
4550 request.set_params(params);
4551
4552 let mut response = self
4553 .client
4554 .sign_and_dispatch(request)
4555 .await
4556 .map_err(RusotoError::from)?;
4557 if response.status.is_success() {
4558 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4559 let result = proto::json::ResponsePayload::new(&response)
4560 .deserialize::<ListFargateProfilesResponse, _>()?;
4561
4562 Ok(result)
4563 } else {
4564 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4565 Err(ListFargateProfilesError::from_response(response))
4566 }
4567 }
4568
4569 #[allow(unused_mut)]
4571 async fn list_identity_provider_configs(
4572 &self,
4573 input: ListIdentityProviderConfigsRequest,
4574 ) -> Result<ListIdentityProviderConfigsResponse, RusotoError<ListIdentityProviderConfigsError>>
4575 {
4576 let request_uri = format!(
4577 "/clusters/{name}/identity-provider-configs",
4578 name = input.cluster_name
4579 );
4580
4581 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4582 request.set_content_type("application/x-amz-json-1.1".to_owned());
4583
4584 let mut params = Params::new();
4585 if let Some(ref x) = input.max_results {
4586 params.put("maxResults", x);
4587 }
4588 if let Some(ref x) = input.next_token {
4589 params.put("nextToken", x);
4590 }
4591 request.set_params(params);
4592
4593 let mut response = self
4594 .client
4595 .sign_and_dispatch(request)
4596 .await
4597 .map_err(RusotoError::from)?;
4598 if response.status.is_success() {
4599 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4600 let result = proto::json::ResponsePayload::new(&response)
4601 .deserialize::<ListIdentityProviderConfigsResponse, _>()?;
4602
4603 Ok(result)
4604 } else {
4605 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4606 Err(ListIdentityProviderConfigsError::from_response(response))
4607 }
4608 }
4609
4610 #[allow(unused_mut)]
4612 async fn list_nodegroups(
4613 &self,
4614 input: ListNodegroupsRequest,
4615 ) -> Result<ListNodegroupsResponse, RusotoError<ListNodegroupsError>> {
4616 let request_uri = format!("/clusters/{name}/node-groups", name = input.cluster_name);
4617
4618 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4619 request.set_content_type("application/x-amz-json-1.1".to_owned());
4620
4621 let mut params = Params::new();
4622 if let Some(ref x) = input.max_results {
4623 params.put("maxResults", x);
4624 }
4625 if let Some(ref x) = input.next_token {
4626 params.put("nextToken", x);
4627 }
4628 request.set_params(params);
4629
4630 let mut response = self
4631 .client
4632 .sign_and_dispatch(request)
4633 .await
4634 .map_err(RusotoError::from)?;
4635 if response.status.is_success() {
4636 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4637 let result = proto::json::ResponsePayload::new(&response)
4638 .deserialize::<ListNodegroupsResponse, _>()?;
4639
4640 Ok(result)
4641 } else {
4642 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4643 Err(ListNodegroupsError::from_response(response))
4644 }
4645 }
4646
4647 #[allow(unused_mut)]
4649 async fn list_tags_for_resource(
4650 &self,
4651 input: ListTagsForResourceRequest,
4652 ) -> Result<ListTagsForResourceResponse, RusotoError<ListTagsForResourceError>> {
4653 let request_uri = format!("/tags/{resource_arn}", resource_arn = input.resource_arn);
4654
4655 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4656 request.set_content_type("application/x-amz-json-1.1".to_owned());
4657
4658 let mut response = self
4659 .client
4660 .sign_and_dispatch(request)
4661 .await
4662 .map_err(RusotoError::from)?;
4663 if response.status.is_success() {
4664 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4665 let result = proto::json::ResponsePayload::new(&response)
4666 .deserialize::<ListTagsForResourceResponse, _>()?;
4667
4668 Ok(result)
4669 } else {
4670 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4671 Err(ListTagsForResourceError::from_response(response))
4672 }
4673 }
4674
4675 #[allow(unused_mut)]
4677 async fn list_updates(
4678 &self,
4679 input: ListUpdatesRequest,
4680 ) -> Result<ListUpdatesResponse, RusotoError<ListUpdatesError>> {
4681 let request_uri = format!("/clusters/{name}/updates", name = input.name);
4682
4683 let mut request = SignedRequest::new("GET", "eks", &self.region, &request_uri);
4684 request.set_content_type("application/x-amz-json-1.1".to_owned());
4685
4686 let mut params = Params::new();
4687 if let Some(ref x) = input.addon_name {
4688 params.put("addonName", x);
4689 }
4690 if let Some(ref x) = input.max_results {
4691 params.put("maxResults", x);
4692 }
4693 if let Some(ref x) = input.next_token {
4694 params.put("nextToken", x);
4695 }
4696 if let Some(ref x) = input.nodegroup_name {
4697 params.put("nodegroupName", x);
4698 }
4699 request.set_params(params);
4700
4701 let mut response = self
4702 .client
4703 .sign_and_dispatch(request)
4704 .await
4705 .map_err(RusotoError::from)?;
4706 if response.status.is_success() {
4707 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4708 let result = proto::json::ResponsePayload::new(&response)
4709 .deserialize::<ListUpdatesResponse, _>()?;
4710
4711 Ok(result)
4712 } else {
4713 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4714 Err(ListUpdatesError::from_response(response))
4715 }
4716 }
4717
4718 #[allow(unused_mut)]
4720 async fn tag_resource(
4721 &self,
4722 input: TagResourceRequest,
4723 ) -> Result<TagResourceResponse, RusotoError<TagResourceError>> {
4724 let request_uri = format!("/tags/{resource_arn}", resource_arn = input.resource_arn);
4725
4726 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4727 request.set_content_type("application/x-amz-json-1.1".to_owned());
4728
4729 let encoded = Some(serde_json::to_vec(&input).unwrap());
4730 request.set_payload(encoded);
4731
4732 let mut response = self
4733 .client
4734 .sign_and_dispatch(request)
4735 .await
4736 .map_err(RusotoError::from)?;
4737 if response.status.is_success() {
4738 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4739 let result = proto::json::ResponsePayload::new(&response)
4740 .deserialize::<TagResourceResponse, _>()?;
4741
4742 Ok(result)
4743 } else {
4744 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4745 Err(TagResourceError::from_response(response))
4746 }
4747 }
4748
4749 #[allow(unused_mut)]
4751 async fn untag_resource(
4752 &self,
4753 input: UntagResourceRequest,
4754 ) -> Result<UntagResourceResponse, RusotoError<UntagResourceError>> {
4755 let request_uri = format!("/tags/{resource_arn}", resource_arn = input.resource_arn);
4756
4757 let mut request = SignedRequest::new("DELETE", "eks", &self.region, &request_uri);
4758 request.set_content_type("application/x-amz-json-1.1".to_owned());
4759
4760 let mut params = Params::new();
4761 for item in input.tag_keys.iter() {
4762 params.put("tagKeys", item);
4763 }
4764 request.set_params(params);
4765
4766 let mut response = self
4767 .client
4768 .sign_and_dispatch(request)
4769 .await
4770 .map_err(RusotoError::from)?;
4771 if response.status.is_success() {
4772 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4773 let result = proto::json::ResponsePayload::new(&response)
4774 .deserialize::<UntagResourceResponse, _>()?;
4775
4776 Ok(result)
4777 } else {
4778 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4779 Err(UntagResourceError::from_response(response))
4780 }
4781 }
4782
4783 #[allow(unused_mut)]
4785 async fn update_addon(
4786 &self,
4787 input: UpdateAddonRequest,
4788 ) -> Result<UpdateAddonResponse, RusotoError<UpdateAddonError>> {
4789 let request_uri = format!(
4790 "/clusters/{name}/addons/{addon_name}/update",
4791 addon_name = input.addon_name,
4792 name = input.cluster_name
4793 );
4794
4795 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4796 request.set_content_type("application/x-amz-json-1.1".to_owned());
4797
4798 let encoded = Some(serde_json::to_vec(&input).unwrap());
4799 request.set_payload(encoded);
4800
4801 let mut response = self
4802 .client
4803 .sign_and_dispatch(request)
4804 .await
4805 .map_err(RusotoError::from)?;
4806 if response.status.is_success() {
4807 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4808 let result = proto::json::ResponsePayload::new(&response)
4809 .deserialize::<UpdateAddonResponse, _>()?;
4810
4811 Ok(result)
4812 } else {
4813 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4814 Err(UpdateAddonError::from_response(response))
4815 }
4816 }
4817
4818 #[allow(unused_mut)]
4820 async fn update_cluster_config(
4821 &self,
4822 input: UpdateClusterConfigRequest,
4823 ) -> Result<UpdateClusterConfigResponse, RusotoError<UpdateClusterConfigError>> {
4824 let request_uri = format!("/clusters/{name}/update-config", name = input.name);
4825
4826 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4827 request.set_content_type("application/x-amz-json-1.1".to_owned());
4828
4829 let encoded = Some(serde_json::to_vec(&input).unwrap());
4830 request.set_payload(encoded);
4831
4832 let mut response = self
4833 .client
4834 .sign_and_dispatch(request)
4835 .await
4836 .map_err(RusotoError::from)?;
4837 if response.status.is_success() {
4838 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4839 let result = proto::json::ResponsePayload::new(&response)
4840 .deserialize::<UpdateClusterConfigResponse, _>()?;
4841
4842 Ok(result)
4843 } else {
4844 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4845 Err(UpdateClusterConfigError::from_response(response))
4846 }
4847 }
4848
4849 #[allow(unused_mut)]
4851 async fn update_cluster_version(
4852 &self,
4853 input: UpdateClusterVersionRequest,
4854 ) -> Result<UpdateClusterVersionResponse, RusotoError<UpdateClusterVersionError>> {
4855 let request_uri = format!("/clusters/{name}/updates", name = input.name);
4856
4857 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4858 request.set_content_type("application/x-amz-json-1.1".to_owned());
4859
4860 let encoded = Some(serde_json::to_vec(&input).unwrap());
4861 request.set_payload(encoded);
4862
4863 let mut response = self
4864 .client
4865 .sign_and_dispatch(request)
4866 .await
4867 .map_err(RusotoError::from)?;
4868 if response.status.is_success() {
4869 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4870 let result = proto::json::ResponsePayload::new(&response)
4871 .deserialize::<UpdateClusterVersionResponse, _>()?;
4872
4873 Ok(result)
4874 } else {
4875 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4876 Err(UpdateClusterVersionError::from_response(response))
4877 }
4878 }
4879
4880 #[allow(unused_mut)]
4882 async fn update_nodegroup_config(
4883 &self,
4884 input: UpdateNodegroupConfigRequest,
4885 ) -> Result<UpdateNodegroupConfigResponse, RusotoError<UpdateNodegroupConfigError>> {
4886 let request_uri = format!(
4887 "/clusters/{name}/node-groups/{nodegroup_name}/update-config",
4888 name = input.cluster_name,
4889 nodegroup_name = input.nodegroup_name
4890 );
4891
4892 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4893 request.set_content_type("application/x-amz-json-1.1".to_owned());
4894
4895 let encoded = Some(serde_json::to_vec(&input).unwrap());
4896 request.set_payload(encoded);
4897
4898 let mut response = self
4899 .client
4900 .sign_and_dispatch(request)
4901 .await
4902 .map_err(RusotoError::from)?;
4903 if response.status.is_success() {
4904 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4905 let result = proto::json::ResponsePayload::new(&response)
4906 .deserialize::<UpdateNodegroupConfigResponse, _>()?;
4907
4908 Ok(result)
4909 } else {
4910 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4911 Err(UpdateNodegroupConfigError::from_response(response))
4912 }
4913 }
4914
4915 #[allow(unused_mut)]
4917 async fn update_nodegroup_version(
4918 &self,
4919 input: UpdateNodegroupVersionRequest,
4920 ) -> Result<UpdateNodegroupVersionResponse, RusotoError<UpdateNodegroupVersionError>> {
4921 let request_uri = format!(
4922 "/clusters/{name}/node-groups/{nodegroup_name}/update-version",
4923 name = input.cluster_name,
4924 nodegroup_name = input.nodegroup_name
4925 );
4926
4927 let mut request = SignedRequest::new("POST", "eks", &self.region, &request_uri);
4928 request.set_content_type("application/x-amz-json-1.1".to_owned());
4929
4930 let encoded = Some(serde_json::to_vec(&input).unwrap());
4931 request.set_payload(encoded);
4932
4933 let mut response = self
4934 .client
4935 .sign_and_dispatch(request)
4936 .await
4937 .map_err(RusotoError::from)?;
4938 if response.status.is_success() {
4939 let mut response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4940 let result = proto::json::ResponsePayload::new(&response)
4941 .deserialize::<UpdateNodegroupVersionResponse, _>()?;
4942
4943 Ok(result)
4944 } else {
4945 let response = response.buffer().await.map_err(RusotoError::HttpDispatch)?;
4946 Err(UpdateNodegroupVersionError::from_response(response))
4947 }
4948 }
4949}