Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Make LettuceObservationContext public to use it with Observation Predicates.

Browse Source 
Close #2550
This commit is contained in:
Mark Paluch
2023-05-09 15:13:28 +02:00
parent 5e2b668dcc
commit 5e8f73a00a
3 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -15,21 +15,21 @@
*/
package org.springframework.data.redis.connection.lettuce.observability;
import org.springframework.lang.Nullable;
import io.lettuce.core.protocol.RedisCommand;
import io.lettuce.core.tracing.Tracing.Endpoint;
import io.micrometer.observation.Observation;
import io.micrometer.observation.transport.Kind;
import io.micrometer.observation.transport.SenderContext;
import org.springframework.lang.Nullable;
/**
* Micrometer {@link Observation.Context} holding Lettuce contextual details.
*
* @author Mark Paluch
* @since 3.0
*/
class LettuceObservationContext extends SenderContext<Object> {
public class LettuceObservationContext extends SenderContext<Object> {
private volatile @Nullable RedisCommand<?, ?, ?> command;

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

@@ -15,13 +15,6 @@
*/
package org.springframework.data.redis.connection.lettuce.observability;
import java.net.SocketAddress;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.data.redis.connection.lettuce.observability.RedisObservation.HighCardinalityCommandKeyNames;
import org.springframework.lang.Nullable;
import io.lettuce.core.protocol.CompleteableCommand;
import io.lettuce.core.protocol.RedisCommand;
import io.lettuce.core.tracing.TraceContext;
@@ -35,6 +28,13 @@ import io.micrometer.observation.ObservationRegistry;
import io.micrometer.observation.contextpropagation.ObservationThreadLocalAccessor;
import reactor.core.publisher.Mono;
import java.net.SocketAddress;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.data.redis.connection.lettuce.observability.RedisObservation.HighCardinalityCommandKeyNames;
import org.springframework.lang.Nullable;
/**
* {@link Tracing} adapter using Micrometer's {@link Observation}. This adapter integrates with Micrometer to propagate
* observations into timers, distributed traces and any other registered handlers. Observations include a set of tags
@@ -111,7 +111,7 @@ public class MicrometerTracingAdapter implements Tracing {
/**
* {@link Tracer} implementation based on Micrometer's {@link ObservationRegistry}.
*/
class MicrometerTracer extends Tracer {
public class MicrometerTracer extends Tracer {
private final ObservationRegistry observationRegistry;

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

@@ -24,7 +24,7 @@ import io.micrometer.observation.docs.ObservationDocumentation;
* @author Mark Paluch
* @since 3.0
*/
enum RedisObservation implements ObservationDocumentation {
public enum RedisObservation implements ObservationDocumentation {
/**
* Timer created around a Redis command execution.