redis_v8

Documentation

Index

• type Option
  • func WithDB(db int) Option
• type TracingHook
  • func NewTracingHook(tracer aitracer.Tracer, addr string, opts ...Option) *TracingHook
  • func (th *TracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (th *TracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (th *TracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (th *TracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

Types

type Option

type Option func(*config)

func WithDB

func WithDB(db int) Option

type TracingHook

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

func NewTracingHook

func NewTracingHook(tracer aitracer.Tracer, addr string, opts ...Option) *TracingHook

NewTracingHook return a redis monitor hook.

func (*TracingHook) AfterProcess

func (th *TracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (*TracingHook) AfterProcessPipeline

func (th *TracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (*TracingHook) BeforeProcess

func (th *TracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (*TracingHook) BeforeProcessPipeline

func (th *TracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)