redis.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. package utils
  2. import (
  3. "eta_gn/eta_bridge/utils/redis"
  4. "time"
  5. )
  6. type RedisClient interface {
  7. Get(key string) interface{}
  8. GetStr(key string) string
  9. GetInt64(key string) (int64, error)
  10. GetUInt64(key string) (uint64, error)
  11. RedisBytes(key string) (data []byte, err error)
  12. RedisString(key string) (data string, err error)
  13. RedisInt(key string) (data int, err error)
  14. Put(key string, val interface{}, timeout time.Duration) error
  15. SetNX(key string, val interface{}, timeout time.Duration) bool
  16. Delete(key string) error
  17. IsExist(key string) bool
  18. LPush(key string, val interface{}) error
  19. Brpop(key string, callback func([]byte))
  20. GetRedisTTL(key string) time.Duration
  21. Incrby(key string, num int) (interface{}, error)
  22. Do(commandName string, args ...interface{}) (reply interface{}, err error)
  23. }
  24. func InitRedis(redisType string, conf string) (redisClient RedisClient, err error) {
  25. switch redisType {
  26. case "cluster": // 集群
  27. redisClient, err = redis.InitClusterRedis(conf)
  28. default: // 默认走单机
  29. redisClient, err = redis.InitStandaloneRedis(conf)
  30. }
  31. return
  32. }
  33. // redis没有key的错误
  34. const RedisNoKeyErr = "redis: nil"
  35. //const redisNoKeyErr = redis2.Error(redis2.Nil)