|
39 | 39 |
|
40 | 40 | import static java.util.Objects.requireNonNull; |
41 | 41 |
|
| 42 | +/** Tracer implementation using OpenTelemetry. */ |
42 | 43 | public class OpenTelemetryTracer extends BaseTracer { |
43 | | - private final io.opentelemetry.api.trace.Tracer tracer; |
44 | | - private final OpenTelemetry openTelemetry; |
45 | | - |
46 | | - public OpenTelemetryTracer(final OpenTelemetry openTelemetry) { |
47 | | - this.openTelemetry = openTelemetry; |
48 | | - this.tracer = openTelemetry.getTracer("github-java-client"); |
49 | | - |
50 | | - } |
51 | | - |
52 | | - public OpenTelemetryTracer() { |
53 | | - this(GlobalOpenTelemetry.get()); |
54 | | - } |
55 | | - |
56 | | - @SuppressWarnings("MustBeClosedChecker") |
57 | | - protected Span internalSpan( |
58 | | - final String path, |
59 | | - final String method, |
60 | | - final CompletionStage<?> future) { |
61 | | - requireNonNull(path); |
62 | | - |
63 | | - Context context = Context.current(); |
64 | | - |
65 | | - final io.opentelemetry.api.trace.Span otSpan = |
66 | | - tracer.spanBuilder("GitHub Request") |
67 | | - .setParent(context) |
68 | | - .setSpanKind(SpanKind.CLIENT).startSpan(); |
69 | | - |
70 | | - otSpan.setAttribute("component", "github-api-client"); |
71 | | - otSpan.setAttribute("peer.service", "github"); |
72 | | - otSpan.setAttribute("http.url", path); |
73 | | - otSpan.setAttribute("method", method); |
74 | | - final Span span = new OpenTelemetrySpan(otSpan); |
75 | | - |
76 | | - if (future == null) { |
77 | | - return span; |
78 | | - } else { |
79 | | - attachSpanToFuture(span, future); |
80 | | - } |
81 | | - return span; |
82 | | - } |
83 | | - |
84 | | - @Override |
85 | | - protected Span internalSpan(final Request request, final CompletionStage<?> future) { |
86 | | - requireNonNull(request); |
87 | | - Context context = W3CTraceContextPropagator.getInstance().extract(Context.current(), request, new TextMapGetter<>() { |
88 | | - @Override |
89 | | - public Iterable<String> keys(@NotNull final Request carrier) { |
90 | | - return carrier.headers().names(); |
91 | | - } |
92 | | - |
93 | | - @Nullable |
94 | | - @Override |
95 | | - public String get(@Nullable final Request carrier, @NotNull final String key) { |
96 | | - if (carrier == null) { |
97 | | - return null; |
98 | | - } |
99 | | - return carrier.header(key); |
100 | | - } |
101 | | - }); |
102 | | - context.makeCurrent(); |
103 | | - return internalSpan(request.url().toString(), request.method(), future); |
104 | | - } |
105 | | - |
106 | | - @Override |
107 | | - public Call.Factory createTracedClient(final OkHttpClient client) { |
108 | | - return OkHttpTelemetry.builder(openTelemetry).build().newCallFactory(client); |
| 44 | + private final io.opentelemetry.api.trace.Tracer tracer; |
| 45 | + private final OpenTelemetry openTelemetry; |
| 46 | + |
| 47 | + public OpenTelemetryTracer(final OpenTelemetry openTelemetry) { |
| 48 | + this.openTelemetry = openTelemetry; |
| 49 | + this.tracer = openTelemetry.getTracer("github-java-client"); |
| 50 | + } |
| 51 | + |
| 52 | + public OpenTelemetryTracer() { |
| 53 | + this(GlobalOpenTelemetry.get()); |
| 54 | + } |
| 55 | + |
| 56 | + /** |
| 57 | + * Create a new span for the given path and method. |
| 58 | + * |
| 59 | + * @param path The path of the request. |
| 60 | + * @param method The method of the request. |
| 61 | + * @param future The future to attach the span to. |
| 62 | + * @return The created span. |
| 63 | + */ |
| 64 | + @SuppressWarnings("MustBeClosedChecker") |
| 65 | + protected Span internalSpan( |
| 66 | + final String path, final String method, final CompletionStage<?> future) { |
| 67 | + requireNonNull(path); |
| 68 | + |
| 69 | + Context context = Context.current(); |
| 70 | + |
| 71 | + final io.opentelemetry.api.trace.Span otSpan = |
| 72 | + tracer |
| 73 | + .spanBuilder("GitHub Request") |
| 74 | + .setParent(context) |
| 75 | + .setSpanKind(SpanKind.CLIENT) |
| 76 | + .startSpan(); |
| 77 | + |
| 78 | + otSpan.setAttribute("component", "github-api-client"); |
| 79 | + otSpan.setAttribute("peer.service", "github"); |
| 80 | + otSpan.setAttribute("http.url", path); |
| 81 | + otSpan.setAttribute("method", method); |
| 82 | + final Span span = new OpenTelemetrySpan(otSpan); |
| 83 | + |
| 84 | + if (future == null) { |
| 85 | + return span; |
| 86 | + } else { |
| 87 | + attachSpanToFuture(span, future); |
109 | 88 | } |
| 89 | + return span; |
| 90 | + } |
| 91 | + |
| 92 | + /** |
| 93 | + * Create a new span for the given request. |
| 94 | + * |
| 95 | + * @param request The request to create a span for. |
| 96 | + * @param future The future to attach the span to. |
| 97 | + * @return The created span. |
| 98 | + */ |
| 99 | + @Override |
| 100 | + protected Span internalSpan(final Request request, final CompletionStage<?> future) { |
| 101 | + requireNonNull(request); |
| 102 | + // Extract the context from the request headers. |
| 103 | + Context context = |
| 104 | + W3CTraceContextPropagator.getInstance() |
| 105 | + .extract( |
| 106 | + Context.current(), |
| 107 | + request, |
| 108 | + new TextMapGetter<>() { |
| 109 | + @Override |
| 110 | + public Iterable<String> keys(@NotNull final Request carrier) { |
| 111 | + return carrier.headers().names(); |
| 112 | + } |
| 113 | + |
| 114 | + @Nullable |
| 115 | + @Override |
| 116 | + public String get(@Nullable final Request carrier, @NotNull final String key) { |
| 117 | + if (carrier == null) { |
| 118 | + return null; |
| 119 | + } |
| 120 | + return carrier.header(key); |
| 121 | + } |
| 122 | + }); |
| 123 | + context.makeCurrent(); |
| 124 | + return internalSpan(request.url().toString(), request.method(), future); |
| 125 | + } |
| 126 | + |
| 127 | + @Override |
| 128 | + public Call.Factory createTracedClient(final OkHttpClient client) { |
| 129 | + return OkHttpTelemetry.builder(openTelemetry).build().newCallFactory(client); |
| 130 | + } |
110 | 131 | } |
0 commit comments