aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/meta_cache
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-04-21 18:50:30 -0700
committerChris Lu <chris.lu@gmail.com>2020-04-21 18:50:30 -0700
commit4f02f7121d232507bbbba825fa241bc8d5e630ff (patch)
treed9facd0b9188e459c0a483cb0891b97594ea1dd7 /weed/filesys/meta_cache
parentb8e4238ad29a60b37a3983a9968e325dd6849103 (diff)
downloadseaweedfs-4f02f7121d232507bbbba825fa241bc8d5e630ff.tar.xz
seaweedfs-4f02f7121d232507bbbba825fa241bc8d5e630ff.zip
read from meta cache
meta cache is not initialized
Diffstat (limited to 'weed/filesys/meta_cache')
-rw-r--r--weed/filesys/meta_cache/cache_config.go32
-rw-r--r--weed/filesys/meta_cache/meta_cache.go34
2 files changed, 66 insertions, 0 deletions
diff --git a/weed/filesys/meta_cache/cache_config.go b/weed/filesys/meta_cache/cache_config.go
new file mode 100644
index 000000000..e6593ebde
--- /dev/null
+++ b/weed/filesys/meta_cache/cache_config.go
@@ -0,0 +1,32 @@
+package meta_cache
+
+import "github.com/chrislusf/seaweedfs/weed/util"
+
+var (
+ _ = util.Configuration(&cacheConfig{})
+)
+
+// implementing util.Configuraion
+type cacheConfig struct {
+ dir string
+}
+
+func (c cacheConfig) GetString(key string) string {
+ return c.dir
+}
+
+func (c cacheConfig) GetBool(key string) bool {
+ panic("implement me")
+}
+
+func (c cacheConfig) GetInt(key string) int {
+ panic("implement me")
+}
+
+func (c cacheConfig) GetStringSlice(key string) []string {
+ panic("implement me")
+}
+
+func (c cacheConfig) SetDefault(key string, value interface{}) {
+ panic("implement me")
+}
diff --git a/weed/filesys/meta_cache/meta_cache.go b/weed/filesys/meta_cache/meta_cache.go
new file mode 100644
index 000000000..4f047e824
--- /dev/null
+++ b/weed/filesys/meta_cache/meta_cache.go
@@ -0,0 +1,34 @@
+package meta_cache
+
+import (
+ "os"
+
+ "github.com/chrislusf/seaweedfs/weed/filer2"
+ "github.com/chrislusf/seaweedfs/weed/filer2/leveldb"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+)
+
+type MetaCache struct {
+ filer2.FilerStore
+}
+
+func NewMetaCache(dbFolder string) *MetaCache {
+ return &MetaCache{
+ FilerStore: OpenMetaStore(dbFolder),
+ }
+}
+
+func OpenMetaStore(dbFolder string) filer2.FilerStore {
+
+ os.MkdirAll(dbFolder, 0755)
+
+ store := &leveldb.LevelDBStore{}
+ config := &cacheConfig{}
+
+ if err := store.Initialize(config, ""); err != nil {
+ glog.Fatalf("Failed to initialize metadata cache store for %s: %+v", store.GetName(), err)
+ }
+
+ return store
+
+}