aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/redis_store/redis_store.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-05-27 11:52:15 -0700
committerChris Lu <chris.lu@gmail.com>2018-05-27 11:52:15 -0700
commit8647191bee2027232105b20b5c110ffda225f9ba (patch)
treea3545bfd3c6c27f5511066db228ef48d5d935c51 /weed/filer/redis_store/redis_store.go
parent03d76479a57a4e28a56d89b14d78300756992007 (diff)
downloadseaweedfs-8647191bee2027232105b20b5c110ffda225f9ba.tar.xz
seaweedfs-8647191bee2027232105b20b5c110ffda225f9ba.zip
removing filer package!
Diffstat (limited to 'weed/filer/redis_store/redis_store.go')
-rw-r--r--weed/filer/redis_store/redis_store.go50
1 files changed, 0 insertions, 50 deletions
diff --git a/weed/filer/redis_store/redis_store.go b/weed/filer/redis_store/redis_store.go
deleted file mode 100644
index 5b8362983..000000000
--- a/weed/filer/redis_store/redis_store.go
+++ /dev/null
@@ -1,50 +0,0 @@
-package redis_store
-
-import (
- "github.com/chrislusf/seaweedfs/weed/filer"
-
- "github.com/go-redis/redis"
-)
-
-type RedisStore struct {
- Client *redis.Client
-}
-
-func NewRedisStore(hostPort string, password string, database int) *RedisStore {
- client := redis.NewClient(&redis.Options{
- Addr: hostPort,
- Password: password,
- DB: database,
- })
- return &RedisStore{Client: client}
-}
-
-func (s *RedisStore) Get(fullFileName string) (fid string, err error) {
- fid, err = s.Client.Get(fullFileName).Result()
- if err == redis.Nil {
- err = filer.ErrNotFound
- }
- return fid, err
-}
-func (s *RedisStore) Put(fullFileName string, fid string) (err error) {
- _, err = s.Client.Set(fullFileName, fid, 0).Result()
- if err == redis.Nil {
- err = nil
- }
- return err
-}
-
-// Currently the fid is not returned
-func (s *RedisStore) Delete(fullFileName string) (err error) {
- _, err = s.Client.Del(fullFileName).Result()
- if err == redis.Nil {
- err = nil
- }
- return err
-}
-
-func (s *RedisStore) Close() {
- if s.Client != nil {
- s.Client.Close()
- }
-}