rdb

Documentation

Index

• func NewClusterClient(opts *CustomOptions) *redis.ClusterClient
• type CustomOptions
• type MetricsHook
• type TracingHook
  • func (TracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (TracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (TracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (TracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

Functions

func NewClusterClient

func NewClusterClient(opts *CustomOptions) *redis.ClusterClient

NewMetricsClusterClient 创建一个带监控指标的的 redis client

Types

type CustomOptions

type CustomOptions struct {
	Password     string
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	PoolSize     int
	MinIdleConns int
	DialTimeout  time.Duration
	Addrs        []string
}

type MetricsHook

type MetricsHook struct {
}

type TracingHook

type TracingHook struct{}

func (TracingHook) AfterProcess

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

func (TracingHook) AfterProcessPipeline

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

func (TracingHook) BeforeProcess

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

func (TracingHook) BeforeProcessPipeline

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