stores

package
v0.0.0-...-79e39e7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 1, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BLPop 

func BLPop(key string, val interface{}) error

func BLPopString 

func BLPopString(key string) (string, error)

func BRPop 

func BRPop(key string, val interface{}) error

func BRPopString 

func BRPopString(key string) (string, error)

func Del 

func Del(keys ...string) error

func DelPattern 

func DelPattern(pattern string) error

func Exists 

func Exists(keys ...string) bool

func Expire 

func Expire(key string, expiration time.Duration) bool

func FlushAll 

func FlushAll() error

func FlushAllAsync 

func FlushAllAsync() error

func FlushDB 

func FlushDB() error

func FlushDBAsync 

func FlushDBAsync() error

func Get 

func Get(key string, val interface{}) error

func GetInt 

func GetInt(key string) int

func GetString 

func GetString(key string) string

func HDel 

func HDel(key string, fields ...string) error

func HDelAll 

func HDelAll(key string)

func HExists 

func HExists(key, field string) bool

func HGet 

func HGet(key, field string, val interface{}) error

func HGetAll 

func HGetAll(key string) (map[string]string, error)

func HKeys 

func HKeys(key string) ([]string, error)

func HSet 

func HSet(key, field string, val interface{}) error

func InitStoreKeeper 

func InitStoreKeeper(cfg config.StoresConf)

func IsRedisNull 

func IsRedisNull(err error) bool

func LLen 

func LLen(key string) int64

func LPop 

func LPop(key string, val interface{}) error

func LPush 

func LPush(key string, values ...interface{}) error

func RPop 

func RPop(key string, val interface{}) error

func RPush 

func RPush(key string, values ...interface{}) error

func Set 

func Set(key string, value interface{}, expire time.Duration) error

func SetNx 

func SetNx(key string, value interface{}, expire time.Duration) error

func ZAdd 

func ZAdd(key string, members ...*redis.Z) error

func ZCard 

func ZCard(key string) int64

func ZIncrBy 

func ZIncrBy(key string, increment float64, member string) (float64, error)

func ZRangeWithScores 

func ZRangeWithScores(key string, start, stop int64) ([]redis.Z, error)

func ZRem 

func ZRem(key string, members ...interface{}) error

func ZRevRangeWithScores 

func ZRevRangeWithScores(key string, start, stop int64) ([]redis.Z, error)

func ZRevRank 

func ZRevRank(key, member string) (int64, error)

func ZScore 

func ZScore(key, member string) float64

Types

type StoreKeeper 

type StoreKeeper interface {
	Set(key string, value interface{}, expire time.Duration) error
	SetNx(key string, value interface{}, expire time.Duration) error //set if not exist
	Get(key string, val interface{}) error
	GetInt(key string) int
	GetString(key string) string
	Del(keys ...string) error
	DelPattern(pattern string) error
	Exists(keys ...string) bool
	HSet(key, field string, val interface{}) error
	HGet(key, field string, val interface{}) error
	HGetAll(key string) (map[string]string, error)
	HDel(key string, fields ...string) error
	HDelAll(key string)
	HExists(key, field string) bool
	Expire(key string, expiration time.Duration) bool
	HKeys(key string) ([]string, error)
	ZAdd(key string, members ...*redis.Z) error
	ZRangeWithScores(key string, start, stop int64) ([]redis.Z, error)
	ZRevRangeWithScores(key string, start, stop int64) ([]redis.Z, error)
	ZRevRank(key, member string) (int64, error)
	ZScore(key, member string) float64
	ZIncrBy(key string, increment float64, member string) (float64, error)
	ZRem(key string, members ...interface{}) error
	ZCard(key string) int64
	LPush(key string, values ...interface{}) error
	RPush(key string, values ...interface{}) error
	LPop(key string, val interface{}) error
	RPop(key string, val interface{}) error
	BLPop(key string, val interface{}) error
	BRPop(key string, val interface{}) error
	BLPopString(key string) (string, error)
	BRPopString(key string) (string, error)
	LLen(key string) int64
	IsRedisNull(err error) bool
	FlushDB() error
	FlushDBAsync() error
	FlushAll() error
	FlushAllAsync() error
}

StoreKeeper stores interface

type StoreRedis 

type StoreRedis struct {
	Endpoints   []string
	Password    string
	DB          int
	DialTimeout time.Duration
	Client      *redis.Client
	Prefix      string
}

func NewStoreRedis 

func NewStoreRedis(opts ...StoreRedisOption) *StoreRedis

func (*StoreRedis) BLPop 

func (s *StoreRedis) BLPop(key string, val interface{}) error

func (*StoreRedis) BLPopString 

func (s *StoreRedis) BLPopString(key string) (string, error)

func (*StoreRedis) BRPop 

