redis.go

package vcache

import (
	"sync"
	"time"

	"github.com/coseyo/radixpool"
)

const (
	radixErrEmpty = "string value is not available for this reply type"
)

var (
	RedisPool *radixpool.Pool
	doOnce    sync.Once
)

// init redis config
func InitRedis(network, addr string, size int, clientTimeout time.Duration, password string, dbNum int) error {
	var err error
	doOnce.Do(func() {
		RedisPool, err = radixpool.NewPool(network, addr, size, clientTimeout, password, dbNum)
	})
	return err
}

func get(key string) (str string, err error) {
	str, err = RedisPool.Cmd("GET", key).Str()
	if err != nil && err.Error() == radixErrEmpty {
		err = nil
	}
	return
}

func set(key, value string) error {
	return RedisPool.Cmd("SET", key, value).Err
}

func setex(key string, seconds int, value string) error {
	return RedisPool.Cmd("SETEX", key, seconds, value).Err
}

func del(key string) error {
	return RedisPool.Cmd("DEL", key).Err
}

func expire(key string, seconds int) error {
	return RedisPool.Cmd("EXPIRE", key, seconds).Err
}

func incr(key string) (int, error) {
	return RedisPool.Cmd("INCR", key).Int()
}

func decr(key string) (int, error) {
	return RedisPool.Cmd("DECR", key).Int()
}

func ttl(key string) (int, error) {
	return RedisPool.Cmd("TTl", key).Int()
}