Deny clippy::large_futures and fix +nightly lint (Azure#1895)

* Deny clippy::large_futures and fix +nightly lint

* Fix test errors

* Add clippy to cspell dictionary

Author: heaths

.vscode/cspell.json

@@ -24,7 +24,8 @@
     "asyncoperation",
     "azsdk",
     "azurecli",
-    "Contoso",
+    "clippy",
+    "contoso",
     "cplusplus",
     "datalake",
     "datetime",
@@ -40,7 +41,7 @@
     "iothub",
     "keyvault",
     "msrc",
-    "Newtonsoft",
+    "newtonsoft",
     "oidc",
     "pageable",
     "pkce",

Cargo.toml

@@ -105,4 +105,5 @@ tz-rs = { version = "0.6" }
 url = "2.2"
 uuid = { version = "1.0", features = ["v4"] }
 
-[workspace.lints]
+[workspace.lints.clippy]
+large_futures = "deny"

eng/test/mock_transport/src/mock_request.rs

@@ -116,7 +116,7 @@ impl<'de> Visitor<'de> for RequestVisitor {
     }
 }
 
-impl<'a> Serialize for RequestSerializer<'a> {
+impl Serialize for RequestSerializer<'_> {
     fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
     where
         S: Serializer,

sdk/core/azure_core/src/hmac.rs

@@ -9,6 +9,7 @@ use crate::{
 };
 
 /// Tries to create an HMAC SHA256 signature from the given `data` and `key`.
+///
 /// The `key` is expected to be a base64 encoded string and will be decoded
 /// before using it for signing. The returned signature is also base64 encoded.
 ///

sdk/core/azure_core_amqp/src/fe2o3/cbs.rs

@@ -27,15 +27,15 @@ impl<'a> Fe2o3ClaimsBasedSecurity<'a> {
     }
 }
 
-impl<'a> Fe2o3ClaimsBasedSecurity<'a> {}
+impl Fe2o3ClaimsBasedSecurity<'_> {}
 
-impl<'a> Drop for Fe2o3ClaimsBasedSecurity<'a> {
+impl Drop for Fe2o3ClaimsBasedSecurity<'_> {
     fn drop(&mut self) {
         debug!("Dropping Fe2o3ClaimsBasedSecurity.");
     }
 }
 
-impl<'a> AmqpClaimsBasedSecurityApis for Fe2o3ClaimsBasedSecurity<'a> {
+impl AmqpClaimsBasedSecurityApis for Fe2o3ClaimsBasedSecurity<'_> {
     async fn attach(&self) -> Result<()> {
         let session = self.session.implementation.get()?;
         let mut session = session.lock().await;

sdk/core/azure_core_amqp/src/fe2o3/management.rs

@@ -134,7 +134,7 @@ impl<'a> WithApplicationPropertiesRequest<'a> {
     }
 }
 
-impl<'a> fe2o3_amqp_management::Request for WithApplicationPropertiesRequest<'a> {
+impl fe2o3_amqp_management::Request for WithApplicationPropertiesRequest<'_> {
     const OPERATION: &'static str = "READ";
     type Response = ReadResponse;
     type Body = ();

sdk/core/azure_core_amqp/src/messaging.rs

@@ -1054,7 +1054,8 @@ impl AmqpApplicationProperties {
     }
 }
 
-/// An AMQP message
+/// An AMQP message.
+///
 /// This is a simplified version of the AMQP message
 /// that is used in the Azure SDK for Event Hubs
 /// and is not a complete implementation of the AMQP message

sdk/cosmos/azure_data_cosmos/examples/cosmos/main.rs

@@ -54,14 +54,14 @@ pub async fn main() -> Result<(), Box<dyn Error>> {
         .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
         .init();
 
-    let mut args = ProgramArgs::parse();
+    let args = ProgramArgs::parse();
 
     let Some(cmd) = args.subcommand else {
         ProgramArgs::command().print_long_help()?;
         return Ok(());
     };
 
-    let client = create_client(&mut args.shared_args)?;
+    let client = create_client(&args.shared_args)?;
 
     match cmd {
         Subcommands::Create(cmd) => cmd.run(client).await,

sdk/eventhubs/azure_messaging_eventhubs/src/lib.rs

@@ -6,30 +6,6 @@
 // cspell: words amqp eventdata
 #![doc = include_str!("../README.md")]
 
-/// This module contains the implementation of the Azure Messaging Event Hubs SDK for Rust.
-///
-/// The SDK provides types and functions to interact with Azure Event Hubs, which is a highly scalable data streaming platform and event ingestion service.
-/// It allows you to consume events from an Event Hub and create/send events to an Event Hub.
-///
-/// # Examples
-///
-/// Consuming events from an Event Hub:
-///
-/// ```no_run
-/// # use azure_identity::{DefaultAzureCredential, TokenCredentialOptions};
-/// # #[tokio::main]
-/// # async fn main() -> Result<(), Box<dyn std::error::Error + 'static>> {
-/// # let my_credentials = DefaultAzureCredential::new()?;
-
-/// use azure_messaging_eventhubs::consumer::ConsumerClient;
-/// use azure_messaging_eventhubs::models::EventData;
-///
-/// let consumer_client = ConsumerClient::new("fully_qualified_domain", "eventhub_name", None, my_credentials, None);
-/// let partition_properties = consumer_client.get_partition_properties("0").await?;
-/// # Ok(())
-/// }
-/// ```
-///
 pub(crate) mod common;
 
 /// Types related to consuming events from an Event Hub.
@@ -408,8 +384,8 @@ pub mod models {
     }
 
     /// Represents the data associated with an event received from an Event Hub.
-    /// This struct provides the event data, enqueued time, offset, sequence number, partition key, and system properties of the event.
     ///
+    /// This struct provides the event data, enqueued time, offset, sequence number, partition key, and system properties of the event.
     pub struct ReceivedEventData {
         message: AmqpMessage,
         event_data: EventData,

sdk/typespec/typespec_client_core/examples/binary_data_request.rs

@@ -9,7 +9,7 @@ use typespec_client_core::{fs::FileStreamBuilder, http::RequestContent};
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
     // Log traces to stdout.
-    let _log = tracing_subscriber::fmt()
+    tracing_subscriber::fmt()
         .with_span_events(FmtSpan::ENTER | FmtSpan::EXIT)
         .with_max_level(LevelFilter::DEBUG)
         .init();