aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/configuration.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filer/configuration.go')
-rw-r--r--weed/filer/configuration.go50
1 files changed, 50 insertions, 0 deletions
diff --git a/weed/filer/configuration.go b/weed/filer/configuration.go
new file mode 100644
index 000000000..3dce67d6d
--- /dev/null
+++ b/weed/filer/configuration.go
@@ -0,0 +1,50 @@
+package filer
+
+import (
+ "os"
+
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/spf13/viper"
+)
+
+var (
+ Stores []FilerStore
+)
+
+func (f *Filer) LoadConfiguration(config *viper.Viper) {
+
+ validateOneEnabledStore(config)
+
+ for _, store := range Stores {
+ if config.GetBool(store.GetName() + ".enabled") {
+ if err := store.Initialize(config, store.GetName()+"."); err != nil {
+ glog.Fatalf("Failed to initialize store for %s: %+v",
+ store.GetName(), err)
+ }
+ f.SetStore(store)
+ glog.V(0).Infof("Configure filer for %s", store.GetName())
+ return
+ }
+ }
+
+ println()
+ println("Supported filer stores are:")
+ for _, store := range Stores {
+ println(" " + store.GetName())
+ }
+
+ os.Exit(-1)
+}
+
+func validateOneEnabledStore(config *viper.Viper) {
+ enabledStore := ""
+ for _, store := range Stores {
+ if config.GetBool(store.GetName() + ".enabled") {
+ if enabledStore == "" {
+ enabledStore = store.GetName()
+ } else {
+ glog.Fatalf("Filer store is enabled for both %s and %s", enabledStore, store.GetName())
+ }
+ }
+ }
+}