diff --git a/pkg/client/redis/config.go b/pkg/client/redis/config.go index 47ac1fae6f..ee1739adc7 100644 --- a/pkg/client/redis/config.go +++ b/pkg/client/redis/config.go @@ -51,8 +51,6 @@ type Config struct { // Should be less than server's timeout. // Default is 5 minutes. -1 disables idle timeout check. IdleTimeout time.Duration `json:"idleTimeout" toml:"idleTimeout"` - // Enables read-only commands on slave nodes. - ReadOnly bool /****** for jupiter ******/ ReadOnMaster bool `json:"readOnMaster" toml:"readOnMaster"` diff --git a/pkg/client/redis/interceptor.go b/pkg/client/redis/interceptor.go index f0ac8b297e..4ef7464a73 100644 --- a/pkg/client/redis/interceptor.go +++ b/pkg/client/redis/interceptor.go @@ -10,7 +10,6 @@ import ( "github.com/fatih/color" "github.com/go-redis/redis/v8" "github.com/spf13/cast" - "go.opentelemetry.io/otel" "go.opentelemetry.io/otel/attribute" "go.opentelemetry.io/otel/codes" semconv "go.opentelemetry.io/otel/semconv/v1.12.0" @@ -194,11 +193,9 @@ func accessInterceptor(compName string, addr string, config *Config, logger *xlo xlog.Any("req", cmd.Args()), xlog.FieldCost(cost)) - // 开启了链路,那么就记录链路id - if config.EnableTraceInterceptor && otel.GetTracerProvider() != nil { - if traceId := xlog.GetTraceID(ctx); len(traceId) > 0 { - fields = append(fields, xlog.String("trace_id", traceId)) - } + // 记录链路id + if traceId := xlog.GetTraceID(ctx); len(traceId) > 0 { + fields = append(fields, xlog.String("trace_id", traceId)) } // error if err != nil { @@ -227,12 +224,11 @@ func accessInterceptor(compName string, addr string, config *Config, logger *xlo xlog.Any("req", cmd.Args()), xlog.FieldCost(cost)) - // 开启了链路,那么就记录链路id - if config.EnableTraceInterceptor && otel.GetTracerProvider() != nil { - if traceId := xlog.GetTraceID(ctx); len(traceId) > 0 { - fields = append(fields, xlog.String("trace_id", traceId)) - } + // 记录链路id + if traceId := xlog.GetTraceID(ctx); len(traceId) > 0 { + fields = append(fields, xlog.String("trace_id", traceId)) } + // error if err != nil { fields = append(fields, xlog.FieldErr(err)) diff --git a/pkg/client/redis/interceptor_test.go b/pkg/client/redis/interceptor_test.go index aa8ee3b93b..b9ff1a1cc3 100644 --- a/pkg/client/redis/interceptor_test.go +++ b/pkg/client/redis/interceptor_test.go @@ -2,15 +2,14 @@ package redis import ( "context" - "fmt" "testing" "time" - "github.com/go-redis/redis/v8" - "go.opentelemetry.io/otel/trace" + "github.com/douyu/jupiter/pkg/xlog" "github.com/douyu/jupiter/pkg/core/xtrace" "github.com/douyu/jupiter/pkg/core/xtrace/jaeger" + "github.com/go-redis/redis/v8" ) func Test_Interceptor(t *testing.T) { @@ -55,15 +54,7 @@ func Test_Interceptor(t *testing.T) { }) t.Run("access", func(t *testing.T) { - xtrace.SetGlobalTracer((&jaeger.Config{ - Name: "trace", - Endpoint: "localhost:6831", - Sampler: 1, - }).Build()) - - ctx, span := xtrace.NewTracer(trace.SpanKindServer).Start(context.Background(), "test", nil) - fmt.Println(span.SpanContext().TraceID()) - + ctx := xlog.SetTraceID(context.Background(), "123456") config.EnableAccessLogInterceptor = true client, _ := config.Build() diff --git a/website/docs/jupiter/6.8clientredis.md b/website/docs/jupiter/6.8clientredis.md index 242975183e..e66e8bbd7a 100644 --- a/website/docs/jupiter/6.8clientredis.md +++ b/website/docs/jupiter/6.8clientredis.md @@ -52,7 +52,7 @@ addr是dns连接包含用户名密码 `redis://127.0.0.2:6379` - 无用户名有密码写法 `redis://:password@127.0.0.2:6379` password前的`:`不可缺省 -- 有用户名有密码写法 +- 有用户名有密码写法 `redis://username:password@127.0.0.2:6379` ### RedisClusterConfig