// Get Redis String Value
func GetRedisString(key string) (string, error) {
redis_conn := rediswrapper.GetRedisPool().Get()
if redis_conn.Err() != nil {
logs.ERRORLOG("GetRedisPool Failed:%s", redis_conn.Err().Error())
return "", public.Err_NoRedis
}
defer redis_conn.Close()
str, err := redis.String(redis_conn.Do("GET", key))
if err != nil {
logs.DEBUGLOG("redis get:%s, error:%v", key, err)
}
return str, nil
}
// Set Redis String Value
func SetRedisString(key string, value interface{}) error {
redis_conn := rediswrapper.GetRedisPool().Get()
if redis_conn.Err() != nil {
logs.ERRORLOG("GetRedisPool Failed:%s", redis_conn.Err().Error())
return public.Err_NoRedis
}
defer redis_conn.Close()
valueStr, err := jsoniter.Marshal(value)
if err != nil {
logs.DEBUGLOG("jsoniter Marshal key:%s,value:%v error:%v", key, value, err)
return err
}
_, err = redis_conn.Do("SET", key, value, "EX", REDIS_TTL)
if err != nil {
logs.DEBUGLOG("Set Redis String key:%s,value:%s error:%v", key, valueStr, err)
return err
}
return nil
}
