Update services json and generated modules

rusoto/services/timestream-query/Cargo.toml

@@ -7,7 +7,7 @@ license = "MIT"
 name = "rusoto_timestream_query"
 readme = "README.md"
 repository = "https://github.com/rusoto/rusoto"
-version = "0.45.0"
+version = "0.46.0"
 homepage = "https://www.rusoto.org/"
 edition = "2018"
 exclude = ["test_resources/*"]

rusoto/services/timestream-query/README.md

@@ -2,6 +2,11 @@
 # Rusoto TimestreamQuery
 Rust SDK for Amazon Timestream Query
 
+<a href="https://docs.rs/rusoto_timestream_query/0.46.0" title="API Docs"><img src="https://img.shields.io/badge/API-docs-blue.svg" alt="api-docs-badge"></img></a>
+<a href="https://crates.io/crates/rusoto_timestream_query/0.46.0" title="Crates.io"><img src="https://img.shields.io/crates/v/rusoto_core.svg" alt="crates-io"></img></a>
+<a href="#license" title="License: MIT"><img src="https://img.shields.io/badge/license-MIT-blue.svg" alt="license-badge"></img></a>
+<a href="https://discordapp.com/invite/WMJ4DWp"><img src="https://img.shields.io/discord/670751965273391124"></img></a>
+
 You may be looking for:
 
 * [An overview of Rusoto][rusoto-overview]
