You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2015/07/14 19:10:16 UTC
[11/14] incubator-usergrid git commit: change comment,
add replicated test
change comment, add replicated test
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/d342875c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/d342875c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/d342875c
Branch: refs/heads/observable-query-fix
Commit: d342875c4c910e49bf4cc48054e5fa99c0e88e70
Parents: 68cafb7
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Jul 13 17:43:34 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Mon Jul 13 17:43:34 2015 -0600
----------------------------------------------------------------------
.../index/ReplicatedIndexLocationStrategy.java | 2 +-
.../corepersistence/index/IndexNamingTest.java | 18 +++++++++++++++++-
2 files changed, 18 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d342875c/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReplicatedIndexLocationStrategy.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReplicatedIndexLocationStrategy.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReplicatedIndexLocationStrategy.java
index e1b6b9e..4dd237a 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReplicatedIndexLocationStrategy.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/ReplicatedIndexLocationStrategy.java
@@ -26,7 +26,7 @@ import org.apache.usergrid.persistence.index.IndexAlias;
import org.apache.usergrid.persistence.index.IndexLocationStrategy;
/**
- * Classy class class.
+ * Strategy to replicate an index naming convention and publish elsewhere
*/
public class ReplicatedIndexLocationStrategy implements IndexLocationStrategy {
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d342875c/stack/core/src/test/java/org/apache/usergrid/corepersistence/index/IndexNamingTest.java
----------------------------------------------------------------------
diff --git a/stack/core/src/test/java/org/apache/usergrid/corepersistence/index/IndexNamingTest.java b/stack/core/src/test/java/org/apache/usergrid/corepersistence/index/IndexNamingTest.java
index 2d77697..95ad17e 100644
--- a/stack/core/src/test/java/org/apache/usergrid/corepersistence/index/IndexNamingTest.java
+++ b/stack/core/src/test/java/org/apache/usergrid/corepersistence/index/IndexNamingTest.java
@@ -20,6 +20,7 @@
package org.apache.usergrid.corepersistence.index;
import com.google.inject.Inject;
+import junit.framework.Assert;
import net.jcip.annotations.NotThreadSafe;
import org.apache.usergrid.corepersistence.TestIndexModule;
import org.apache.usergrid.corepersistence.util.CpNamingUtils;
@@ -173,7 +174,22 @@ public class IndexNamingTest {
names.add(name);
}
//always hashes to diff't bucket
- assertTrue(names.size()==indexProcessorFig.getNumberOfIndexBuckets());
+ assertTrue(names.size() == indexProcessorFig.getNumberOfIndexBuckets());
+ }
+
+ @Test
+ public void testReplication(){
+ IndexLocationStrategy indexLocationStrategy = indexLocationStrategyFactory.getIndexLocationStrategy(applicationScope);
+ ReplicatedIndexLocationStrategy replicatedIndexLocationStrategy = new ReplicatedIndexLocationStrategy(indexLocationStrategy);
+ assertEquals(replicatedIndexLocationStrategy.getApplicationScope(),indexLocationStrategy.getApplicationScope());
+ assertEquals(replicatedIndexLocationStrategy.getIndexInitialName(),indexLocationStrategy.getIndexInitialName());
+ assertEquals(replicatedIndexLocationStrategy.getIndexRootName(),indexLocationStrategy.getIndexRootName());
+ assertEquals(replicatedIndexLocationStrategy.getNumberOfReplicas(), indexLocationStrategy.getNumberOfReplicas());
+ assertEquals(replicatedIndexLocationStrategy.getNumberOfShards(),indexLocationStrategy.getNumberOfShards());
+ assertEquals(replicatedIndexLocationStrategy.getAlias().getReadAlias(),indexLocationStrategy.getAlias().getReadAlias());
+ assertEquals(replicatedIndexLocationStrategy.getAlias().getWriteAlias(),indexLocationStrategy.getAlias().getWriteAlias());
+
+
}
}