redis

package
v0.0.0-...-e272627 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 21, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL