diff options
Diffstat (limited to 'weed/filer/redis/redis_store.go')
| -rw-r--r-- | weed/filer/redis/redis_store.go | 36 |
1 files changed, 36 insertions, 0 deletions
diff --git a/weed/filer/redis/redis_store.go b/weed/filer/redis/redis_store.go new file mode 100644 index 000000000..e152457ed --- /dev/null +++ b/weed/filer/redis/redis_store.go @@ -0,0 +1,36 @@ +package redis + +import ( + "github.com/chrislusf/seaweedfs/weed/filer" + "github.com/chrislusf/seaweedfs/weed/util" + "github.com/go-redis/redis" +) + +func init() { + filer.Stores = append(filer.Stores, &RedisStore{}) +} + +type RedisStore struct { + UniversalRedisStore +} + +func (store *RedisStore) GetName() string { + return "redis" +} + +func (store *RedisStore) Initialize(configuration util.Configuration, prefix string) (err error) { + return store.initialize( + configuration.GetString(prefix+"address"), + configuration.GetString(prefix+"password"), + configuration.GetInt(prefix+"database"), + ) +} + +func (store *RedisStore) initialize(hostPort string, password string, database int) (err error) { + store.Client = redis.NewClient(&redis.Options{ + Addr: hostPort, + Password: password, + DB: database, + }) + return +} |
