From 3c99ddfbe12b965c84ce128b11aab25833dac5fb Mon Sep 17 00:00:00 2001
From: Mark Mandel <markmandel@google.com>
Date: Mon, 22 Mar 2021 13:09:29 -0700
Subject: [PATCH] Missing `source` in `ClusterManager` logger. (#219)

Just a small cleanup I saw when reviewing logging.
---
 src/xds/cluster.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/xds/cluster.rs b/src/xds/cluster.rs
index 8b1b868768..842bc58241 100644
--- a/src/xds/cluster.rs
+++ b/src/xds/cluster.rs
@@ -28,7 +28,7 @@ use crate::xds::ads_client::send_discovery_req;
 use crate::xds::error::Error;
 use bytes::Bytes;
 use prost::Message;
-use slog::{debug, warn, Logger};
+use slog::{debug, o, warn, Logger};
 use std::collections::{HashMap, HashSet};
 use std::net::SocketAddr;
 use tokio::sync::mpsc;
@@ -61,12 +61,12 @@ impl ClusterManager {
     /// ACKs/NACKs are sent on the provided channel to be forwarded to the XDS
     /// server.
     pub(in crate::xds) fn new(
-        log: Logger,
+        base: Logger,
         cluster_updates_tx: mpsc::Sender<HashMap<String, ProxyCluster>>,
         discovery_req_tx: mpsc::Sender<DiscoveryRequest>,
     ) -> Self {
         ClusterManager {
-            log,
+            log: base.new(o!("source" => "xds::ClusterManager")),
             discovery_req_tx,
             cluster_updates_tx,
             clusters: HashMap::new(),