Skip to content

Commit ef1a60f

Browse files
committed
code review updates
1 parent 5ff910b commit ef1a60f

File tree

4 files changed

+20
-80
lines changed

4 files changed

+20
-80
lines changed

instrumentation/ratpack/ratpack-1.7/library/README.md

Lines changed: 18 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
# Library Instrumentation for Ratpack version 1.7 and higher
22

3-
Provides OpenTelemetry instrumentation for [Ratpack](https://ratpack.io/), enabling HTTP client and server spans and
4-
metrics.
3+
Provides OpenTelemetry instrumentation for [Ratpack](https://ratpack.io/), enabling HTTP client and
4+
server spans and metrics.
55

66
## Quickstart
77

@@ -29,30 +29,38 @@ implementation("io.opentelemetry.instrumentation:opentelemetry-ratpack-1.7:OPENT
2929

3030
### Usage
3131

32+
The instrumentation library provides implementations for both server and client instrumentation
33+
that wrap Ratpack components.
34+
3235
```java
3336
import io.opentelemetry.api.OpenTelemetry;
3437
import io.opentelemetry.instrumentation.ratpack.v1_7.RatpackServerTelemetry;
3538
import io.opentelemetry.instrumentation.ratpack.v1_7.RatpackClientTelemetry;
3639
import ratpack.server.RatpackServer;
3740
import ratpack.http.client.HttpClient;
3841

39-
public class RatpackExample {
40-
public static void main(String[] args) throws Exception {
41-
// Get an OpenTelemetry instance
42-
OpenTelemetry openTelemetry = ...;
42+
public class RatpackConfiguration {
4343

44-
// Server instrumentation
44+
// Create a server with OpenTelemetry instrumentation
45+
public RatpackServer createTracedServer(OpenTelemetry openTelemetry) throws Exception {
4546
RatpackServerTelemetry serverTelemetry = RatpackServerTelemetry.create(openTelemetry);
46-
RatpackServer.start(server -> {
47+
return RatpackServer.start(server -> {
4748
server.registryOf(serverTelemetry::configureRegistry);
4849
server.handlers(chain ->
4950
chain.get(ctx -> ctx.render("Hello, World!"))
5051
);
5152
});
53+
}
5254

53-
// Client instrumentation
55+
// Create an instrumented HttpClient
56+
public HttpClient createTracedClient(OpenTelemetry openTelemetry) {
5457
RatpackClientTelemetry clientTelemetry = RatpackClientTelemetry.create(openTelemetry);
55-
HttpClient instrumentedHttpClient = clientTelemetry.instrument(HttpClient.of(spec -> {}));
58+
return clientTelemetry.instrument(createClient());
59+
}
60+
61+
// Configuration of the HttpClient goes here
62+
private HttpClient createClient() {
63+
return HttpClient.of(spec -> {});
5664
}
5765
}
5866
```

instrumentation/rxjava/rxjava-1.0/library/README.md

Lines changed: 0 additions & 67 deletions
This file was deleted.
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
classification: internal

instrumentation/rxjava/rxjava-3.1.1/library/README.md

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -46,9 +46,7 @@ public class RxJavaExample {
4646
// All RxJava operations will now be automatically instrumented
4747
Observable<String> observable = Observable.just("Hello", "World");
4848
Flowable<String> flowable = Flowable.just("Hello", "World");
49-
50-
observable.subscribe(System.out::println);
51-
flowable.subscribe(System.out::println);
49+
...
5250
}
5351
}
5452
```

0 commit comments

Comments
 (0)