diff --git a/src/xds/client.rs b/src/xds/client.rs index e8ad068240..7d189a9085 100644 --- a/src/xds/client.rs +++ b/src/xds/client.rs @@ -204,7 +204,7 @@ impl Client { let client = connect_to_server .instrument(tracing::trace_span!("client_connect")) .await?; - tracing::info!("Connected to relay server"); + tracing::info!("Connected to management server"); Ok(client) } } @@ -395,7 +395,7 @@ impl MdsStream { let mut stream = control_plane.stream_aggregated_resources(stream).await?; while let Some(result) = stream.next().await { let response = result?; - tracing::info!(config=%serde_json::to_value(&config).unwrap(), "received discovery response"); + tracing::debug!(config=%serde_json::to_value(&config).unwrap(), "received discovery response"); requests.send(response)?; } @@ -506,7 +506,7 @@ pub fn handle_discovery_responses( ) -> std::pin::Pin> + Send>> { Box::pin(async_stream::try_stream! { let _stream_metrics = super::metrics::StreamConnectionMetrics::new(identifier.clone()); - tracing::info!("awaiting response"); + tracing::debug!("awaiting response"); for await response in stream { let response = match response { @@ -520,7 +520,7 @@ pub fn handle_discovery_responses( let control_plane_identifier = response.control_plane.as_ref().map(|cp| cp.identifier.clone()).unwrap_or_default(); super::metrics::discovery_responses(&control_plane_identifier, &response.type_url).inc(); - tracing::info!( + tracing::debug!( version = &*response.version_info, r#type = &*response.type_url, nonce = &*response.nonce, @@ -534,7 +534,7 @@ pub fn handle_discovery_responses( .map(Resource::try_from) .try_for_each(|resource| { let resource = resource?; - tracing::info!("applying resource"); + tracing::debug!("applying resource"); (on_new_resource)(&resource) }); diff --git a/src/xds/server.rs b/src/xds/server.rs index 207a0d46b4..2578bd6164 100644 --- a/src/xds/server.rs +++ b/src/xds/server.rs @@ -250,7 +250,7 @@ impl ControlPlane { // Currently just resend previous discovery response. } else if uuid::Uuid::parse_str(&new_message.response_nonce).is_ok() { if pending_acks.cache_get(&new_message.response_nonce).is_some() { - tracing::info!(nonce = %new_message.response_nonce, "ACK"); + tracing::debug!(nonce = %new_message.response_nonce, "ACK"); continue } else { tracing::trace!(nonce = %new_message.response_nonce, "Unknown nonce: could not be found in cache");