Implement logs retriever pagination using new Elasticsearch Java client

.gitignore

@@ -53,3 +53,6 @@ private/
 agent.jar
 local.pid
 
+.env
+
+

pom.xml

@@ -61,16 +61,18 @@
                 <type>pom</type>
                 <scope>import</scope>
             </dependency>
+            <!--
             <dependency>
-                <!--
+                <!- -
                 conflict between io.opentelemetry:opentelemetry-sdk-extension-aws and io.jenkins.configuration-as-code:test-harness
-                -->
+                - ->
                 <groupId>com.fasterxml.jackson</groupId>
                 <artifactId>jackson-bom</artifactId>
                 <version>2.13.1</version>
                 <type>pom</type>
                 <scope>import</scope>
             </dependency>
+            -->
             <dependency>
                 <!-- okhttp:4.9.3 -> okio:2.8.0 versus okhttp:4.9.3 -> okio:2.8.0 - kotlin-stdlib-->
                 <groupId>org.jetbrains.kotlin</groupId>
@@ -229,6 +231,10 @@
             <artifactId>jsr305</artifactId>
             <version>3.0.2</version>
         </dependency>
+        <dependency>
+            <groupId>org.jenkins-ci.plugins</groupId>
+            <artifactId>jackson2-api</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.jenkins-ci.plugins</groupId>
             <artifactId>credentials</artifactId>
@@ -341,16 +347,11 @@
             <optional>true</optional>
         </dependency>
         <dependency>
-            <groupId>org.elasticsearch.client</groupId>
-            <artifactId>elasticsearch-rest-high-level-client</artifactId>
+            <groupId>co.elastic.clients</groupId>
+            <artifactId>elasticsearch-java</artifactId>
             <version>${elasticstack.version}</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>net.sf.jopt-simple</groupId>
-                    <artifactId>jopt-simple</artifactId>
-                </exclusion>
-            </exclusions>
         </dependency>
+
         <dependency>
             <groupId>io.opentelemetry</groupId>
             <artifactId>opentelemetry-sdk-testing</artifactId>

src/main/java/io/jenkins/plugins/opentelemetry/backend/ElasticBackend.java

@@ -13,7 +13,7 @@
 import hudson.security.ACL;
 import hudson.util.FormValidation;
 import hudson.util.ListBoxModel;
-import io.jenkins.plugins.opentelemetry.backend.elastic.ElasticsearchLogStorageRetriever;
+import io.jenkins.plugins.opentelemetry.backend.elastic.ElasticsearchLogStorageScrollingRetriever;
 import io.jenkins.plugins.opentelemetry.job.log.LogStorageRetriever;
 import jenkins.model.Jenkins;
 import org.apache.commons.lang.StringUtils;
@@ -150,7 +150,7 @@ public String getMetricsVisualizationUrlTemplate() {
     @Override
     public LogStorageRetriever getLogStorageRetriever() {
         if (StringUtils.isNotBlank(this.elasticsearchUrl)) {
-            return new ElasticsearchLogStorageRetriever(this.elasticsearchUrl, ElasticsearchLogStorageRetriever.getCredentials(this.elasticsearchCredentialsId), indexPattern);
+            return new ElasticsearchLogStorageScrollingRetriever(this.elasticsearchUrl, ElasticsearchLogStorageScrollingRetriever.getCredentials(this.elasticsearchCredentialsId), indexPattern);
         } else {
             return null;
         }
@@ -309,7 +309,7 @@ public FormValidation doCheckElasticsearchCredentialsId(Item context, @QueryPara
             }
 
             try {
-                ElasticsearchLogStorageRetriever.getCredentials(elasticsearchCredentialsId);
+                ElasticsearchLogStorageScrollingRetriever.getCredentials(elasticsearchCredentialsId);
             } catch (NoSuchElementException e) {
                 return FormValidation.warning("The credentials are not valid.");
             }
@@ -333,7 +333,10 @@ public FormValidation doValidate(@QueryParameter String credentialsId, @QueryPar
             }
 
             try {
-                ElasticsearchLogStorageRetriever elasticsearchLogStorageRetriever = new ElasticsearchLogStorageRetriever(elasticsearchUrl, ElasticsearchLogStorageRetriever.getCredentials(credentialsId), indexPattern);
+                ElasticsearchLogStorageScrollingRetriever elasticsearchLogStorageRetriever = new ElasticsearchLogStorageScrollingRetriever(
+                    elasticsearchUrl,
+                    ElasticsearchLogStorageScrollingRetriever.getCredentials(credentialsId),
+                    indexPattern);
 
                 if (elasticsearchLogStorageRetriever.indexExists()) {
                     return FormValidation.ok("success");