Reduce load and system stress by polling less with awatility

Author: brunobat

integration-tests/observability-lgtm-prometheus/src/main/resources/application.properties

@@ -2,3 +2,6 @@ quarkus.log.category."io.quarkus.observability".level=DEBUG
 quarkus.log.category."io.quarkus.devservices".level=DEBUG
 
 quarkus.micrometer.binder-enabled-default=false
+
+quarkus.http.access-log.enabled=true
+quarkus.http.access-log.pattern=%h %l %u %t "%r" %s %b %m "%{i,Referer}" "%{i,User-Agent}" "%{i,X-Request-Id}" "%{i,X-Organization-Id}" %D

integration-tests/observability-lgtm-prometheus/src/test/java/io/quarkus/observability/test/LgtmTest.java

@@ -32,6 +32,9 @@ public void testPoke() {
         String response = RestAssured.get("/api/poke?f=100").body().asString();
         log.info("Response: " + response);
         GrafanaClient client = new GrafanaClient(endpoint, "admin", "admin");
+
+        Awaitility.setDefaultPollInterval(1, TimeUnit.SECONDS); // reduce load on the server. Default is .1s
+
         Awaitility.await().atMost(61, TimeUnit.SECONDS).until(
                 client::user,
                 u -> "admin".equals(u.login));

integration-tests/observability-lgtm/src/test/java/io/quarkus/observability/test/LgtmTestHelper.java

@@ -18,6 +18,9 @@ protected void poke(String path) {
         String response = RestAssured.get(path + "/poke?f=100").body().asString();
         log.info("Response: " + response);
         GrafanaClient client = new GrafanaClient(grafanaEndpoint(), "admin", "admin");
+
+        Awaitility.setDefaultPollInterval(1, TimeUnit.SECONDS); // reduce load on the server. Default is .1s
+
         Awaitility.await().atMost(61, TimeUnit.SECONDS).until(
                 client::user,
                 u -> "admin".equals(u.login));
@@ -28,5 +31,4 @@ protected void poke(String path) {
                 () -> client.traces("quarkus-integration-test-observability-lgtm", 20, 3),
                 result -> !result.traces.isEmpty());
     }
-
 }

test-framework/observability/src/main/java/io/quarkus/observability/test/utils/GrafanaClient.java

@@ -10,11 +10,14 @@
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.BiConsumer;
 import java.util.function.Function;
+import java.util.logging.Logger;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
 public class GrafanaClient {
+    private static final Logger LOG = Logger.getLogger(GrafanaClient.class.getName());
+
     private static final ObjectMapper MAPPER = new ObjectMapper();
 
     private final String url;
@@ -87,7 +90,9 @@ public User user() {
                         throw new UncheckedIOException(e);
                     }
                 });
-        return ref.get();
+        User user = ref.get();
+        LOG.info("User: " + user);
+        return user;
     }
 
     public QueryResult query(String query) {
@@ -104,7 +109,9 @@ public QueryResult query(String query) {
                         throw new UncheckedIOException(e);
                     }
                 });
-        return ref.get();
+        QueryResult queryResult = ref.get();
+        LOG.info("Query: " + queryResult);
+        return queryResult;
     }
 
     public TempoResult traces(String service, int limit, int spss) {
@@ -123,6 +130,8 @@ public TempoResult traces(String service, int limit, int spss) {
                         throw new UncheckedIOException(e);
                     }
                 });
-        return ref.get();
+        TempoResult tempoResult = ref.get();
+        LOG.info("Traces: " + tempoResult);
+        return tempoResult;
     }
 }

test-framework/observability/src/main/java/io/quarkus/observability/test/utils/User.java

@@ -11,4 +11,13 @@ public class User {
     public String email;
     @JsonProperty
     public String login;
+
+    @Override
+    public String toString() {
+        return "User{" +
+                "id=" + id +
+                ", email='" + email + '\'' +
+                ", login='" + login + '\'' +
+                '}';
+    }
 }