|
1 | | -/* |
2 | | - * Copyright The OpenTelemetry Authors |
3 | | - * SPDX-License-Identifier: Apache-2.0 |
4 | | - */ |
5 | | - |
6 | 1 | package io.opentelemetry.instrumentation.ktor.v2_0.common.client.internal |
7 | 2 |
|
8 | 3 | import io.opentelemetry.instrumentation.ktor.v2_0.common.client.AbstractKtorClientTelemetryBuilder |
9 | | -import java.lang.reflect.InvocationTargetException |
10 | | -import java.lang.reflect.Method |
11 | | -import java.util.logging.Level |
12 | | -import java.util.logging.Logger |
13 | | - |
14 | | -/** |
15 | | - * This class is internal and experimental. Its APIs are unstable and can change at any time. Its |
16 | | - * APIs (or a version of them) may be promoted to the public stable API in the future, but no |
17 | | - * guarantees are made. |
18 | | - */ |
19 | | -class Experimental { |
| 4 | +import java.util.function.BiConsumer |
20 | 5 |
|
21 | | - companion object { |
22 | | - private val logger: Logger = Logger.getLogger(Experimental::class.java.name) |
| 6 | +class Experimental private constructor() { |
23 | 7 |
|
24 | | - private val emitExperimentalTelemetryMethod = getEmitExperimentalTelemetry() |
| 8 | + companion object { |
| 9 | + private var setEmitExperimentalTelemetry: BiConsumer<AbstractKtorClientTelemetryBuilder, Boolean>? = null |
25 | 10 |
|
26 | | - fun setEmitExperimentalTelemetry(builder: AbstractKtorClientTelemetryBuilder?, emitExperimentalTelemetry: Boolean) { |
27 | | - if (emitExperimentalTelemetryMethod != null) { |
28 | | - try { |
29 | | - emitExperimentalTelemetryMethod.invoke(builder, emitExperimentalTelemetry) |
30 | | - } catch (e: IllegalAccessException) { |
31 | | - logger.log(Level.FINE, e.message, e) |
32 | | - } catch (e: InvocationTargetException) { |
33 | | - logger.log(Level.FINE, e.message, e) |
| 11 | + fun emitExperimentalTelemetry( |
| 12 | + builder: AbstractKtorClientTelemetryBuilder |
| 13 | + ) { |
| 14 | + if (setEmitExperimentalTelemetry != null) { |
| 15 | + setEmitExperimentalTelemetry!!.accept(builder, true) |
| 16 | + } |
34 | 17 | } |
35 | | - } |
36 | | - } |
37 | 18 |
|
38 | | - private fun getEmitExperimentalTelemetry(): Method? { |
39 | | - try { |
40 | | - val method = AbstractKtorClientTelemetryBuilder::class.java.getDeclaredMethod( |
41 | | - "setEmitExperimentalHttpClientMetrics", |
42 | | - Boolean::class.javaPrimitiveType |
43 | | - ) |
44 | | - method.setAccessible(true) |
45 | | - return method |
46 | | - } catch (e: NoSuchMethodException) { |
47 | | - logger.log(Level.FINE, e.message, e) |
48 | | - return null |
49 | | - } |
| 19 | + fun setSetEmitExperimentalTelemetry( |
| 20 | + setEmitExperimentalTelemetry: BiConsumer<AbstractKtorClientTelemetryBuilder, Boolean>? |
| 21 | + ) { |
| 22 | + Companion.setEmitExperimentalTelemetry = setEmitExperimentalTelemetry |
| 23 | + } |
50 | 24 | } |
51 | | - } |
52 | 25 | } |
0 commit comments