18
18
import io .jenkins .plugins .opentelemetry .job .log .util .InputStreamByteBuffer ;
19
19
import io .jenkins .plugins .opentelemetry .job .log .util .LogLineIterator ;
20
20
import io .jenkins .plugins .opentelemetry .job .log .util .LogLineIteratorInputStream ;
21
- import io .jenkins .plugins .opentelemetry .semconv .JenkinsOtelSemanticAttributes ;
21
+ import io .jenkins .plugins .opentelemetry .semconv .ExtendedJenkinsAttributes ;
22
22
import io .opentelemetry .api .GlobalOpenTelemetry ;
23
23
import io .opentelemetry .api .OpenTelemetry ;
24
24
import io .opentelemetry .api .trace .Span ;
@@ -94,7 +94,7 @@ public LokiLogStorageRetriever(@Nonnull String lokiUrl, boolean disableSslVerifi
94
94
this .lokiTenantId = lokiTenantId ;
95
95
this .httpContext = new BasicHttpContext ();
96
96
this .openTelemetry = GlobalOpenTelemetry .get ();
97
- this .tracer = openTelemetry .getTracer (JenkinsOtelSemanticAttributes .INSTRUMENTATION_NAME );
97
+ this .tracer = openTelemetry .getTracer (ExtendedJenkinsAttributes .INSTRUMENTATION_NAME );
98
98
99
99
HttpClientBuilder httpClientBuilder = ApacheHttpClientTelemetry .create (openTelemetry ).newHttpClientBuilder ();
100
100
if (disableSslVerifications ) {
@@ -118,8 +118,8 @@ public LokiLogStorageRetriever(@Nonnull String lokiUrl, boolean disableSslVerifi
118
118
@ Override
119
119
public LogsQueryResult overallLog (@ Nonnull String jobFullName , int runNumber , @ Nonnull String traceId , @ Nonnull String spanId , boolean complete , @ Nonnull Instant startTime , @ Nullable Instant endTime ) {
120
120
SpanBuilder spanBuilder = tracer .spanBuilder ("LokiLogStorageRetriever.overallLog" )
121
- .setAttribute (JenkinsOtelSemanticAttributes .CI_PIPELINE_ID , jobFullName )
122
- .setAttribute (JenkinsOtelSemanticAttributes .CI_PIPELINE_RUN_NUMBER , (long ) runNumber )
121
+ .setAttribute (ExtendedJenkinsAttributes .CI_PIPELINE_ID , jobFullName )
122
+ .setAttribute (ExtendedJenkinsAttributes .CI_PIPELINE_RUN_NUMBER , (long ) runNumber )
123
123
.setAttribute ("complete" , complete );
124
124
125
125
Span span = spanBuilder .startSpan ();
@@ -139,7 +139,7 @@ public LogsQueryResult overallLog(@Nonnull String jobFullName, int runNumber, @N
139
139
lokiQueryParameters ,
140
140
httpClient , httpContext ,
141
141
lokiUrl , lokiCredentials , lokiTenantId ,
142
- openTelemetry .getTracer ( JenkinsOtelSemanticAttributes .INSTRUMENTATION_NAME ));
142
+ openTelemetry .getTracer ( ExtendedJenkinsAttributes .INSTRUMENTATION_NAME ));
143
143
144
144
LogLineIterator .JenkinsHttpSessionLineBytesToLogLineIdMapper <Long > lineBytesToLineNumberConverter = new LogLineIterator .JenkinsHttpSessionLineBytesToLogLineIdMapper <>(jobFullName , runNumber , null );
145
145
InputStream lineIteratorInputStream = new LogLineIteratorInputStream <>(logLines , lineBytesToLineNumberConverter , tracer );
@@ -176,9 +176,9 @@ public LogsQueryResult overallLog(@Nonnull String jobFullName, int runNumber, @N
176
176
@ Override
177
177
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 ) {
178
178
SpanBuilder spanBuilder = tracer .spanBuilder ("LokiLogStorageRetriever.stepLog" )
179
- .setAttribute (JenkinsOtelSemanticAttributes .CI_PIPELINE_ID , jobFullName )
180
- .setAttribute (JenkinsOtelSemanticAttributes .CI_PIPELINE_RUN_NUMBER , (long ) runNumber )
181
- .setAttribute (JenkinsOtelSemanticAttributes .JENKINS_STEP_ID , flowNodeId )
179
+ .setAttribute (ExtendedJenkinsAttributes .CI_PIPELINE_ID , jobFullName )
180
+ .setAttribute (ExtendedJenkinsAttributes .CI_PIPELINE_RUN_NUMBER , (long ) runNumber )
181
+ .setAttribute (ExtendedJenkinsAttributes .JENKINS_STEP_ID , flowNodeId )
182
182
.setAttribute ("complete" , complete );
183
183
184
184
Span span = spanBuilder .startSpan ();
0 commit comments