aboutsummaryrefslogtreecommitdiff
path: root/weed/filer2/redis/redis_cluster_store.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filer2/redis/redis_cluster_store.go')
-rw-r--r--weed/filer2/redis/redis_cluster_store.go14
1 files changed, 7 insertions, 7 deletions
diff --git a/weed/filer2/redis/redis_cluster_store.go b/weed/filer2/redis/redis_cluster_store.go
index f1ad4b35c..eaaecb740 100644
--- a/weed/filer2/redis/redis_cluster_store.go
+++ b/weed/filer2/redis/redis_cluster_store.go
@@ -18,16 +18,16 @@ func (store *RedisClusterStore) GetName() string {
return "redis_cluster"
}
-func (store *RedisClusterStore) Initialize(configuration util.Configuration) (err error) {
+func (store *RedisClusterStore) Initialize(configuration util.Configuration, prefix string) (err error) {
- configuration.SetDefault("useReadOnly", true)
- configuration.SetDefault("routeByLatency", true)
+ configuration.SetDefault(prefix+"useReadOnly", true)
+ configuration.SetDefault(prefix+"routeByLatency", true)
return store.initialize(
- configuration.GetStringSlice("addresses"),
- configuration.GetString("password"),
- configuration.GetBool("useReadOnly"),
- configuration.GetBool("routeByLatency"),
+ configuration.GetStringSlice(prefix+"addresses"),
+ configuration.GetString(prefix+"password"),
+ configuration.GetBool(prefix+"useReadOnly"),
+ configuration.GetBool(prefix+"routeByLatency"),
)
}