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 final int	MAX_LINES
static final int	PAGE_SIZE
static final 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 Details

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 Details

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 Details

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