|
|
@ -4,7 +4,7 @@ import ( |
|
|
|
"encoding/json" |
|
|
|
"errors" |
|
|
|
|
|
|
|
"git.tetele.net/tgo/redis" |
|
|
|
"git.tetele.net/tgo/redisrpc" |
|
|
|
) |
|
|
|
|
|
|
|
/** |
|
|
@ -15,7 +15,7 @@ import ( |
|
|
|
func GetSiteFromRedis(host string) (map[string]string, error) { |
|
|
|
|
|
|
|
var site map[string]string = make(map[string]string) |
|
|
|
info, err := redis.HGetString(SITE_KEY, host) |
|
|
|
info, err := redisrpc.HGetString(SITE_KEY, host) |
|
|
|
if err != nil { |
|
|
|
return site, err |
|
|
|
} |
|
|
@ -55,14 +55,14 @@ func SetToRedis(host string, site map[string]string) error { |
|
|
|
if err != nil { |
|
|
|
return err |
|
|
|
} |
|
|
|
_, err = redis.HMSet(SITE_KEY, host, siteStr) |
|
|
|
_, err = redisrpc.HSet(SITE_KEY, host, siteStr) |
|
|
|
|
|
|
|
return err |
|
|
|
} |
|
|
|
|
|
|
|
func GetAll() ([]map[string]string, error) { |
|
|
|
|
|
|
|
list, err := redis.HGetAll(SITE_KEY) |
|
|
|
list, err := redisrpc.HGetAll(SITE_KEY) |
|
|
|
if err != nil { |
|
|
|
return nil, err |
|
|
|
} |
|
|
|