adding KratiStorage.Factory

dbuthay · Feb 15, 2012 · b204b68 · b204b68
1 parent 7666d8f
commit b204b68
Showing 1 changed file with 22 additions and 0 deletions.
diff --git a/src/main/java/com/flaptor/indextank/index/storage/KratiStorage.java b/src/main/java/com/flaptor/indextank/index/storage/KratiStorage.java
@@ -7,8 +7,10 @@
 
 import com.flaptor.indextank.index.Document;
 import com.flaptor.indextank.storage.alternatives.DocumentStorage;
+import com.flaptor.indextank.storage.alternatives.DocumentStorageFactory;
 
 import com.google.common.collect.Maps;
+import com.google.common.base.Preconditions;
 
 import krati.core.StoreConfig;
 import krati.core.StoreFactory;
@@ -65,4 +67,24 @@ public Map<String, String> getStats() {
     return Maps.newHashMap();
   }
 
+
+  public class Factory implements DocumentStorageFactory {
+
+    public static final String DIR = "dir";
+
+    @Override 
+    public DocumentStorage fromConfiguration(Map<?, ?> config) {
+      Preconditions.checkNotNull(config);
+      Preconditions.checkNotNull(config.get(DIR), "config needs '" + DIR + "' value");
+
+      File backupDir = new File(config.get(DIR).toString());
+
+      try { 
+        return new KratiStorage(backupDir);
+      } catch (Exception e) {
+        throw new RuntimeException("while creating a KratiStorage: " + e.getMessage(), e);
+      }
+    }
+  } 
+
 }