You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by as...@apache.org on 2015/09/01 20:44:46 UTC
incubator-geode git commit: GEODE-11: Add utility method to discover
IndexRepo
Repository: incubator-geode
Updated Branches:
refs/heads/feature/GEODE-11 746bb3140 -> 6f9401e19
GEODE-11: Add utility method to discover IndexRepo
* Add method to discover IndexRepositories for a given region and buckets
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/6f9401e1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/6f9401e1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/6f9401e1
Branch: refs/heads/feature/GEODE-11
Commit: 6f9401e19cef1dd370ea209bfa3b8c64883d1764
Parents: 746bb31
Author: Ashvin Agrawal <as...@apache.org>
Authored: Tue Sep 1 11:30:43 2015 -0700
Committer: Ashvin Agrawal <as...@apache.org>
Committed: Tue Sep 1 11:44:24 2015 -0700
----------------------------------------------------------------------
.../internal/repository/RepositoryManager.java | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f9401e1/gemfire-lucene/src/main/java/com/gemstone/gemfire/cache/lucene/internal/repository/RepositoryManager.java
----------------------------------------------------------------------
diff --git a/gemfire-lucene/src/main/java/com/gemstone/gemfire/cache/lucene/internal/repository/RepositoryManager.java b/gemfire-lucene/src/main/java/com/gemstone/gemfire/cache/lucene/internal/repository/RepositoryManager.java
index 0d3e61f..418941a 100644
--- a/gemfire-lucene/src/main/java/com/gemstone/gemfire/cache/lucene/internal/repository/RepositoryManager.java
+++ b/gemfire-lucene/src/main/java/com/gemstone/gemfire/cache/lucene/internal/repository/RepositoryManager.java
@@ -1,9 +1,27 @@
package com.gemstone.gemfire.cache.lucene.internal.repository;
+import java.util.Collection;
+
import com.gemstone.gemfire.cache.Region;
+import com.gemstone.gemfire.internal.cache.BucketNotFoundException;
+/**
+ * {@link RepositoryManager} instances will be used to get {@link IndexRepository} instances hosting index data for
+ * {@link Region}s
+ */
public interface RepositoryManager {
IndexRepository getRepository(Region region, Object key);
+ /**
+ * Returns a collection of {@link IndexRepository} instances hosting index data of the input list of bucket ids. The
+ * bucket needs to be present on this member.
+ *
+ * @param region
+ * @param bucketIds buckets of a Partitioned region for which {@link IndexRepository}s needs to be discovered. null
+ * for all primary buckets on this member or if the region is Replicated.
+ * @return a collection of {@link IndexRepository} instances
+ * @throws BucketNotFoundException if any of the requested buckets is not found on this member
+ */
+ Collection<IndexRepository> getRepositories(Region region, int[] bucketIds) throws BucketNotFoundException;
}