Reduce load and system stress by polling less with awatility

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

@@ -87,6 +87,7 @@ public User user() {
                         throw new UncheckedIOException(e);
                     }
                 });
+        System.out.println("User: " + ref.get());
         return ref.get();
     }
 
@@ -104,6 +105,7 @@ public QueryResult query(String query) {
                         throw new UncheckedIOException(e);
                     }
                 });
+        System.out.println("Query: " + ref.get());
         return ref.get();
     }
 
@@ -123,6 +125,7 @@ public TempoResult traces(String service, int limit, int spss) {
                         throw new UncheckedIOException(e);
                     }
                 });
+        System.out.println("Traces: " + ref.get());
         return ref.get();
     }
 }

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 + '\'' +
+                '}';
+    }
 }