diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-12-22 02:26:05 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-12-22 02:26:05 -0800 |
| commit | 90d785a15fb8c0379e068aab94066cf5e3622071 (patch) | |
| tree | b834d04131c69808c3d58dbac0e34498ce247bc6 /weed/filer/redis2/redis_store.go | |
| parent | fe46411cd4e675d910fdac1a5d91964376518c1c (diff) | |
| download | seaweedfs-90d785a15fb8c0379e068aab94066cf5e3622071.tar.xz seaweedfs-90d785a15fb8c0379e068aab94066cf5e3622071.zip | |
filer: redis, redis cluster, cassandra support super large directory
Diffstat (limited to 'weed/filer/redis2/redis_store.go')
| -rw-r--r-- | weed/filer/redis2/redis_store.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/filer/redis2/redis_store.go b/weed/filer/redis2/redis_store.go index ed04c817b..da404ed4c 100644 --- a/weed/filer/redis2/redis_store.go +++ b/weed/filer/redis2/redis_store.go @@ -23,14 +23,16 @@ func (store *Redis2Store) Initialize(configuration util.Configuration, prefix st configuration.GetString(prefix+"address"), configuration.GetString(prefix+"password"), configuration.GetInt(prefix+"database"), + configuration.GetStringSlice(prefix+"superLargeDirectories"), ) } -func (store *Redis2Store) initialize(hostPort string, password string, database int) (err error) { +func (store *Redis2Store) initialize(hostPort string, password string, database int, superLargeDirectories []string) (err error) { store.Client = redis.NewClient(&redis.Options{ Addr: hostPort, Password: password, DB: database, }) + store.loadSuperLargeDirectories(superLargeDirectories) return } |