opentelemetry -> openTelemetry (#9858)
This commit is contained in:
parent
61f3a64cca
commit
5ba402fd2f
|
@ -23,7 +23,7 @@ public final class ElasticsearchRestInstrumenterFactory {
|
||||||
private ElasticsearchRestInstrumenterFactory() {}
|
private ElasticsearchRestInstrumenterFactory() {}
|
||||||
|
|
||||||
public static Instrumenter<ElasticsearchRestRequest, Response> create(
|
public static Instrumenter<ElasticsearchRestRequest, Response> create(
|
||||||
OpenTelemetry opentelemetry,
|
OpenTelemetry openTelemetry,
|
||||||
String instrumentationName,
|
String instrumentationName,
|
||||||
List<AttributesExtractor<ElasticsearchRestRequest, Response>> attributesExtractors,
|
List<AttributesExtractor<ElasticsearchRestRequest, Response>> attributesExtractors,
|
||||||
Set<String> knownMethods,
|
Set<String> knownMethods,
|
||||||
|
@ -36,7 +36,7 @@ public final class ElasticsearchRestInstrumenterFactory {
|
||||||
new ElasticsearchSpanNameExtractor(dbClientAttributesGetter);
|
new ElasticsearchSpanNameExtractor(dbClientAttributesGetter);
|
||||||
|
|
||||||
return Instrumenter.<ElasticsearchRestRequest, Response>builder(
|
return Instrumenter.<ElasticsearchRestRequest, Response>builder(
|
||||||
opentelemetry, instrumentationName, nameExtractor)
|
openTelemetry, instrumentationName, nameExtractor)
|
||||||
.addAttributesExtractor(DbClientAttributesExtractor.create(dbClientAttributesGetter))
|
.addAttributesExtractor(DbClientAttributesExtractor.create(dbClientAttributesGetter))
|
||||||
.addAttributesExtractor(esClientAtrributesExtractor)
|
.addAttributesExtractor(esClientAtrributesExtractor)
|
||||||
.addAttributesExtractors(attributesExtractors)
|
.addAttributesExtractors(attributesExtractors)
|
||||||
|
|
|
@ -32,14 +32,14 @@ The instrumentation library provides the implementation of `ClientInterceptor` a
|
||||||
|
|
||||||
```java
|
```java
|
||||||
// For client-side, attach the interceptor to your channel builder.
|
// For client-side, attach the interceptor to your channel builder.
|
||||||
void configureClientInterceptor(Opentelemetry opentelemetry, NettyChannelBuilder nettyChannelBuilder) {
|
void configureClientInterceptor(OpenTelemetry openTelemetry, NettyChannelBuilder nettyChannelBuilder) {
|
||||||
GrpcTelemetry grpcTelemetry = GrpcTelemetry.create(opentelemetry);
|
GrpcTelemetry grpcTelemetry = GrpcTelemetry.create(openTelemetry);
|
||||||
nettyChannelBuilder.intercept(grpcTelemetry.newClientInterceptor());
|
nettyChannelBuilder.intercept(grpcTelemetry.newClientInterceptor());
|
||||||
}
|
}
|
||||||
|
|
||||||
// For server-side, attatch the interceptor to your service.
|
// For server-side, attatch the interceptor to your service.
|
||||||
ServerServiceDefinition configureServerInterceptor(Opentelemetry opentelemetry, ServerServiceDefinition serviceDefinition) {
|
ServerServiceDefinition configureServerInterceptor(OpenTelemetry openTelemetry, ServerServiceDefinition serviceDefinition) {
|
||||||
GrpcTelemetry grpcTelemetry = GrpcTelemetry.create(opentelemetry);
|
GrpcTelemetry grpcTelemetry = GrpcTelemetry.create(openTelemetry);
|
||||||
return ServiceInterceptors.intercept(serviceDefinition, grpcTelemetry.newServerInterceptor());
|
return ServiceInterceptors.intercept(serviceDefinition, grpcTelemetry.newServerInterceptor());
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
|
@ -311,15 +311,15 @@ class InstrumentedHttpClientTest extends Specification {
|
||||||
class BarService implements Service {
|
class BarService implements Service {
|
||||||
private final String url
|
private final String url
|
||||||
private final CountDownLatch latch
|
private final CountDownLatch latch
|
||||||
private final OpenTelemetry opentelemetry
|
private final OpenTelemetry openTelemetry
|
||||||
|
|
||||||
BarService(CountDownLatch latch, String url, OpenTelemetry opentelemetry) {
|
BarService(CountDownLatch latch, String url, OpenTelemetry openTelemetry) {
|
||||||
this.latch = latch
|
this.latch = latch
|
||||||
this.url = url
|
this.url = url
|
||||||
this.opentelemetry = opentelemetry
|
this.openTelemetry = openTelemetry
|
||||||
}
|
}
|
||||||
|
|
||||||
private Tracer tracer = opentelemetry.tracerProvider.tracerBuilder("testing").build()
|
private Tracer tracer = openTelemetry.tracerProvider.tracerBuilder("testing").build()
|
||||||
|
|
||||||
void onStart(StartEvent event) {
|
void onStart(StartEvent event) {
|
||||||
def parentContext = Context.current()
|
def parentContext = Context.current()
|
||||||
|
@ -345,15 +345,15 @@ class BarService implements Service {
|
||||||
class BarForkService implements Service {
|
class BarForkService implements Service {
|
||||||
private final String url
|
private final String url
|
||||||
private final CountDownLatch latch
|
private final CountDownLatch latch
|
||||||
private final OpenTelemetry opentelemetry
|
private final OpenTelemetry openTelemetry
|
||||||
|
|
||||||
BarForkService(CountDownLatch latch, String url, OpenTelemetry opentelemetry) {
|
BarForkService(CountDownLatch latch, String url, OpenTelemetry openTelemetry) {
|
||||||
this.latch = latch
|
this.latch = latch
|
||||||
this.url = url
|
this.url = url
|
||||||
this.opentelemetry = opentelemetry
|
this.openTelemetry = openTelemetry
|
||||||
}
|
}
|
||||||
|
|
||||||
private Tracer tracer = opentelemetry.tracerProvider.tracerBuilder("testing").build()
|
private Tracer tracer = openTelemetry.tracerProvider.tracerBuilder("testing").build()
|
||||||
|
|
||||||
void onStart(StartEvent event) {
|
void onStart(StartEvent event) {
|
||||||
Execution.fork().start {
|
Execution.fork().start {
|
||||||
|
|
|
@ -32,14 +32,14 @@ runtimeOnly("io.opentelemetry.instrumentation:opentelemetry-runtime-telemetry-ja
|
||||||
Register observers for the desired runtime metrics:
|
Register observers for the desired runtime metrics:
|
||||||
|
|
||||||
```java
|
```java
|
||||||
OpenTelemetry opentelemetry = // OpenTelemetry instance configured elsewhere
|
OpenTelemetry openTelemetry = // OpenTelemetry instance configured elsewhere
|
||||||
|
|
||||||
BufferPools.registerObservers(opentelemetry);
|
BufferPools.registerObservers(openTelemetry);
|
||||||
Classes.registerObservers(opentelemetry);
|
Classes.registerObservers(openTelemetry);
|
||||||
Cpu.registerObservers(opentelemetry);
|
Cpu.registerObservers(openTelemetry);
|
||||||
MemoryPools.registerObservers(opentelemetry);
|
MemoryPools.registerObservers(openTelemetry);
|
||||||
Threads.registerObservers(opentelemetry);
|
Threads.registerObservers(openTelemetry);
|
||||||
GarbageCollector.registerObservers(opentelemetry);
|
GarbageCollector.registerObservers(openTelemetry);
|
||||||
```
|
```
|
||||||
|
|
||||||
## Garbage Collector Dependent Metrics
|
## Garbage Collector Dependent Metrics
|
||||||
|
|
|
@ -151,7 +151,7 @@ implementation("io.opentelemetry:opentelemetry-extension-annotations:OPENTELEMET
|
||||||
|
|
||||||
#### OpenTelemetry Tracer Auto Configuration
|
#### OpenTelemetry Tracer Auto Configuration
|
||||||
|
|
||||||
Provides a OpenTelemetry tracer bean (`io.opentelemetry.api.trace.Tracer`) if one does not exist in the application context of the spring project. This tracer bean will be used in all configurations listed below. Feel free to declare your own Opentelemetry tracer bean to overwrite this configuration.
|
Provides a OpenTelemetry tracer bean (`io.opentelemetry.api.trace.Tracer`) if one does not exist in the application context of the spring project. This tracer bean will be used in all configurations listed below. Feel free to declare your own OpenTelemetry tracer bean to overwrite this configuration.
|
||||||
|
|
||||||
#### Spring Web Auto Configuration
|
#### Spring Web Auto Configuration
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue