v3

Documentation

Index

• Variables
• type Client
  • func NewClient(addr string, opts ...Option) (Client, error)
• type Option
  • func WithDialTimeout(dialTimeout time.Duration) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMaxRetries(maxRetries int) Option
  • func WithMetrics(r metrics.Registerer) Option
  • func WithMinIdleConns(minIdleConns int) Option
  • func WithPassword(password string) Option
  • func WithPoolSize(poolSize int) Option
  • func WithPoolTimeout(poolTimeout time.Duration) Option
  • func WithServerName(serverName string) Option
• type PipeClient

Variables

var (
	ErrNil         = goredis.Nil
	ErrInvalidType = errors.New("redis: invalid type")
)

Types

type Client

type Client interface {
	Close() error
	Check(context.Context) health.Status
	Stats() redis.PoolStats
	Scan(cursor uint64, key string, count int64) (uint64, []string, error)
	Get(key string) ([]byte, error)
	GetMulti(keys []string) ([]interface{}, error)
	Set(key string, val interface{}, expiration time.Duration) error
	PFAdd(key string, els ...string) (int64, error)
	PFCount(keys ...string) (int64, error)
	PFMerge(dest string, keys ...string) error
	IncrByFloat(key string, value float64) (float64, error)
	Del(key string) error
	Incr(key string) (int64, error)
	Pipeline() PipeClient
	Expire(key string, expiration time.Duration) (bool, error)
}

func NewClient

func NewClient(addr string, opts ...Option) (Client, error)

type Option

type Option func(*options)

func WithDialTimeout

func WithDialTimeout(dialTimeout time.Duration) Option

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMaxRetries

func WithMaxRetries(maxRetries int) Option

func WithMetrics

func WithMetrics(r metrics.Registerer) Option

func WithMinIdleConns

func WithMinIdleConns(minIdleConns int) Option

func WithPassword

func WithPassword(password string) Option

func WithPoolSize

func WithPoolSize(poolSize int) Option

func WithPoolTimeout

func WithPoolTimeout(poolTimeout time.Duration) Option

func WithServerName

func WithServerName(serverName string) Option

type PipeClient

type PipeClient interface {
	PFAdd(key string, els ...string) *goredis.IntCmd
	Incr(key string) *goredis.IntCmd
	TTL(key string) *goredis.DurationCmd
	Exec() ([]goredis.Cmder, error)
	PFCount(keys ...string) *goredis.IntCmd
	Get(key string) *goredis.StringCmd
	Del(keys string) *goredis.IntCmd
}