Rename method, use Telemetry instead of Metrics (#13574)
This commit is contained in:
parent
e8ed4e2075
commit
e207579370
|
@ -61,7 +61,7 @@ public final class DefaultHttpClientInstrumenterBuilder<REQUEST, RESPONSE> {
|
|||
@Nullable private final TextMapSetter<REQUEST> headerSetter;
|
||||
private Function<SpanNameExtractor<REQUEST>, ? extends SpanNameExtractor<REQUEST>>
|
||||
spanNameExtractorTransformer = Function.identity();
|
||||
private boolean emitExperimentalHttpClientMetrics = false;
|
||||
private boolean emitExperimentalHttpClientTelemetry = false;
|
||||
private Consumer<InstrumenterBuilder<REQUEST, RESPONSE>> builderCustomizer = b -> {};
|
||||
|
||||
private DefaultHttpClientInstrumenterBuilder(
|
||||
|
@ -162,15 +162,15 @@ public final class DefaultHttpClientInstrumenterBuilder<REQUEST, RESPONSE> {
|
|||
}
|
||||
|
||||
/**
|
||||
* Configures the instrumentation to emit experimental HTTP client metrics.
|
||||
* Configures the instrumentation to emit experimental HTTP client telemetry.
|
||||
*
|
||||
* @param emitExperimentalHttpClientMetrics {@code true} if the experimental HTTP client metrics
|
||||
* are to be emitted.
|
||||
* @param emitExperimentalHttpClientTelemetry {@code true} if the experimental HTTP client
|
||||
* telemetry is to be emitted.
|
||||
*/
|
||||
@CanIgnoreReturnValue
|
||||
public DefaultHttpClientInstrumenterBuilder<REQUEST, RESPONSE>
|
||||
setEmitExperimentalHttpClientMetrics(boolean emitExperimentalHttpClientMetrics) {
|
||||
this.emitExperimentalHttpClientMetrics = emitExperimentalHttpClientMetrics;
|
||||
setEmitExperimentalHttpClientTelemetry(boolean emitExperimentalHttpClientTelemetry) {
|
||||
this.emitExperimentalHttpClientTelemetry = emitExperimentalHttpClientTelemetry;
|
||||
return this;
|
||||
}
|
||||
|
||||
|
@ -229,7 +229,7 @@ public final class DefaultHttpClientInstrumenterBuilder<REQUEST, RESPONSE> {
|
|||
.addAttributesExtractor(httpAttributesExtractorBuilder.build())
|
||||
.addAttributesExtractors(additionalExtractors)
|
||||
.addOperationMetrics(HttpClientMetrics.get());
|
||||
if (emitExperimentalHttpClientMetrics) {
|
||||
if (emitExperimentalHttpClientTelemetry) {
|
||||
builder
|
||||
.addAttributesExtractor(HttpExperimentalAttributesExtractor.create(attributesGetter))
|
||||
.addOperationMetrics(HttpClientExperimentalMetrics.get());
|
||||
|
@ -257,7 +257,7 @@ public final class DefaultHttpClientInstrumenterBuilder<REQUEST, RESPONSE> {
|
|||
set(config::getPeerServiceResolver, this::setPeerServiceResolver);
|
||||
set(
|
||||
config::shouldEmitExperimentalHttpClientTelemetry,
|
||||
this::setEmitExperimentalHttpClientMetrics);
|
||||
this::setEmitExperimentalHttpClientTelemetry);
|
||||
set(config::redactQueryParameters, this::setRedactQueryParameters);
|
||||
return this;
|
||||
}
|
||||
|
|
|
@ -57,7 +57,7 @@ public final class DefaultHttpServerInstrumenterBuilder<REQUEST, RESPONSE> {
|
|||
spanNameExtractorTransformer = Function.identity();
|
||||
private final HttpServerRouteBuilder<REQUEST> httpServerRouteBuilder;
|
||||
private final HttpServerAttributesGetter<REQUEST, RESPONSE> attributesGetter;
|
||||
private boolean emitExperimentalHttpServerMetrics = false;
|
||||
private boolean emitExperimentalHttpServerTelemetry = false;
|
||||
private Consumer<InstrumenterBuilder<REQUEST, RESPONSE>> builderCustomizer = b -> {};
|
||||
|
||||
private DefaultHttpServerInstrumenterBuilder(
|
||||
|
@ -160,15 +160,15 @@ public final class DefaultHttpServerInstrumenterBuilder<REQUEST, RESPONSE> {
|
|||
}
|
||||
|
||||
/**
|
||||
* Configures the instrumentation to emit experimental HTTP server metrics.
|
||||
* Configures the instrumentation to emit experimental HTTP server telemetry.
|
||||
*
|
||||
* @param emitExperimentalHttpServerMetrics {@code true} if the experimental HTTP server metrics
|
||||
* are to be emitted.
|
||||
* @param emitExperimentalHttpServerTelemetry {@code true} if the experimental HTTP server
|
||||
* telemetry is to be emitted.
|
||||
*/
|
||||
@CanIgnoreReturnValue
|
||||
public DefaultHttpServerInstrumenterBuilder<REQUEST, RESPONSE>
|
||||
setEmitExperimentalHttpServerMetrics(boolean emitExperimentalHttpServerMetrics) {
|
||||
this.emitExperimentalHttpServerMetrics = emitExperimentalHttpServerMetrics;
|
||||
setEmitExperimentalHttpServerTelemetry(boolean emitExperimentalHttpServerTelemetry) {
|
||||
this.emitExperimentalHttpServerTelemetry = emitExperimentalHttpServerTelemetry;
|
||||
return this;
|
||||
}
|
||||
|
||||
|
@ -210,7 +210,7 @@ public final class DefaultHttpServerInstrumenterBuilder<REQUEST, RESPONSE> {
|
|||
.addAttributesExtractors(additionalExtractors)
|
||||
.addContextCustomizer(httpServerRouteBuilder.build())
|
||||
.addOperationMetrics(HttpServerMetrics.get());
|
||||
if (emitExperimentalHttpServerMetrics) {
|
||||
if (emitExperimentalHttpServerTelemetry) {
|
||||
builder
|
||||
.addAttributesExtractor(HttpExperimentalAttributesExtractor.create(attributesGetter))
|
||||
.addOperationMetrics(HttpServerExperimentalMetrics.get());
|
||||
|
@ -226,7 +226,7 @@ public final class DefaultHttpServerInstrumenterBuilder<REQUEST, RESPONSE> {
|
|||
set(config::getServerResponseHeaders, this::setCapturedResponseHeaders);
|
||||
set(
|
||||
config::shouldEmitExperimentalHttpServerTelemetry,
|
||||
this::setEmitExperimentalHttpServerMetrics);
|
||||
this::setEmitExperimentalHttpServerTelemetry);
|
||||
return this;
|
||||
}
|
||||
|
||||
|
|
|
@ -25,7 +25,7 @@ public final class ApacheHttpClientTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
ApacheHttpClientTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -25,7 +25,7 @@ public final class ApacheHttpClientTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
ApacheHttpClientTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -27,7 +27,7 @@ public final class ArmeriaClientTelemetryBuilder {
|
|||
static {
|
||||
ArmeriaInstrumenterBuilderUtil.setClientBuilderExtractor(builder -> builder.builder);
|
||||
Experimental.internalSetEmitExperimentalClientTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
Experimental.internalSetClientPeerService(
|
||||
(builder, peerService) -> builder.builder.setPeerService(peerService));
|
||||
}
|
||||
|
|
|
@ -27,7 +27,7 @@ public final class ArmeriaServerTelemetryBuilder {
|
|||
static {
|
||||
ArmeriaInstrumenterBuilderUtil.setServerBuilderExtractor(builder -> builder.builder);
|
||||
Experimental.internalSetEmitExperimentalServerTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerTelemetry(emit));
|
||||
}
|
||||
|
||||
ArmeriaServerTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -26,7 +26,7 @@ public final class JavaHttpClientTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
JavaHttpClientTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -27,7 +27,7 @@ public final class JavaHttpServerTelemetryBuilder {
|
|||
static {
|
||||
JavaHttpServerInstrumenterBuilderUtil.setServerBuilderExtractor(builder -> builder.builder);
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerTelemetry(emit));
|
||||
}
|
||||
|
||||
JavaHttpServerTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -28,7 +28,7 @@ public final class JettyClientTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
JettyClientTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -29,7 +29,7 @@ public final class JettyClientTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
JettyClientTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -12,11 +12,11 @@ class Experimental private constructor() {
|
|||
|
||||
companion object {
|
||||
fun emitExperimentalTelemetry(builder: AbstractKtorClientTelemetryBuilder) {
|
||||
builder.builder().setEmitExperimentalHttpClientMetrics(true)
|
||||
builder.builder().setEmitExperimentalHttpClientTelemetry(true)
|
||||
}
|
||||
|
||||
fun emitExperimentalTelemetry(builder: AbstractKtorServerTelemetryBuilder) {
|
||||
builder.builder.setEmitExperimentalHttpServerMetrics(true)
|
||||
builder.builder.setEmitExperimentalHttpServerTelemetry(true)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -29,7 +29,7 @@ public final class NettyClientTelemetryBuilder {
|
|||
static {
|
||||
Experimental.internalSetEmitExperimentalClientTelemetry(
|
||||
(builder, emit) -> {
|
||||
builder.builder.setEmitExperimentalHttpClientMetrics(emit);
|
||||
builder.builder.setEmitExperimentalHttpClientTelemetry(emit);
|
||||
builder.emitExperimentalHttpClientEvents = emit;
|
||||
});
|
||||
}
|
||||
|
@ -117,7 +117,7 @@ public final class NettyClientTelemetryBuilder {
|
|||
@CanIgnoreReturnValue
|
||||
public NettyClientTelemetryBuilder setEmitExperimentalHttpClientMetrics(
|
||||
boolean emitExperimentalHttpClientMetrics) {
|
||||
builder.setEmitExperimentalHttpClientMetrics(emitExperimentalHttpClientMetrics);
|
||||
builder.setEmitExperimentalHttpClientTelemetry(emitExperimentalHttpClientMetrics);
|
||||
return this;
|
||||
}
|
||||
|
||||
|
|
|
@ -30,7 +30,7 @@ public final class NettyServerTelemetryBuilder {
|
|||
nettyServerTelemetryBuilder -> nettyServerTelemetryBuilder.builder);
|
||||
Experimental.internalSetEmitExperimentalServerTelemetry(
|
||||
(builder, emit) -> {
|
||||
builder.builder.setEmitExperimentalHttpServerMetrics(emit);
|
||||
builder.builder.setEmitExperimentalHttpServerTelemetry(emit);
|
||||
builder.emitExperimentalHttpServerEvents = emit;
|
||||
});
|
||||
}
|
||||
|
@ -111,7 +111,7 @@ public final class NettyServerTelemetryBuilder {
|
|||
@CanIgnoreReturnValue
|
||||
public NettyServerTelemetryBuilder setEmitExperimentalHttpServerMetrics(
|
||||
boolean emitExperimentalHttpServerMetrics) {
|
||||
builder.setEmitExperimentalHttpServerMetrics(emitExperimentalHttpServerMetrics);
|
||||
builder.setEmitExperimentalHttpServerTelemetry(emitExperimentalHttpServerMetrics);
|
||||
return this;
|
||||
}
|
||||
|
||||
|
|
|
@ -26,7 +26,7 @@ public final class OkHttpTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
OkHttpTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -27,7 +27,7 @@ public final class RatpackClientTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalClientTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
RatpackClientTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -27,7 +27,7 @@ public final class RatpackServerTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalServerTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerTelemetry(emit));
|
||||
}
|
||||
|
||||
RatpackServerTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -25,7 +25,7 @@ public final class RestletTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerTelemetry(emit));
|
||||
}
|
||||
|
||||
RestletTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
@ -96,7 +96,7 @@ public final class RestletTelemetryBuilder {
|
|||
@CanIgnoreReturnValue
|
||||
public RestletTelemetryBuilder setEmitExperimentalHttpServerMetrics(
|
||||
boolean emitExperimentalHttpServerMetrics) {
|
||||
builder.setEmitExperimentalHttpServerMetrics(emitExperimentalHttpServerMetrics);
|
||||
builder.setEmitExperimentalHttpServerTelemetry(emitExperimentalHttpServerMetrics);
|
||||
return this;
|
||||
}
|
||||
|
||||
|
|
|
@ -25,7 +25,7 @@ public final class RestletTelemetryBuilder {
|
|||
|
||||
static {
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerTelemetry(emit));
|
||||
}
|
||||
|
||||
RestletTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
@ -96,7 +96,7 @@ public final class RestletTelemetryBuilder {
|
|||
@CanIgnoreReturnValue
|
||||
public RestletTelemetryBuilder setEmitExperimentalHttpServerMetrics(
|
||||
boolean emitExperimentalHttpServerMetrics) {
|
||||
builder.setEmitExperimentalHttpServerMetrics(emitExperimentalHttpServerMetrics);
|
||||
builder.setEmitExperimentalHttpServerTelemetry(emitExperimentalHttpServerMetrics);
|
||||
return this;
|
||||
}
|
||||
|
||||
|
|
|
@ -26,7 +26,7 @@ public final class SpringWebTelemetryBuilder {
|
|||
static {
|
||||
WebTelemetryUtil.setBuilderExtractor(SpringWebTelemetryBuilder::getBuilder);
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
SpringWebTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
@ -129,7 +129,7 @@ public final class SpringWebTelemetryBuilder {
|
|||
@CanIgnoreReturnValue
|
||||
public SpringWebTelemetryBuilder setEmitExperimentalHttpClientMetrics(
|
||||
boolean emitExperimentalHttpClientMetrics) {
|
||||
builder.setEmitExperimentalHttpClientMetrics(emitExperimentalHttpClientMetrics);
|
||||
builder.setEmitExperimentalHttpClientTelemetry(emitExperimentalHttpClientMetrics);
|
||||
return this;
|
||||
}
|
||||
|
||||
|
|
|
@ -29,7 +29,7 @@ public final class SpringWebfluxClientTelemetryBuilder {
|
|||
static {
|
||||
SpringWebfluxBuilderUtil.setClientBuilderExtractor(builder -> builder.builder);
|
||||
Experimental.internalSetEmitExperimentalClientTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpClientTelemetry(emit));
|
||||
}
|
||||
|
||||
SpringWebfluxClientTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -26,7 +26,7 @@ public final class SpringWebfluxServerTelemetryBuilder {
|
|||
static {
|
||||
SpringWebfluxBuilderUtil.setServerBuilderExtractor(builder -> builder.builder);
|
||||
Experimental.internalSetEmitExperimentalServerTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerTelemetry(emit));
|
||||
}
|
||||
|
||||
SpringWebfluxServerTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
|
|
@ -29,7 +29,7 @@ public final class SpringWebMvcTelemetryBuilder {
|
|||
static {
|
||||
SpringMvcBuilderUtil.setBuilderExtractor(builder -> builder.builder);
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerTelemetry(emit));
|
||||
}
|
||||
|
||||
SpringWebMvcTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
@ -115,7 +115,7 @@ public final class SpringWebMvcTelemetryBuilder {
|
|||
@CanIgnoreReturnValue
|
||||
public SpringWebMvcTelemetryBuilder setEmitExperimentalHttpServerMetrics(
|
||||
boolean emitExperimentalHttpServerMetrics) {
|
||||
builder.setEmitExperimentalHttpServerMetrics(emitExperimentalHttpServerMetrics);
|
||||
builder.setEmitExperimentalHttpServerTelemetry(emitExperimentalHttpServerMetrics);
|
||||
return this;
|
||||
}
|
||||
|
||||
|
|
|
@ -28,7 +28,7 @@ public final class SpringWebMvcTelemetryBuilder {
|
|||
static {
|
||||
SpringMvcBuilderUtil.setBuilderExtractor(builder -> builder.builder);
|
||||
Experimental.internalSetEmitExperimentalTelemetry(
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerMetrics(emit));
|
||||
(builder, emit) -> builder.builder.setEmitExperimentalHttpServerTelemetry(emit));
|
||||
}
|
||||
|
||||
SpringWebMvcTelemetryBuilder(OpenTelemetry openTelemetry) {
|
||||
|
@ -114,7 +114,7 @@ public final class SpringWebMvcTelemetryBuilder {
|
|||
@CanIgnoreReturnValue
|
||||
public SpringWebMvcTelemetryBuilder setEmitExperimentalHttpServerMetrics(
|
||||
boolean emitExperimentalHttpServerMetrics) {
|
||||
builder.setEmitExperimentalHttpServerMetrics(emitExperimentalHttpServerMetrics);
|
||||
builder.setEmitExperimentalHttpServerTelemetry(emitExperimentalHttpServerMetrics);
|
||||
return this;
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue