Support for a distributed counter
Change-Id: I346e9baa28556fac13e53771021f5f6fbcd75ac9
diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDatabase.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDatabase.java
index 8ed7670..4bdfcb3 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDatabase.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultDatabase.java
@@ -65,6 +65,11 @@
}
@Override
+ public CompletableFuture<Map<String, Long>> counters() {
+ return checkOpen(() -> proxy.counters());
+ }
+
+ @Override
public CompletableFuture<Integer> size(String tableName) {
return checkOpen(() -> proxy.size(tableName));
}
@@ -145,6 +150,16 @@
}
@Override
+ public CompletableFuture<Long> nextValue(String counterName) {
+ return checkOpen(() -> proxy.nextValue(counterName));
+ }
+
+ @Override
+ public CompletableFuture<Long> currentValue(String counterName) {
+ return checkOpen(() -> proxy.currentValue(counterName));
+ }
+
+ @Override
public CompletableFuture<Boolean> prepareAndCommit(Transaction transaction) {
return checkOpen(() -> proxy.prepareAndCommit(transaction));
}