redis

Documentation

Index

• Variables
• func Close() error
• func DecreaseCounter(key string) (result int64, err error)
• func DoCmd(cmd string, params ...any) (reply any, err error)
• func GeoAdd(key, longitude, latitude, member string) (err error)
• func GeoRadiusWithLua(key, longitude, latitude, distance, unit string, page, limit int64) (result []int64, err error)
• func GeoRemove(key, member string) (err error)
• func Get(key string) (*red.Pool, error)
• func GetCounter(key string) (result int64, err error)
• func GetInt64s(key string) (value []int64, err error)
• func GetJSONObject(key string, dest interface{}) error
• func GetPool() *red.Pool
• func GetString(key string) (value string, err error)
• func IncreaseCounter(key string) (result int64, err error)
• func InitRedis(conf *Config) error
• func IsBUSYGROUPErr(err error) bool
• func IsExist(key string) (isExist bool, err error)
• func IsMessageNotFound(err error) bool
• func Register(conf *Config, key string) error
• func Set(key, value interface{}, expireTime int64) (err error)
• func SetInt64s(key string, value []int64, expireTime int64) (err error)
• func SetJSONObjectWithNoExpireTime(key string, value interface{}) (err error)
• func SetWithOutExpire(key, value interface{}) (err error)
• func XACK(key, groupName, messageID string) (err error)
• func XAdd(key string, message interface{}) (messageID string, err error)
• func XAddWithConn(c r2.Conn, key string, message interface{}) (messageID string, err error)
• func XGROUPDESTORY(key, groupName string) (err error)
• func XGroupCreate(key string, groupName string) (err error)
• func XGroupCreateCustomFromStart(key string, groupName string) (err error)
• func XReadBlock(key, groupName, consumer string, message IMessage) (err error)
• func XReadBlockFromStart(key, groupName, consumer string, message IMessage) (err error)
• type Config
• type GeoRadiusCoordinate
• type GeoRadiusResult
  • func GeoRadius(key, longitude, latitude, distance, unit string) (result []GeoRadiusResult, err error)
• type IMessage

Variables

var (
	ErrMessageNotFoundErr = errors.New("messageNotFound")
)

Functions

func Close

func Close() error

func DecreaseCounter

func DecreaseCounter(key string) (result int64, err error)

func DoCmd

func DoCmd(cmd string, params ...any) (reply any, err error)

func GeoAdd

func GeoAdd(key, longitude, latitude, member string) (err error)

func GeoRadiusWithLua

func GeoRadiusWithLua(key, longitude, latitude, distance, unit string, page, limit int64) (result []int64, err error)

func GeoRemove

func GeoRemove(key, member string) (err error)

func Get

func Get(key string) (*red.Pool, error)

func GetCounter

func GetCounter(key string) (result int64, err error)

func GetInt64s

func GetInt64s(key string) (value []int64, err error)

func GetJSONObject

func GetJSONObject(key string, dest interface{}) error

func GetPool

func GetPool() *red.Pool

func GetString

func GetString(key string) (value string, err error)

func IncreaseCounter

func IncreaseCounter(key string) (result int64, err error)

func InitRedis

func InitRedis(conf *Config) error

func IsBUSYGROUPErr

func IsBUSYGROUPErr(err error) bool

func IsExist

func IsExist(key string) (isExist bool, err error)

func IsMessageNotFound

func IsMessageNotFound(err error) bool

func Register

func Register(conf *Config, key string) error

func Set

func Set(key, value interface{}, expireTime int64) (err error)

func SetInt64s

func SetInt64s(key string, value []int64, expireTime int64) (err error)

func SetJSONObjectWithNoExpireTime

func SetJSONObjectWithNoExpireTime(key string, value interface{}) (err error)

func SetWithOutExpire

func SetWithOutExpire(key, value interface{}) (err error)

func XACK

func XACK(key, groupName, messageID string) (err error)

func XAdd

func XAdd(key string, message interface{}) (messageID string, err error)

func XAddWithConn

func XAddWithConn(c r2.Conn, key string, message interface{}) (messageID string, err error)

func XGROUPDESTORY

func XGROUPDESTORY(key, groupName string) (err error)

func XGroupCreate

func XGroupCreate(key string, groupName string) (err error)

func XGroupCreateCustomFromStart

func XGroupCreateCustomFromStart(key string, groupName string) (err error)

func XReadBlock

func XReadBlock(key, groupName, consumer string, message IMessage) (err error)

func XReadBlockFromStart

func XReadBlockFromStart(key, groupName, consumer string, message IMessage) (err error)

Types

type Config

type Config struct {
	Host     string `json:",default=127.0.0.1"`
	Port     int    `json:",default=6379"`
	UserName string `json:",optional"`
	Password string `json:",optional"`
	DB       int    `json:",default=3"`
}

type GeoRadiusCoordinate

type GeoRadiusCoordinate struct {
	Longitude string
	Latitude  string
}

type GeoRadiusResult

type GeoRadiusResult struct {
	Member     string
	Distance   string
	Coordinate GeoRadiusCoordinate
}

func GeoRadius

func GeoRadius(key, longitude, latitude, distance, unit string) (result []GeoRadiusResult, err error)

type IMessage

type IMessage interface {
	SetMessageID(messageID string)
}