WIP: Partitioned Database based on Raft.
Removed the implementation based on previous Copycat API.
Change-Id: I6b9d67e943e17095f585ae2a2cb6304c248cd686
diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseState.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseState.java
new file mode 100644
index 0000000..89a51e8
--- /dev/null
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseState.java
@@ -0,0 +1,77 @@
+package org.onosproject.store.consistent.impl;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Map.Entry;
+import java.util.Set;
+
+import net.kuujo.copycat.state.Command;
+import net.kuujo.copycat.state.Initializer;
+import net.kuujo.copycat.state.Query;
+import net.kuujo.copycat.state.StateContext;
+
+/**
+ * Database state.
+ *
+ */
+public interface DatabaseState<K, V> {
+
+ /**
+ * Initializes the database state.
+ *
+ * @param context The map state context.
+ */
+ @Initializer
+ public void init(StateContext<DatabaseState<K, V>> context);
+
+ @Query
+ int size(String tableName);
+
+ @Query
+ boolean isEmpty(String tableName);
+
+ @Query
+ boolean containsKey(String tableName, K key);
+
+ @Query
+ boolean containsValue(String tableName, V value);
+
+ @Query
+ Versioned<V> get(String tableName, K key);
+
+ @Command
+ Versioned<V> put(String tableName, K key, V value);
+
+ @Command
+ Versioned<V> remove(String tableName, K key);
+
+ @Command
+ void clear(String tableName);
+
+ @Query
+ Set<K> keySet(String tableName);
+
+ @Query
+ Collection<Versioned<V>> values(String tableName);
+
+ @Query
+ Set<Entry<K, Versioned<V>>> entrySet(String tableName);
+
+ @Command
+ Versioned<V> putIfAbsent(String tableName, K key, V value);
+
+ @Command
+ boolean remove(String tableName, K key, V value);
+
+ @Command
+ boolean remove(String tableName, K key, long version);
+
+ @Command
+ boolean replace(String tableName, K key, V oldValue, V newValue);
+
+ @Command
+ boolean replace(String tableName, K key, long oldVersion, V newValue);
+
+ @Command
+ boolean batchUpdate(List<UpdateOperation<K, V>> updates);
+}