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

Class ElasticsearchLogStorageRetriever

java.lang.Object

io.jenkins.plugins.opentelemetry.backend.elastic.ElasticsearchLogStorageRetriever

All Implemented Interfaces:

LogStorageRetriever, Closeable, AutoCloseable

public class ElasticsearchLogStorageRetriever
extends Object
implements LogStorageRetriever, Closeable

Retrieve the logs from Elasticsearch.

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	KEEPALIVE
static final String	KEEPALIVE_DEFAULT
static final int	KEEPALIVE_INTERVAL
static final String	KEEPALIVE_INTERVAL_DEFAULT
static final String	KEEPALIVE_INTERVAL_PROPERTY
static final String	KEEPALIVE_PROPERTY

Constructor Summary

Constructors

Constructor	Description
ElasticsearchLogStorageRetriever(String elasticsearchUrl, boolean disableSslVerifications, String elasticsearchCredentialsId, groovy.text.Template buildLogsVisualizationUrlTemplate, TemplateBindingsProvider templateBindingsProvider)

Method Summary

Modifier and Type	Method	Description
List<FormValidation>	checkElasticsearchSetup()	Example of a successful check:
void	close()
LogsQueryResult	overallLog(String jobFullName, int runNumber, String traceId, String spanId, boolean complete, Instant startTime, Instant endTime)
protected static String	prettyPrintPhaseRetentionPolicy(co.elastic.clients.elasticsearch.ilm.Phase phase, String phaseName)
LogsQueryResult	stepLog(String jobFullName, int runNumber, String flowNodeId, String traceId, String spanId, boolean complete, Instant startTime, Instant endTime)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

KEEPALIVE_INTERVAL_DEFAULT

public static final String KEEPALIVE_INTERVAL_DEFAULT

See Also:

• Constant Field Values

KEEPALIVE_DEFAULT

public static final String KEEPALIVE_DEFAULT

See Also:

• Constant Field Values

KEEPALIVE_INTERVAL_PROPERTY

public static final String KEEPALIVE_INTERVAL_PROPERTY

KEEPALIVE_PROPERTY

public static final String KEEPALIVE_PROPERTY

KEEPALIVE_INTERVAL

public static final int KEEPALIVE_INTERVAL

KEEPALIVE

public static final boolean KEEPALIVE

Constructor Details

ElasticsearchLogStorageRetriever

@MustBeClosed
public ElasticsearchLogStorageRetriever(@NonNull
 String elasticsearchUrl,
 boolean disableSslVerifications,
 @NonNull
 String elasticsearchCredentialsId,
 @NonNull
 groovy.text.Template buildLogsVisualizationUrlTemplate,
 @NonNull
 TemplateBindingsProvider templateBindingsProvider)

Method Details

overallLog

@NonNull
public LogsQueryResult overallLog(@NonNull
 String jobFullName,
 int runNumber,
 @NonNull
 String traceId,
 @NonNull
 String spanId,
 boolean complete,
 @NonNull
 Instant startTime,
 Instant endTime)

Specified by:

overallLog in interface LogStorageRetriever

Parameters:

jobFullName - see AbstractItem.getFullName()

runNumber - see Run.getNumber()

complete - if true, we claim to be serving the complete log for a build, so implementations should be sure to retrieve final log lines

startTime - Pipeline run start time. See Run.getStartTimeInMillis()

endTime - null if the pipeline is still running. See Run.getDuration()

stepLog

@NonNull
public LogsQueryResult stepLog(@NonNull
 String jobFullName,
 int runNumber,
 @NonNull
 String flowNodeId,
 @NonNull
 String traceId,
 @NonNull
 String spanId,
 boolean complete,
 @NonNull
 Instant startTime,
 @Nullable
 Instant endTime)

Specified by:

stepLog in interface LogStorageRetriever

Parameters:

jobFullName - see AbstractItem.getFullName()

runNumber - see Run.getNumber()

flowNodeId - see FlowNode.getId()

complete - if true, we claim to be serving the complete log for a build, so implementations should be sure to retrieve final log lines

startTime - Pipeline run start time. See Run.getStartTimeInMillis()

endTime - null if the pipeline is still running. See Run.getDuration()

checkElasticsearchSetup

public List<FormValidation> checkElasticsearchSetup()

Example of a successful check:

 OK: Connected to Elasticsearch https://***.es.example.com with user 'jenkins'.
 OK: Indices 'logs-*' found.
 

prettyPrintPhaseRetentionPolicy

@NonNull
protected static String prettyPrintPhaseRetentionPolicy(co.elastic.clients.elasticsearch.ilm.Phase phase,
 String phaseName)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object