redis_cluster

package

v0.0.0-...-b08fcc5 Latest Latest Go to latest Published: Jun 22, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Nbyete/common

Documentation ¶

Index ¶

func NewConnected(srvName string, confName string) (client *redis.ClusterClient, err error)
type RedisConf
type TracingHook
- func NewTracingHook(opt redisOpt, redisLog *loggers.Logger, redisSlowLog *loggers.Logger) *TracingHook

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewConnected ¶

func NewConnected(srvName string, confName string) (client *redis.ClusterClient, err error)

NewConnected redis cluster client

Types ¶

type RedisConf ¶

type RedisConf struct {
	Addrs        []string
	MaxRetries   int
	PoolSize     int
	MinIdleConns int
	DialTimeout  string
	ReadTimeout  string
	WriteTimeout string
	MaxConnAge   string
	Tls          bool
}

type TracingHook ¶

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

func NewTracingHook ¶

func NewTracingHook(opt redisOpt, redisLog *loggers.Logger, redisSlowLog *loggers.Logger) *TracingHook

func (*TracingHook) AfterProcess ¶

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

AfterProcess 执行后

func (*TracingHook) AfterProcessPipeline ¶

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

AfterProcessPipeline 后处理管道

func (*TracingHook) BeforeProcess ¶

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

BeforeProcess 执行前

func (*TracingHook) BeforeProcessPipeline ¶

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

BeforeProcessPipeline 流水线前

func (*TracingHook) StartSpanFromContext ¶

func (hook *TracingHook) StartSpanFromContext(ctx context.Context, cmd redis.Cmder, cmdList []redis.Cmder) context.Context

Source Files ¶

View all Source files

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