func (s *StoreRedis) BRPop(key string, val interface{}) error

func (*StoreRedis) BRPopString 

func (s *StoreRedis) BRPopString(key string) (string, error)

func (*StoreRedis) Del 

func (s *StoreRedis) Del(keys ...string) error

func (*StoreRedis) DelPattern 

func (s *StoreRedis) DelPattern(pattern string) error

func (*StoreRedis) Exists 

func (s *StoreRedis) Exists(keys ...string) bool

func (*StoreRedis) Expire 

func (s *StoreRedis) Expire(key string, expiration time.Duration) bool

func (*StoreRedis) FlushAll 

func (s *StoreRedis) FlushAll() error

func (*StoreRedis) FlushAllAsync 

func (s *StoreRedis) FlushAllAsync() error

func (*StoreRedis) FlushDB 

func (s *StoreRedis) FlushDB() error

func (*StoreRedis) FlushDBAsync 

func (s *StoreRedis) FlushDBAsync() error

func (*StoreRedis) Get 

func (s *StoreRedis) Get(key string, val interface{}) error

func (*StoreRedis) GetInt 

func (s *StoreRedis) GetInt(key string) int

func (*StoreRedis) GetKey 

func (s *StoreRedis) GetKey(key string) string

func (*StoreRedis) GetKeys 

func (s *StoreRedis) GetKeys(keys []string) []string

func (*StoreRedis) GetString 

func (s *StoreRedis) GetString(key string) string

func (*StoreRedis) GetValues 

func (s *StoreRedis) GetValues(values []interface{}) []interface{}

func (*StoreRedis) HDel 

func (s *StoreRedis) HDel(key string, fields ...string) error

func (*StoreRedis) HDelAll 

func (s *StoreRedis) HDelAll(key string)

func (*StoreRedis) HExists 

func (s *StoreRedis) HExists(key, field string) bool

func (*StoreRedis) HGet 

func (s *StoreRedis) HGet(key, field string, val interface{}) error

func (*StoreRedis) HGetAll 

func (s *StoreRedis) HGetAll(key string) (map[string]string, error)

func (*StoreRedis) HKeys 

func (s *StoreRedis) HKeys(key string) ([]string, error)

func (*StoreRedis) HSet 

func (s *StoreRedis) HSet(key, field string, val interface{}) error

func (*StoreRedis) IsRedisNull 

func (s *StoreRedis) IsRedisNull(err error) bool

func (*StoreRedis) LLen 

func (s *StoreRedis) LLen(key string) int64

func (*StoreRedis) LPop 

func (s *StoreRedis) LPop(key string, val interface{}) error

func (*StoreRedis) LPush 

func (s *StoreRedis) LPush(key string, values ...interface{}) error

func (*StoreRedis) RPop 

func (s *StoreRedis) RPop(key string, val interface{}) error

func (*StoreRedis) RPush 

func (s *StoreRedis) RPush(key string, values ...interface{}) error

func (*StoreRedis) Set 

func (s *StoreRedis) Set(key string, value interface{}, expire time.Duration) error

func (*StoreRedis) SetNx 

func (s *StoreRedis) SetNx(key string, value interface{}, expire time.Duration) error

func (*StoreRedis) ZAdd 

func (s *StoreRedis) ZAdd(key string, members ...*redis.Z) error

func (*StoreRedis) ZCard 

func (s *StoreRedis) ZCard(key string) int64

func (*StoreRedis) ZIncrBy 

func (s *StoreRedis) ZIncrBy(key string, increment float64, member string) (float64, error)

func (*StoreRedis) ZRangeWithScores 

func (s *StoreRedis) ZRangeWithScores(key string, start, stop int64) ([]redis.Z, error)

func (*StoreRedis) ZRem 

func (s *StoreRedis) ZRem(key string, members ...interface{}) error

func (*StoreRedis) ZRevRangeWithScores 

func (s *StoreRedis) ZRevRangeWithScores(key string, start, stop int64) ([]redis.Z, error)

func (*StoreRedis) ZRevRank 

func (s *StoreRedis) ZRevRank(key, member string) (int64, error)

func (*StoreRedis) ZScore 

func (s *StoreRedis) ZScore(key, member string) float64

type StoreRedisOption 

type StoreRedisOption func(s *StoreRedis)

func WithRedisDB 

func WithRedisDB(DB int) StoreRedisOption

func WithRedisDialTimeout 

func WithRedisDialTimeout(timeout time.Duration) StoreRedisOption

func WithRedisEndpoints 

func WithRedisEndpoints(endpoints []string) StoreRedisOption

func WithRedisPassword 

func WithRedisPassword(password string) StoreRedisOption

func WithRedisPrefix 

func WithRedisPrefix(prefix string) StoreRedisOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.