redis

Documentation

Index

• func New(opts ...Option) (*redis.Client, error)
• func NewClient(conf *Config, hooks ...redis.Hook) (*redis.Client, error)
• func NewHook(tracer opentracing.Tracer) redis.Hook
• type Config
• type Option
  • func WithAddr(addr string) Option
  • func WithDB(db int) Option
  • func WithMaxConnTime(duration time.Duration) Option
  • func WithMinIdleConn(conn int) Option
  • func WithMinIdleTime(duration time.Duration) Option
  • func WithPassWord(password string) Option
  • func WithPoolSize(size int) Option
  • func WithTrace(tracer opentracing.Tracer) Option
  • func WithUserName(username string) Option
• 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 New

func New(opts ...Option) (*redis.Client, error)

func NewClient

func NewClient(conf *Config, hooks ...redis.Hook) (*redis.Client, error)

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 Config

type Config struct {
	Addr        string
	UserName    string
	PassWord    string
	DB          int
	PoolSize    int
	MinIdleConn int
	MinIdleTime time.Duration
	MaxConnTime time.Duration
	Tracer      opentracing.Tracer
}

type Option

type Option func(*Config)

func WithAddr

func WithAddr(addr string) Option

func WithDB

func WithDB(db int) Option

func WithMaxConnTime

func WithMaxConnTime(duration time.Duration) Option

func WithMinIdleConn

func WithMinIdleConn(conn int) Option

func WithMinIdleTime

func WithMinIdleTime(duration time.Duration) Option

func WithPassWord

func WithPassWord(password string) Option

func WithPoolSize

func WithPoolSize(size int) Option

func WithTrace

func WithTrace(tracer opentracing.Tracer) Option

func WithUserName

func WithUserName(username string) Option

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)

func (RedisTracingHook) BeforeProcessPipeline

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