redis

Documentation

Index

• Variables
• func DefaultNewClient1(c *ClientConfig, cc *Config) (clt *redis.Client, err error)
• type Client
  • func (c *Client) CliFlags(name string) []cli.Flag
  • func (c *Client) Load(r *Component, name string, cfg *Config, appCfg gsf.Config, ...) (err error)
  • func (c *Client) Ref() *Component
  • func (c *Client) SetLogger(log logger.Interface)
• type ClientConfig
• type Component
  • func (c *Component) CliFlags() []cli.Flag
  • func (c *Component) Close(_ logger.Interface, _ gsf.Config) (err error)
  • func (c *Component) Init(log logger.Interface, cfg gsf.Config) error
  • func (c *Component) Run(log logger.Interface, cfg gsf.Config) error
• type Config
• type Logger
  • func (l *Logger) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (l *Logger) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (l *Logger) BeforeProcess(ctx context.Context, _ redis.Cmder) (context.Context, error)
  • func (l *Logger) BeforeProcessPipeline(ctx context.Context, _ []redis.Cmder) (context.Context, error)

Variables

var CreateClient = DefaultNewClient1

Functions

func DefaultNewClient1

func DefaultNewClient1(c *ClientConfig, cc *Config) (clt *redis.Client, err error)

Types

type Client

type Client struct {
	Client *redis.Client
	Cfg    ClientConfig
	// contains filtered or unexported fields
}

func (*Client) CliFlags

func (c *Client) CliFlags(name string) []cli.Flag

func (*Client) Load

func (c *Client) Load(r *Component, name string, cfg *Config, appCfg gsf.Config, log logger.Interface) (err error)

func (*Client) Ref

func (c *Client) Ref() *Component

func (*Client) SetLogger

func (c *Client) SetLogger(log logger.Interface)

type ClientConfig

type ClientConfig struct {
	Host       string `json:"host"         yaml:"host"`
	Pwd        string `json:"password"     yaml:"password"`
	DB         int    `json:"db"           yaml:"db"`
	MinIdleNum int    `json:"min_idle_num" yaml:"max_req_time"`
	MaxConnNum int    `json:"max_con_num"  yaml:"max_con_num"`
}

type Component

type Component struct {
	DSNPrint bool
	Cfg      Config
	Clts     map[string]*Client
}

func (*Component) CliFlags

func (c *Component) CliFlags() []cli.Flag

func (*Component) Close

func (c *Component) Close(_ logger.Interface, _ gsf.Config) (err error)

func (*Component) Init

func (c *Component) Init(log logger.Interface, cfg gsf.Config) error

func (*Component) Run

func (c *Component) Run(log logger.Interface, cfg gsf.Config) error

type Config

type Config struct {
	MaxReadTime    int `json:"max_sock_read_time"  yaml:"max_sock_read_time"`
	MaxWriteTime   int `json:"max_sock_write_time" yaml:"max_sock_write_time"`
	MaxRequestTime int `json:"max_request_time"    yaml:"max_request_time"`
	IdleCheckTime  int `json:"idle_check_time"     yaml:"idle_check_time"`
	SlowThreshold  int `json:"slow_threshold"      yaml:"slow_threshold"`
}

type Logger

type Logger struct {
	Logger logger.Interface
	// contains filtered or unexported fields
}

Logger 实现 redis.Hook 接口，用于记录 Redis 命令日志

func (*Logger) AfterProcess

func (l *Logger) AfterProcess(ctx context.Context, cmd redis.Cmder) error

AfterProcess 在命令执行完成后调用

func (*Logger) AfterProcessPipeline

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

AfterProcessPipeline 在收到流水线响应后调用

func (*Logger) BeforeProcess

func (l *Logger) BeforeProcess(ctx context.Context, _ redis.Cmder) (context.Context, error)

BeforeProcess 在命令发送到 Redis 服务器前调用

func (*Logger) BeforeProcessPipeline

func (l *Logger) BeforeProcessPipeline(ctx context.Context, _ []redis.Cmder) (context.Context, error)

BeforeProcessPipeline 在流水线命令发送前调用