@@ -15,15 +20,15 @@ Rust stable or beta are required to use Rusoto. Nightly is tested, but not guara
 versions _may_ be supported. The currently supported Rust versions can be found in the Rusoto project
 [`travis.yml`](https://github.com/rusoto/rusoto/blob/master/.travis.yml).
 
-On Linux, OpenSSL is required.
+On Linux, OpenSSL is required if using the `native-tls` feature.
 
 ## Installation
 
 To use `rusoto_timestream_query` in your application, add it as a dependency in your `Cargo.toml`:
 
 ```toml
 [dependencies]
-rusoto_timestream_query = "0.45.0"
+rusoto_timestream_query = "0.46.0"
 ```
 
 ## Crate Features

rusoto/services/timestream-query/src/generated.rs

@@ -164,11 +164,33 @@ pub struct QueryResponse {
     /// <p> A unique ID for the given query. </p>
     #[serde(rename = "QueryId")]
     pub query_id: String,
+    /// <p>Information about the status of the query, including progress and bytes scannned.</p>
+    #[serde(rename = "QueryStatus")]
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub query_status: Option<QueryStatus>,
     /// <p> The result set rows returned by the query. </p>
     #[serde(rename = "Rows")]
     pub rows: Vec<Row>,
 }
 
+/// <p>Information about the status of the query, including progress and bytes scannned.</p>
+#[derive(Clone, Debug, Default, Deserialize, PartialEq)]
+#[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]
+pub struct QueryStatus {
+    /// <p>The amount of data scanned by the query in bytes that you will be charged for. This is a cumulative sum and represents the total amount of data that you will be charged for since the query was started. The charge is applied only once and is either applied when the query completes execution or when the query is cancelled. </p>
+    #[serde(rename = "CumulativeBytesMetered")]
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub cumulative_bytes_metered: Option<i64>,
+    /// <p>The amount of data scanned by the query in bytes. This is a cumulative sum and represents the total amount of bytes scanned since the query was started. </p>
+    #[serde(rename = "CumulativeBytesScanned")]
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub cumulative_bytes_scanned: Option<i64>,
+    /// <p>The progress of the query, expressed as a percentage.</p>
+    #[serde(rename = "ProgressPercentage")]
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub progress_percentage: Option<f64>,
+}
+
 /// <p>Represents a single row in the query results.</p>
 #[derive(Clone, Debug, Default, Deserialize, PartialEq)]
 #[cfg_attr(any(test, feature = "serialize_structs"), derive(Serialize))]

rusoto/services/timestream-write/README.md

@@ -2,6 +2,11 @@
 # Rusoto TimestreamWrite
 Rust SDK for Amazon Timestream Write
 
+<a href="https://docs.rs/rusoto_timestream_write/0.46.0" title="API Docs"><img src="https://img.shields.io/badge/API-docs-blue.svg" alt="api-docs-badge"></img></a>
+<a href="https://crates.io/crates/rusoto_timestream_write/0.46.0" title="Crates.io"><img src="https://img.shields.io/crates/v/rusoto_core.svg" alt="crates-io"></img></a>
+<a href="#license" title="License: MIT"><img src="https://img.shields.io/badge/license-MIT-blue.svg" alt="license-badge"></img></a>
+<a href="https://discordapp.com/invite/WMJ4DWp"><img src="https://img.shields.io/discord/670751965273391124"></img></a>
+
 You may be looking for:
 
 * [An overview of Rusoto][rusoto-overview]
@@ -15,15 +20,15 @@ Rust stable or beta are required to use Rusoto. Nightly is tested, but not guara
 versions _may_ be supported. The currently supported Rust versions can be found in the Rusoto project
 [`travis.yml`](https://github.com/rusoto/rusoto/blob/master/.travis.yml).
 
-On Linux, OpenSSL is required.
+On Linux, OpenSSL is required if using the `native-tls` feature.
 
 ## Installation
 
 To use `rusoto_timestream_write` in your application, add it as a dependency in your `Cargo.toml`:
 
 ```toml
 [dependencies]
-rusoto_timestream_write = "0.45.0"
+rusoto_timestream_write = "0.46.0"
 ```
 
 ## Crate Features

rusoto/services/timestream-write/src/generated.rs

@@ -28,7 +28,7 @@ use serde::{Deserialize, Serialize};
 impl TimestreamWriteClient {
     fn new_signed_request(&self, http_method: &str, request_uri: &str) -> SignedRequest {
         let mut request = SignedRequest::new(http_method, "timestream", &self.region, request_uri);
-        request.set_endpoint_prefix("ingest-cell1.timestream".to_string());
+        request.set_endpoint_prefix("ingest.timestream".to_string());
 
         request.set_content_type("application/x-amz-json-1.0".to_owned());
 
@@ -210,7 +210,7 @@ pub struct Dimension {
     #[serde(rename = "DimensionValueType")]
     #[serde(skip_serializing_if = "Option::is_none")]
     pub dimension_value_type: Option<String>,
-    /// <p> Dimension represents the meta data attributes of the time series. For example, the name and availability zone of an EC2 instance or the name of the manufacturer of a wind turbine are dimensions. <i>Dimension names can only contain alphanumeric characters and underscores. Dimension names cannot end with an underscore.</i> </p>
+    /// <p> Dimension represents the meta data attributes of the time series. For example, the name and availability zone of an EC2 instance or the name of the manufacturer of a wind turbine are dimensions. </p> <p>For constraints on Dimension names, see <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html#limits.naming">Naming Constraints</a>.</p>
     #[serde(rename = "Name")]
     pub name: String,
     /// <p>The value of the dimension.</p>
@@ -323,20 +323,26 @@ pub struct Record {
     #[serde(rename = "MeasureValueType")]
     #[serde(skip_serializing_if = "Option::is_none")]
     pub measure_value_type: Option<String>,
-    /// <p> Contains the time at which the measure value for the data point was collected. </p>
+    /// <p> Contains the time at which the measure value for the data point was collected. The time value plus the unit provides the time elapsed since the epoch. For example, if the time value is <code>12345</code> and the unit is <code>ms</code>, then <code>12345 ms</code> have elapsed since the epoch. </p>
     #[serde(rename = "Time")]
     #[serde(skip_serializing_if = "Option::is_none")]
     pub time: Option<String>,
     /// <p> The granularity of the timestamp unit. It indicates if the time value is in seconds, milliseconds, nanoseconds or other supported values. </p>
     #[serde(rename = "TimeUnit")]
     #[serde(skip_serializing_if = "Option::is_none")]
     pub time_unit: Option<String>,
+    /// <p>64-bit attribute used for record updates. Write requests for duplicate data with a higher version number will update the existing measure value and version. In cases where the measure value is the same, <code>Version</code> will still be updated . Default value is to 1.</p>
+    #[serde(rename = "Version")]
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub version: Option<i64>,
 }
 
 /// <p> Records that were not successfully inserted into Timestream due to data validation issues that must be resolved prior to reinserting time series data into the system. </p>
 #[derive(Clone, Debug, Default, PartialEq)]
 pub struct RejectedRecord {
-    /// <p> The reason why a record was not successfully inserted into Timestream. Possible causes of failure include: </p> <ul> <li> <p> Records with duplicate data where there are multiple records with the same dimensions, timestamps, and measure names but different measure values. </p> </li> <li> <p> Records with timestamps that lie outside the retention duration of the memory store </p> </li> <li> <p> Records with dimensions or measures that exceed the Timestream defined limits. </p> </li> </ul> <p> For more information, see <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html">Access Management</a> in the Timestream Developer Guide. </p>
+    /// <p>The existing version of the record. This value is populated in scenarios where an identical record exists with a higher version than the version in the write request.</p>
+    pub existing_version: Option<i64>,
+    /// <p> The reason why a record was not successfully inserted into Timestream. Possible causes of failure include: </p> <ul> <li> <p> Records with duplicate data where there are multiple records with the same dimensions, timestamps, and measure names but different measure values. </p> </li> <li> <p> Records with timestamps that lie outside the retention duration of the memory store </p> <note> <p>When the retention window is updated, you will receive a <code>RejectedRecords</code> exception if you immediately try to ingest data within the new window. To avoid a <code>RejectedRecords</code> exception, wait until the duration of the new window to ingest new data. For further information, see <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/best-practices.html#configuration"> Best Practices for Configuring Timestream</a> and <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/storage.html">the explanation of how storage works in Timestream</a>.</p> </note> </li> <li> <p> Records with dimensions or measures that exceed the Timestream defined limits. </p> </li> </ul> <p> For more information, see <a href="https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html">Access Management</a> in the Timestream Developer Guide. </p>
     pub reason: Option<String>,
     /// <p> The index of the record in the input request for WriteRecords. Indexes begin with 0. </p>
     pub record_index: Option<i64>,
@@ -975,6 +981,8 @@ pub enum ListTagsForResourceError {
     InvalidEndpoint(String),
     /// <p>The operation tried to access a nonexistent resource. The resource might not be specified correctly, or its status might not be ACTIVE.</p>
     ResourceNotFound(String),
+    /// <p> Too many requests were made by a user exceeding service quotas. The request was throttled.</p>
+    Throttling(String),
 }
 
 impl ListTagsForResourceError {
@@ -989,6 +997,9 @@ impl ListTagsForResourceError {
                         err.msg,
                     ))
                 }
+                "ThrottlingException" => {
+                    return RusotoError::Service(ListTagsForResourceError::Throttling(err.msg))
+                }
                 "ValidationException" => return RusotoError::Validation(err.msg),
                 _ => {}
             }
@@ -1002,6 +1013,7 @@ impl fmt::Display for ListTagsForResourceError {
         match *self {
             ListTagsForResourceError::InvalidEndpoint(ref cause) => write!(f, "{}", cause),
             ListTagsForResourceError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
+            ListTagsForResourceError::Throttling(ref cause) => write!(f, "{}", cause),
         }
     }
 }
@@ -1015,6 +1027,8 @@ pub enum TagResourceError {
     ResourceNotFound(String),
     /// <p> Instance quota of resource exceeded for this account.</p>
     ServiceQuotaExceeded(String),
+    /// <p> Too many requests were made by a user exceeding service quotas. The request was throttled.</p>
+    Throttling(String),
 }
 
 impl TagResourceError {
@@ -1030,6 +1044,9 @@ impl TagResourceError {
                 "ServiceQuotaExceededException" => {
                     return RusotoError::Service(TagResourceError::ServiceQuotaExceeded(err.msg))
                 }
+                "ThrottlingException" => {
+                    return RusotoError::Service(TagResourceError::Throttling(err.msg))
+                }
                 "ValidationException" => return RusotoError::Validation(err.msg),
                 _ => {}
             }
@@ -1044,6 +1061,7 @@ impl fmt::Display for TagResourceError {
             TagResourceError::InvalidEndpoint(ref cause) => write!(f, "{}", cause),
             TagResourceError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
             TagResourceError::ServiceQuotaExceeded(ref cause) => write!(f, "{}", cause),
+            TagResourceError::Throttling(ref cause) => write!(f, "{}", cause),
         }
     }
 }
@@ -1057,6 +1075,8 @@ pub enum UntagResourceError {
     ResourceNotFound(String),
     /// <p> Instance quota of resource exceeded for this account.</p>
     ServiceQuotaExceeded(String),
+    /// <p> Too many requests were made by a user exceeding service quotas. The request was throttled.</p>
+    Throttling(String),
 }
 
 impl UntagResourceError {
@@ -1072,6 +1092,9 @@ impl UntagResourceError {
                 "ServiceQuotaExceededException" => {
                     return RusotoError::Service(UntagResourceError::ServiceQuotaExceeded(err.msg))
                 }
+                "ThrottlingException" => {
+                    return RusotoError::Service(UntagResourceError::Throttling(err.msg))
+                }
                 "ValidationException" => return RusotoError::Validation(err.msg),
                 _ => {}
             }
@@ -1086,6 +1109,7 @@ impl fmt::Display for UntagResourceError {
             UntagResourceError::InvalidEndpoint(ref cause) => write!(f, "{}", cause),
             UntagResourceError::ResourceNotFound(ref cause) => write!(f, "{}", cause),
             UntagResourceError::ServiceQuotaExceeded(ref cause) => write!(f, "{}", cause),
+            UntagResourceError::Throttling(ref cause) => write!(f, "{}", cause),
         }
     }
 }
@@ -1279,13 +1303,13 @@ pub trait TimestreamWrite {
         input: CreateTableRequest,
     ) -> Result<CreateTableResponse, RusotoError<CreateTableError>>;
 
-    /// <p>Deletes a given Timestream database. <i>This is an irreversible operation. After a database is deleted, the time series data from its tables cannot be recovered.</i> </p> <p>All tables in the database must be deleted first, or a ValidationException error will be thrown. </p>
+    /// <p>Deletes a given Timestream database. <i>This is an irreversible operation. After a database is deleted, the time series data from its tables cannot be recovered.</i> </p> <p>All tables in the database must be deleted first, or a ValidationException error will be thrown. </p> <p>Due to the nature of distributed retries, the operation can return either success or a ResourceNotFoundException. Clients should consider them equivalent.</p>
     async fn delete_database(
         &self,
         input: DeleteDatabaseRequest,
     ) -> Result<(), RusotoError<DeleteDatabaseError>>;
 
-    /// <p>Deletes a given Timestream table. This is an irreversible operation. After a Timestream database table is deleted, the time series data stored in the table cannot be recovered. </p>
+    /// <p>Deletes a given Timestream table. This is an irreversible operation. After a Timestream database table is deleted, the time series data stored in the table cannot be recovered. </p> <p>Due to the nature of distributed retries, the operation can return either success or a ResourceNotFoundException. Clients should consider them equivalent.</p>
     async fn delete_table(
         &self,
         input: DeleteTableRequest,
@@ -1432,7 +1456,7 @@ impl TimestreamWrite for TimestreamWriteClient {
         proto::json::ResponsePayload::new(&response).deserialize::<CreateTableResponse, _>()
     }
 
-    /// <p>Deletes a given Timestream database. <i>This is an irreversible operation. After a database is deleted, the time series data from its tables cannot be recovered.</i> </p> <p>All tables in the database must be deleted first, or a ValidationException error will be thrown. </p>
+    /// <p>Deletes a given Timestream database. <i>This is an irreversible operation. After a database is deleted, the time series data from its tables cannot be recovered.</i> </p> <p>All tables in the database must be deleted first, or a ValidationException error will be thrown. </p> <p>Due to the nature of distributed retries, the operation can return either success or a ResourceNotFoundException. Clients should consider them equivalent.</p>
     async fn delete_database(
         &self,
         input: DeleteDatabaseRequest,
@@ -1449,7 +1473,7 @@ impl TimestreamWrite for TimestreamWriteClient {
         Ok(())
     }
 
-    /// <p>Deletes a given Timestream table. This is an irreversible operation. After a Timestream database table is deleted, the time series data stored in the table cannot be recovered. </p>
+    /// <p>Deletes a given Timestream table. This is an irreversible operation. After a Timestream database table is deleted, the time series data stored in the table cannot be recovered. </p> <p>Due to the nature of distributed retries, the operation can return either success or a ResourceNotFoundException. Clients should consider them equivalent.</p>
     async fn delete_table(
         &self,
         input: DeleteTableRequest,

service_crategen/services.json

@@ -1236,14 +1236,14 @@
     "baseTypeName": "Textract"
   },
   "timestream-query": {
-    "version": "0.45.0",
-    "coreVersion": "0.45.0",
+    "version": "0.46.0",
+    "coreVersion": "0.46.0",
     "protocolVersion": "2018-11-01",
     "baseTypeName": "TimestreamQuery"
   },
   "timestream-write": {
-    "version": "0.45.0",
-    "coreVersion": "0.45.0",
+    "version": "0.46.0",
+    "coreVersion": "0.46.0",
     "protocolVersion": "2018-11-01",
     "baseTypeName": "TimestreamWrite"
   },