Make some info logs debug

Signed-off-by: Sebastian Schepens <[email protected]>

Author: sschepens

cache/src/main/java/io/envoyproxy/controlplane/cache/SimpleCache.java

@@ -130,12 +130,14 @@ public Watch createWatch(
 
         long watchId = watchCount;
 
-        LOGGER.info("open watch {} for {}[{}] from node {} for version {}",
-            watchId,
-            request.getTypeUrl(),
-            String.join(", ", request.getResourceNamesList()),
-            group,
-            request.getVersionInfo());
+        if (LOGGER.isDebugEnabled()) {
+          LOGGER.debug("open watch {} for {}[{}] from node {} for version {}",
+              watchId,
+              request.getTypeUrl(),
+              String.join(", ", request.getResourceNamesList()),
+              group,
+              request.getVersionInfo());
+        }
 
         status.setWatch(watchId, watch);
 
@@ -150,12 +152,14 @@ public Watch createWatch(
       if (!responded) {
         watchCount++;
 
-        LOGGER.info("did not respond immediately, leaving open watch {} for {}[{}] from node {} for version {}",
-            watchCount,
-            request.getTypeUrl(),
-            String.join(", ", request.getResourceNamesList()),
-            group,
-            request.getVersionInfo());
+        if (LOGGER.isDebugEnabled()) {
+          LOGGER.debug("did not respond immediately, leaving open watch {} for {}[{}] from node {} for version {}",
+              watchCount,
+              request.getTypeUrl(),
+              String.join(", ", request.getResourceNamesList()),
+              group,
+              request.getVersionInfo());
+        }
 
         status.setWatch(watchCount, watch);
 
@@ -216,10 +220,12 @@ public void setSnapshot(T group, Snapshot snapshot) {
         String version = snapshot.version(watch.request().getTypeUrl(), watch.request().getResourceNamesList());
 
         if (!watch.request().getVersionInfo().equals(version)) {
-          LOGGER.info("responding to open watch {}[{}] with new version {}",
-              id,
-              String.join(", ", watch.request().getResourceNamesList()),
-              version);
+          if (LOGGER.isDebugEnabled()) {
+            LOGGER.debug("responding to open watch {}[{}] with new version {}",
+                id,
+                String.join(", ", watch.request().getResourceNamesList()),
+                version);
+          }
 
           respond(watch, snapshot, group);
 
@@ -283,7 +289,7 @@ private boolean respond(Watch watch, Snapshot snapshot, T group) {
 
     String version = snapshot.version(watch.request().getTypeUrl(), watch.request().getResourceNamesList());
 
-    LOGGER.info("responding for {} from node {} at version {} with version {}",
+    LOGGER.debug("responding for {} from node {} at version {} with version {}",
         watch.request().getTypeUrl(),
         group,
         watch.request().getVersionInfo(),

server/src/main/java/io/envoyproxy/controlplane/server/DiscoveryServer.java

@@ -177,7 +177,7 @@ private StreamObserver<DiscoveryRequest> createRequestHandler(
     long streamId = streamCount.getAndIncrement();
     Executor executor = executorGroup.next();
 
-    LOGGER.info("[{}] open stream from {}", streamId, defaultTypeUrl);
+    LOGGER.debug("[{}] open stream from {}", streamId, defaultTypeUrl);
 
     callbacks.forEach(cb -> cb.onStreamOpen(streamId, defaultTypeUrl));
 
@@ -239,7 +239,7 @@ public void onNext(DiscoveryRequest request) {
         requestTypeUrl = defaultTypeUrl;
       }
 
-      LOGGER.info("[{}] request {}[{}] with nonce {} from version {}",
+      LOGGER.debug("[{}] request {}[{}] with nonce {} from version {}",
           streamId,
           requestTypeUrl,
           String.join(", ", request.getResourceNamesList()),
@@ -300,7 +300,7 @@ public void onError(Throwable t) {
 
     @Override
     public void onCompleted() {
-      LOGGER.info("[{}] stream closed", streamId);
+      LOGGER.debug("[{}] stream closed", streamId);
 
       try {
         callbacks.forEach(cb -> cb.onStreamClose(streamId, defaultTypeUrl));
@@ -337,7 +337,7 @@ private void send(Response response, String typeUrl) {
           .setNonce(nonce)
           .build();
 
-      LOGGER.info("[{}] response {} with nonce {} version {}", streamId, typeUrl, nonce, response.version());
+      LOGGER.debug("[{}] response {} with nonce {} version {}", streamId, typeUrl, nonce, response.version());
 
       callbacks.forEach(cb -> cb.onStreamResponse(streamId, response.request(), discoveryResponse));