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;
 }