Fix compilation when the tracing_instrument feature is enabled (#3110)

Author: mkrasnitski

src/cache/mod.rs

@@ -37,6 +37,8 @@ use dashmap::DashMap;
 #[cfg(feature = "temp_cache")]
 use mini_moka::sync::Cache as MokaCache;
 use parking_lot::RwLock;
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 
 pub use self::cache_update::CacheUpdate;
 pub use self::settings::Settings;

src/error.rs

@@ -6,6 +6,8 @@ use std::io::Error as IoError;
 use reqwest::{header::InvalidHeaderValue, Error as ReqwestError};
 #[cfg(feature = "gateway")]
 use tokio_tungstenite::tungstenite::error::Error as TungsteniteError;
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 
 #[cfg(feature = "gateway")]
 use crate::gateway::GatewayError;

src/gateway/client/mod.rs

@@ -38,6 +38,8 @@ use std::time::Duration;
 use futures::channel::mpsc::UnboundedReceiver as Receiver;
 use futures::future::BoxFuture;
 use futures::StreamExt as _;
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 use tracing::{debug, warn};
 
 pub use self::context::Context;
@@ -294,7 +296,6 @@ impl IntoFuture for ClientBuilder {
 
     type IntoFuture = BoxFuture<'static, Result<Client>>;
 
-    #[cfg_attr(feature = "tracing_instrument", instrument(skip(self)))]
     fn into_future(self) -> Self::IntoFuture {
         let data = self.data.unwrap_or(Arc::new(()));
         #[cfg(feature = "framework")]

src/gateway/sharding/mod.rs

@@ -50,6 +50,8 @@ use aformat::{aformat, ArrayString, CapStr};
 use serde::Deserialize;
 use tokio_tungstenite::tungstenite::error::Error as TungsteniteError;
 use tokio_tungstenite::tungstenite::protocol::frame::CloseFrame;
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 use tracing::{debug, error, info, trace, warn};
 use url::Url;
 

src/gateway/sharding/shard_manager.rs

@@ -9,6 +9,8 @@ use futures::channel::mpsc::{self, UnboundedReceiver as Receiver, UnboundedSende
 use futures::{SinkExt, StreamExt};
 use tokio::sync::Mutex;
 use tokio::time::timeout;
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 use tracing::{info, warn};
 
 use super::{

src/gateway/sharding/shard_queuer.rs

@@ -8,6 +8,8 @@ use futures::channel::mpsc::UnboundedReceiver as Receiver;
 use futures::StreamExt;
 use tokio::sync::Mutex;
 use tokio::time::{sleep, timeout, Duration, Instant};
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 use tracing::{debug, info, warn};
 
 use super::{

src/gateway/sharding/shard_runner.rs

@@ -5,6 +5,8 @@ use tokio_tungstenite::tungstenite;
 use tokio_tungstenite::tungstenite::error::Error as TungsteniteError;
 use tokio_tungstenite::tungstenite::protocol::frame::CloseFrame;
 use tokio_tungstenite::tungstenite::Message;
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 use tracing::{debug, error, info, trace, warn};
 
 #[cfg(feature = "collector")]

src/gateway/ws.rs

@@ -13,6 +13,8 @@ use tokio::time::{timeout, Duration};
 use tokio_tungstenite::tungstenite::protocol::{CloseFrame, WebSocketConfig};
 use tokio_tungstenite::tungstenite::{Error as WsError, Message};
 use tokio_tungstenite::{connect_async_with_config, MaybeTlsStream, WebSocketStream};
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 use tracing::{debug, trace, warn};
 use url::Url;
 #[cfg(feature = "transport_compression_zstd")]

src/http/client.rs

@@ -15,6 +15,8 @@ use serde::de::DeserializeOwned;
 use serde::ser::SerializeSeq as _;
 use serde_json::{from_value, to_string, to_vec};
 use to_arraystring::ToArrayString as _;
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 use tracing::{debug, warn};
 
 use super::multipart::{Multipart, MultipartUpload};

src/http/ratelimiting.rs

@@ -46,6 +46,8 @@ use reqwest::{Client, Response, StatusCode};
 use tokio::sync::Mutex;
 use tokio::time::{sleep, Duration};
 use tracing::debug;
+#[cfg(feature = "tracing_instrument")]
+use tracing::instrument;
 
 pub use super::routing::RatelimitingBucket;
 use super::{HttpError, LightMethod, Request};