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

Class ElasticsearchBuildLogsLineIterator

java.lang.Object

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

All Implemented Interfaces:

LogLineIterator<Long>, Closeable, AutoCloseable, Iterator<LogLine<Long>>

public class ElasticsearchBuildLogsLineIterator
extends Object
implements LogLineIterator<Long>, 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.LogLineIterator

LogLineIterator.JenkinsHttpSessionLineBytesToLogLineIdMapper<Id>, LogLineIterator.LogLineBytesToLogLineIdMapper<Id>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_LINES_PAGINATED
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<LogLine<Long>>	loadNextFormattedLogLines()
LogLine<Long>	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_PAGINATED

public static final int MAX_LINES_PAGINATED

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<LogLine<Long>>

next

public LogLine<Long> next()

Specified by:

next in interface Iterator<LogLine<Long>>

loadNextFormattedLogLines

protected Iterator<LogLine<Long>> loadNextFormattedLogLines()
                                                     throws IOException

Throws:

IOException

skipLines

public void skipLines(Long skipLines)

Specified by:

skipLines in interface LogLineIterator<Long>