Add getAll to DatabaseService
Change-Id: I5fb9d52244b005dfc22e7faaa68341be3c3f3725
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
index a6320ed..d512635 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
@@ -3,6 +3,7 @@
import static com.google.common.base.Preconditions.checkNotNull;
import java.util.List;
+import java.util.Map;
import java.util.Set;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
@@ -13,6 +14,7 @@
import org.onlab.onos.store.service.BatchWriteRequest;
import org.onlab.onos.store.service.DatabaseException;
import org.onlab.onos.store.service.ReadResult;
+import org.onlab.onos.store.service.VersionedValue;
import org.onlab.onos.store.service.WriteResult;
/**
@@ -95,4 +97,13 @@
throw new DatabaseException(e);
}
}
+
+ public Map<String, VersionedValue> getAll(String tableName) {
+ CompletableFuture<Map<String, VersionedValue>> future = copycat.submit("getAll", tableName);
+ try {
+ return future.get();
+ } catch (InterruptedException | ExecutionException e) {
+ throw new DatabaseException(e);
+ }
+ }
}