redis

Documentation

Index

• Variables
• func New(config *Config, l *zap.Logger) (*redis.Client, func(), error)
• func WithPing(client *redis.Client)
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (x *Config) GetDb() int64
  • func (x *Config) GetDialTimeout() *durationpb.Duration
  • func (x *Config) GetHost() string
  • func (x *Config) GetIdleCheckFrequency() int64
  • func (x *Config) GetIdleTimeout() *durationpb.Duration
  • func (x *Config) GetMaxConnAge() int64
  • func (x *Config) GetMaxRetries() int64
  • func (x *Config) GetMaxRetryBackoff() int64
  • func (x *Config) GetMinIdleConns() int64
  • func (x *Config) GetMinRetryBackoff() int64
  • func (x *Config) GetPassword() string
  • func (x *Config) GetPoolSize() int64
  • func (x *Config) GetPoolTimeout() *durationpb.Duration
  • func (x *Config) GetPort() int64
  • func (x *Config) GetReadTimeout() *durationpb.Duration
  • func (x *Config) GetUsername() string
  • func (x *Config) GetWriteTimeout() *durationpb.Duration
  • func (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (x *Config) String() string
• type HandlerFunc

Variables

var File_component_redis_redis_proto protoreflect.FileDescriptor

Functions

func New

func New(config *Config, l *zap.Logger) (*redis.Client, func(), error)

New 创建 redis 客户端

func WithPing

func WithPing(client *redis.Client)

Types

type Config

type Config struct {
	Host               string               `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port               int64                `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Username           string               `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password           string               `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	Db                 int64                `protobuf:"varint,5,opt,name=db,proto3" json:"db,omitempty"`
	MaxRetries         int64                `protobuf:"varint,6,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	MinRetryBackoff    int64                `protobuf:"varint,7,opt,name=min_retry_backoff,json=minRetryBackoff,proto3" json:"min_retry_backoff,omitempty"`
	MaxRetryBackoff    int64                `protobuf:"varint,8,opt,name=max_retry_backoff,json=maxRetryBackoff,proto3" json:"max_retry_backoff,omitempty"`
	DialTimeout        *durationpb.Duration `protobuf:"bytes,9,opt,name=dial_timeout,json=dialTimeout,proto3" json:"dial_timeout,omitempty"`
	ReadTimeout        *durationpb.Duration `protobuf:"bytes,10,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`
	WriteTimeout       *durationpb.Duration `protobuf:"bytes,11,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"`
	PoolSize           int64                `protobuf:"varint,12,opt,name=pool_size,json=poolSize,proto3" json:"pool_size,omitempty"`
	MinIdleConns       int64                `protobuf:"varint,13,opt,name=min_idle_conns,json=minIdleConns,proto3" json:"min_idle_conns,omitempty"`
	MaxConnAge         int64                `protobuf:"varint,14,opt,name=max_conn_age,json=maxConnAge,proto3" json:"max_conn_age,omitempty"`
	PoolTimeout        *durationpb.Duration `protobuf:"bytes,15,opt,name=pool_timeout,json=poolTimeout,proto3" json:"pool_timeout,omitempty"`
	IdleTimeout        *durationpb.Duration `protobuf:"bytes,16,opt,name=idle_timeout,json=idleTimeout,proto3" json:"idle_timeout,omitempty"`
	IdleCheckFrequency int64                `protobuf:"varint,17,opt,name=idle_check_frequency,json=idleCheckFrequency,proto3" json:"idle_check_frequency,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) Descriptor

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetDb

func (x *Config) GetDb() int64

func (*Config) GetDialTimeout

func (x *Config) GetDialTimeout() *durationpb.Duration

func (*Config) GetHost

func (x *Config) GetHost() string

func (*Config) GetIdleCheckFrequency

func (x *Config) GetIdleCheckFrequency() int64

func (*Config) GetIdleTimeout

func (x *Config) GetIdleTimeout() *durationpb.Duration

func (*Config) GetMaxConnAge

func (x *Config) GetMaxConnAge() int64

func (*Config) GetMaxRetries

func (x *Config) GetMaxRetries() int64

func (*Config) GetMaxRetryBackoff

func (x *Config) GetMaxRetryBackoff() int64

func (*Config) GetMinIdleConns

func (x *Config) GetMinIdleConns() int64

func (*Config) GetMinRetryBackoff

func (x *Config) GetMinRetryBackoff() int64

func (*Config) GetPassword

func (x *Config) GetPassword() string

func (*Config) GetPoolSize

func (x *Config) GetPoolSize() int64

func (*Config) GetPoolTimeout

func (x *Config) GetPoolTimeout() *durationpb.Duration

func (*Config) GetPort

func (x *Config) GetPort() int64

func (*Config) GetReadTimeout

func (x *Config) GetReadTimeout() *durationpb.Duration

func (*Config) GetUsername

func (x *Config) GetUsername() string

func (*Config) GetWriteTimeout

func (x *Config) GetWriteTimeout() *durationpb.Duration

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string

type HandlerFunc

type HandlerFunc func(*redis.Client)