Merge pull request #1 from chrislusf/master

catch up

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())
+			}
+		}
+	}
+}