Skip to content

Commit e437c3d

Browse files
committed
Make LettuceObservationContext public to use it with Observation Predicates.
Close #2550
1 parent 36c08ae commit e437c3d

File tree

3 files changed

+12
-12
lines changed

3 files changed

+12
-12
lines changed

src/main/java/org/springframework/data/redis/connection/lettuce/observability/LettuceObservationContext.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,21 +15,21 @@
1515
*/
1616
package org.springframework.data.redis.connection.lettuce.observability;
1717

18-
import org.springframework.lang.Nullable;
19-
2018
import io.lettuce.core.protocol.RedisCommand;
2119
import io.lettuce.core.tracing.Tracing.Endpoint;
2220
import io.micrometer.observation.Observation;
2321
import io.micrometer.observation.transport.Kind;
2422
import io.micrometer.observation.transport.SenderContext;
2523

24+
import org.springframework.lang.Nullable;
25+
2626
/**
2727
* Micrometer {@link Observation.Context} holding Lettuce contextual details.
2828
*
2929
* @author Mark Paluch
3030
* @since 3.0
3131
*/
32-
class LettuceObservationContext extends SenderContext<Object> {
32+
public class LettuceObservationContext extends SenderContext<Object> {
3333

3434
private volatile @Nullable RedisCommand<?, ?, ?> command;
3535

src/main/java/org/springframework/data/redis/connection/lettuce/observability/MicrometerTracingAdapter.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -15,13 +15,6 @@
1515
*/
1616
package org.springframework.data.redis.connection.lettuce.observability;
1717

18-
import java.net.SocketAddress;
19-
20-
import org.apache.commons.logging.Log;
21-
import org.apache.commons.logging.LogFactory;
22-
import org.springframework.data.redis.connection.lettuce.observability.RedisObservation.HighCardinalityCommandKeyNames;
23-
import org.springframework.lang.Nullable;
24-
2518
import io.lettuce.core.protocol.CompleteableCommand;
2619
import io.lettuce.core.protocol.RedisCommand;
2720
import io.lettuce.core.tracing.TraceContext;
@@ -35,6 +28,13 @@
3528
import io.micrometer.observation.contextpropagation.ObservationThreadLocalAccessor;
3629
import reactor.core.publisher.Mono;
3730

31+
import java.net.SocketAddress;
32+
33+
import org.apache.commons.logging.Log;
34+
import org.apache.commons.logging.LogFactory;
35+
import org.springframework.data.redis.connection.lettuce.observability.RedisObservation.HighCardinalityCommandKeyNames;
36+
import org.springframework.lang.Nullable;
37+
3838
/**
3939
* {@link Tracing} adapter using Micrometer's {@link Observation}. This adapter integrates with Micrometer to propagate
4040
* observations into timers, distributed traces and any other registered handlers. Observations include a set of tags
@@ -111,7 +111,7 @@ public Endpoint createEndpoint(SocketAddress socketAddress) {
111111
/**
112112
* {@link Tracer} implementation based on Micrometer's {@link ObservationRegistry}.
113113
*/
114-
class MicrometerTracer extends Tracer {
114+
public class MicrometerTracer extends Tracer {
115115

116116
private final ObservationRegistry observationRegistry;
117117

src/main/java/org/springframework/data/redis/connection/lettuce/observability/RedisObservation.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
* @author Mark Paluch
2525
* @since 3.0
2626
*/
27-
enum RedisObservation implements ObservationDocumentation {
27+
public enum RedisObservation implements ObservationDocumentation {
2828

2929
/**
3030
* Timer created around a Redis command execution.

0 commit comments

Comments
 (0)