Implementation for StorageAdmin and PartitionAdmin APIs
Change-Id: I48cbfae6f410425294196884cdb2ce4705fa2c3d
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java
index 20c2a98..99d0897 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java
@@ -19,6 +19,7 @@
import java.util.List;
import java.util.Map;
+import java.util.Set;
import java.util.TreeMap;
import org.apache.commons.lang.StringUtils;
@@ -33,8 +34,10 @@
import org.onosproject.store.service.DistributedQueue;
import org.onosproject.store.service.Serializer;
+import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
+import com.google.common.collect.Sets;
import com.google.common.hash.HashCode;
import com.google.common.hash.Hashing;
import com.google.common.primitives.Bytes;
@@ -93,6 +96,24 @@
return getCreator(name).newAsyncLeaderElector(name);
}
+ @Override
+ public Set<String> getAsyncConsistentMapNames() {
+ return members.values()
+ .stream()
+ .map(DistributedPrimitiveCreator::getAsyncConsistentMapNames)
+ .reduce(Sets::union)
+ .orElse(ImmutableSet.of());
+ }
+
+ @Override
+ public Set<String> getAsyncAtomicCounterNames() {
+ return members.values()
+ .stream()
+ .map(DistributedPrimitiveCreator::getAsyncAtomicCounterNames)
+ .reduce(Sets::union)
+ .orElse(ImmutableSet.of());
+ }
+
/**
* Returns the {@code DistributedPrimitiveCreator} to use for hosting a primitive.
* @param name primitive name