xredis

Documentation

Index

• func NewRedisClient(opts ...Option) *redis.Client
• func NewRedisClusterClient(opts ...ClusterOption) *redis.ClusterClient
• type ClusterOption
  • func WithClusterAddr(addr []string) ClusterOption
  • func WithClusterDialTimeout(d time.Duration) ClusterOption
  • func WithClusterReadTimeout(d time.Duration) ClusterOption
  • func WithClusterWriteTimeout(d time.Duration) ClusterOption
• type Config
• type Option
  • func WithAddr(addr string) Option
  • func WithDB(db int) Option
  • func WithDialTimeout(d time.Duration) Option
  • func WithReadTimeout(d time.Duration) Option
  • func WithWriteTimeout(d time.Duration) Option
• type XRedis
  • func NewXRedis(conf *Config) *XRedis
  • func (xr *XRedis) ExistEX(ctx context.Context, key string, ttl time.Duration) error
  • func (xr *XRedis) HGetXEX(ctx context.Context, key, field string, ttl time.Duration) (string, error)
  • func (xr *XRedis) HIncrByXEX(ctx context.Context, key, field string, incr int64, ttl time.Duration) error
  • func (xr *XRedis) HMGetXEX(ctx context.Context, key string, ttl time.Duration, field ...string) ([]interface{}, error)
  • func (xr *XRedis) HMIncrByEX(ctx context.Context, key string, fieldMap map[string]int64, ttl time.Duration) error
  • func (xr *XRedis) HMSetEX(ctx context.Context, key string, fieldMap map[string]interface{}, ...) error
  • func (xr *XRedis) HMSetXEX(ctx context.Context, key string, fieldMap map[string]interface{}, ...) error
  • func (xr *XRedis) IncrByXEX(ctx context.Context, key string, incr int64, ttl time.Duration) error
  • func (xr *XRedis) ZAddEX(ctx context.Context, key string, zs []*redis.Z, ttl time.Duration) error
  • func (xr *XRedis) ZAddXEX(ctx context.Context, key string, zs []*redis.Z, ttl time.Duration) error
  • func (xr *XRedis) ZRevPageByMember(ctx context.Context, key string, member interface{}, offset int64) ([]interface{}, error)
  • func (xr *XRedis) ZRevPageByMemberWithScores(ctx context.Context, key string, member interface{}, offset int64) ([]redis.Z, error)
  • func (xr *XRedis) ZRevRangeByMember(ctx context.Context, key string, member interface{}, offset int64) ([]interface{}, error)
  • func (xr *XRedis) ZRevRangeByMemberWithScores(ctx context.Context, key string, member interface{}, offset int64) ([]redis.Z, error)

Functions

func NewRedisClient

func NewRedisClient(opts ...Option) *redis.Client

func NewRedisClusterClient

func NewRedisClusterClient(opts ...ClusterOption) *redis.ClusterClient

Types

type ClusterOption

type ClusterOption func(*redis.ClusterOptions)

func WithClusterAddr

func WithClusterAddr(addr []string) ClusterOption

func WithClusterDialTimeout

func WithClusterDialTimeout(d time.Duration) ClusterOption

func WithClusterReadTimeout

func WithClusterReadTimeout(d time.Duration) ClusterOption

func WithClusterWriteTimeout

func WithClusterWriteTimeout(d time.Duration) ClusterOption

type Config

type Config struct {
	Addr         []string `yaml:"addr"`
	DB           int      `yaml:"db"`
	Type         string   `yaml:"type"`
	DialTimeout  int      `yaml:"dial_timeout"`
	ReadTimeout  int      `yaml:"read_timeout"`
	WriteTimeout int      `yaml:"write_timeout"`
}

type Option

type Option func(*redis.Options)

func WithAddr

func WithAddr(addr string) Option

func WithDB

func WithDB(db int) Option

func WithDialTimeout

func WithDialTimeout(d time.Duration) Option

func WithReadTimeout

func WithReadTimeout(d time.Duration) Option

func WithWriteTimeout

func WithWriteTimeout(d time.Duration) Option

type XRedis

type XRedis struct {
	redis.Cmdable
}

func NewXRedis

func NewXRedis(conf *Config) *XRedis

func (*XRedis) ExistEX

func (xr *XRedis) ExistEX(ctx context.Context, key string, ttl time.Duration) error

func (*XRedis) HGetXEX

func (xr *XRedis) HGetXEX(ctx context.Context, key, field string, ttl time.Duration) (string, error)

func (*XRedis) HIncrByXEX

func (xr *XRedis) HIncrByXEX(ctx context.Context, key, field string, incr int64, ttl time.Duration) error

func (*XRedis) HMGetXEX

func (xr *XRedis) HMGetXEX(ctx context.Context, key string, ttl time.Duration, field ...string) ([]interface{}, error)

func (*XRedis) HMIncrByEX

func (xr *XRedis) HMIncrByEX(ctx context.Context, key string, fieldMap map[string]int64, ttl time.Duration) error

func (*XRedis) HMSetEX

func (xr *XRedis) HMSetEX(ctx context.Context, key string, fieldMap map[string]interface{}, ttl time.Duration) error

func (*XRedis) HMSetXEX

func (xr *XRedis) HMSetXEX(ctx context.Context, key string, fieldMap map[string]interface{}, ttl time.Duration) error

func (*XRedis) IncrByXEX

func (xr *XRedis) IncrByXEX(ctx context.Context, key string, incr int64, ttl time.Duration) error

func (*XRedis) ZAddEX

func (xr *XRedis) ZAddEX(ctx context.Context, key string, zs []*redis.Z, ttl time.Duration) error

func (*XRedis) ZAddXEX

func (xr *XRedis) ZAddXEX(ctx context.Context, key string, zs []*redis.Z, ttl time.Duration) error

func (*XRedis) ZRevPageByMember

func (xr *XRedis) ZRevPageByMember(ctx context.Context, key string, member interface{}, offset int64) ([]interface{}, error)

func (*XRedis) ZRevPageByMemberWithScores

func (xr *XRedis) ZRevPageByMemberWithScores(ctx context.Context, key string, member interface{}, offset int64) ([]redis.Z, error)

func (*XRedis) ZRevRangeByMember

func (xr *XRedis) ZRevRangeByMember(ctx context.Context, key string, member interface{}, offset int64) ([]interface{}, error)

func (*XRedis) ZRevRangeByMemberWithScores

func (xr *XRedis) ZRevRangeByMemberWithScores(ctx context.Context, key string, member interface{}, offset int64) ([]redis.Z, error)