x
This commit is contained in:
+2
-2
@@ -81,7 +81,7 @@ func MakeBucket(name string) storage.Bucket {
|
|||||||
})
|
})
|
||||||
storage.Watch(app, "redis_addr", func(old, new, _ string) *storage.Final {
|
storage.Watch(app, "redis_addr", func(old, new, _ string) *storage.Final {
|
||||||
message := "Redis连接成功,重启生效!"
|
message := "Redis连接成功,重启生效!"
|
||||||
err := redis.Try(app.GetString("redis_addr"), app.GetString("redis_password"))
|
err := redis.Try(new, app.GetString("redis_password"))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
message = "Redis连接失败:" + err.Error()
|
message = "Redis连接失败:" + err.Error()
|
||||||
}
|
}
|
||||||
@@ -91,7 +91,7 @@ func MakeBucket(name string) storage.Bucket {
|
|||||||
})
|
})
|
||||||
storage.Watch(app, "redis_password", func(old, new, _ string) *storage.Final {
|
storage.Watch(app, "redis_password", func(old, new, _ string) *storage.Final {
|
||||||
message := "Redis连接成功,重启生效!"
|
message := "Redis连接成功,重启生效!"
|
||||||
err := redis.Try(app.GetString("redis_addr"), app.GetString("redis_password"))
|
err := redis.Try(app.GetString("redis_addr"), new)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
message = "Redis连接失败:" + err.Error()
|
message = "Redis连接失败:" + err.Error()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user