redis_jaeger

Documentation

Index

• func NewHook(tracer opentracing.Tracer) redis.Hook
• type RedisTracingHook
  • func (hook RedisTracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (hook RedisTracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (hook RedisTracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (hook RedisTracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

Functions

func NewHook

func NewHook(tracer opentracing.Tracer) redis.Hook

NewHook creates a new go-redis hook instance and that will collect spans using the provided tracer.

Types

type RedisTracingHook

type RedisTracingHook struct {
	// contains filtered or unexported fields
}

func (RedisTracingHook) AfterProcess

func (hook RedisTracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (RedisTracingHook) AfterProcessPipeline

func (hook RedisTracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (RedisTracingHook) BeforeProcess

func (hook RedisTracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

实现hook的接口

func (RedisTracingHook) BeforeProcessPipeline

func (hook RedisTracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)