Package io.jenkins.plugins.opentelemetry.backend.elastic

Class ElasticsearchBuildLogsLineIterator

java.lang.Object

io.jenkins.plugins.opentelemetry.backend.elastic.ElasticsearchBuildLogsLineIterator

All Implemented Interfaces:

LineIterator, Closeable, AutoCloseable, Iterator<String>

public class ElasticsearchBuildLogsLineIterator
extends Object
implements LineIterator, Closeable

https://www.elastic.co/guide/en/elasticsearch/reference/7.17/point-in-time-api.html

Nested Class Summary

Nested classes/interfaces inherited from interface io.jenkins.plugins.opentelemetry.job.log.util.LineIterator

LineIterator.JenkinsHttpSessionLineBytesToLineNumberConverter, LineIterator.LineBytesToLineNumberConverter

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_LINES
static int	PAGE_SIZE
static co.elastic.clients.elasticsearch._types.Time	POINT_IN_TIME_KEEP_ALIVE

Constructor Summary

Constructors

Constructor	Description
ElasticsearchBuildLogsLineIterator(String jobFullName, int runNumber, String traceId, co.elastic.clients.elasticsearch.ElasticsearchClient esClient, io.opentelemetry.api.trace.Tracer tracer)
ElasticsearchBuildLogsLineIterator(String jobFullName, int runNumber, String traceId, String flowNodeId, co.elastic.clients.elasticsearch.ElasticsearchClient esClient, io.opentelemetry.api.trace.Tracer tracer)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
protected Iterator<String>	loadNextFormattedLogLines()
String	next()
void	skipLines(long skipLines)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Field Detail

POINT_IN_TIME_KEEP_ALIVE

public static final co.elastic.clients.elasticsearch._types.Time POINT_IN_TIME_KEEP_ALIVE

PAGE_SIZE

public static final int PAGE_SIZE

See Also:

Constant Field Values

MAX_LINES

public static final int MAX_LINES

See Also:

Constant Field Values

Constructor Detail

ElasticsearchBuildLogsLineIterator

public ElasticsearchBuildLogsLineIterator(@NonNull
                                          String jobFullName,
                                          int runNumber,
                                          @NonNull
                                          String traceId,
                                          @NonNull
                                          co.elastic.clients.elasticsearch.ElasticsearchClient esClient,
                                          @NonNull
                                          io.opentelemetry.api.trace.Tracer tracer)

ElasticsearchBuildLogsLineIterator

public ElasticsearchBuildLogsLineIterator(@NonNull
                                          String jobFullName,
                                          int runNumber,
                                          @NonNull
                                          String traceId,
                                          @Nullable
                                          String flowNodeId,
                                          @NonNull
                                          co.elastic.clients.elasticsearch.ElasticsearchClient esClient,
                                          @NonNull
                                          io.opentelemetry.api.trace.Tracer tracer)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<String>

next

public String next()

Specified by:

next in interface Iterator<String>

loadNextFormattedLogLines

protected Iterator<String> loadNextFormattedLogLines()
                                              throws IOException

Throws:

IOException

skipLines

public void skipLines(long skipLines)

Specified by:

skipLines in interface LineIterator