aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/redis2/redis_cluster_store.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-12-22 17:44:52 -0800
committerChris Lu <chris.lu@gmail.com>2020-12-22 17:44:52 -0800
commit1c7e1295dc4c91ab55920af9082498b55bdc3e66 (patch)
tree7c91e9c32958e339d8bd36b05382c1ab5d0e0ccb /weed/filer/redis2/redis_cluster_store.go
parent2260864b458d33c03376eb789af8053712ae31c8 (diff)
parentda134a2eb74c12dec110db20cc882c768f2f41c2 (diff)
downloadseaweedfs-1c7e1295dc4c91ab55920af9082498b55bdc3e66.tar.xz
seaweedfs-1c7e1295dc4c91ab55920af9082498b55bdc3e66.zip
Merge branch 'master' into support_ssd_volume
Diffstat (limited to 'weed/filer/redis2/redis_cluster_store.go')
-rw-r--r--weed/filer/redis2/redis_cluster_store.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/filer/redis2/redis_cluster_store.go b/weed/filer/redis2/redis_cluster_store.go
index d155dbe88..c7742bb19 100644
--- a/weed/filer/redis2/redis_cluster_store.go
+++ b/weed/filer/redis2/redis_cluster_store.go
@@ -28,15 +28,17 @@ func (store *RedisCluster2Store) Initialize(configuration util.Configuration, pr
configuration.GetString(prefix+"password"),
configuration.GetBool(prefix+"useReadOnly"),
configuration.GetBool(prefix+"routeByLatency"),
+ configuration.GetStringSlice(prefix+"superLargeDirectories"),
)
}
-func (store *RedisCluster2Store) initialize(addresses []string, password string, readOnly, routeByLatency bool) (err error) {
+func (store *RedisCluster2Store) initialize(addresses []string, password string, readOnly, routeByLatency bool, superLargeDirectories []string) (err error) {
store.Client = redis.NewClusterClient(&redis.ClusterOptions{
Addrs: addresses,
Password: password,
ReadOnly: readOnly,
RouteByLatency: routeByLatency,
})
+ store.loadSuperLargeDirectories(superLargeDirectories)
return
}