Cluster distributed data store

Add experimental cluster co-ordination service using Atomic framework.

Included distributed data store creation utilities.

Sample docker compose data cluster between cds controller and resource-resolution instances.

Issue-ID: CCSDK-2000
Signed-off-by: Brinda Santh <bs2796@att.com>
Change-Id: I4de00e773a996e08fd1d260fc27ed18832433883

3 files changed, 76 insertions, 0 deletions

diff --git a/ms/blueprintsprocessor/application/src/main/resources/atomix/atomix-bootstrap.conf b/ms/blueprintsprocessor/application/src/main/resources/atomix/atomix-bootstrap.conf
new file mode 100644
index 000000000..0fc31e00f
--- /dev/null
+++ b/ms/blueprintsprocessor/application/src/main/resources/atomix/atomix-bootstrap.conf
@@ -0,0 +1,35 @@
+cluster {
+  # Configure the cluster node information.
+  node {
+    id: ${CLUSTER_NODE_ID}
+    address: ${CLUSTER_NODE_ADDRESS}
+  }
+  # Configure the node discovery protocol.
+  discovery {
+    type: bootstrap
+    nodes.1 {
+      id: cds-controller-1
+      address: "cds-controller-1:5679"
+    }
+    nodes.2 {
+      id: resource-reolution-1
+      address: "resource-reolution-1:5679"
+    }
+  }
+}
+# Configure the system management group.
+managementGroup {
+  type: raft
+  name: system
+  partitions: 1
+  members: [${CLUSTER_MEMBERS}]
+  storage {
+    directory: ${CLUSTER_STORAGE_PATH}/data-${CLUSTER_NODE_ID}
+    level: DISK
+  }
+}
+# Configure a Raft partition group.
+partitionGroups.data {
+  type: primary-backup
+  partitions: 7
+}
diff --git a/ms/blueprintsprocessor/application/src/main/resources/atomix/atomix-multicast.conf b/ms/blueprintsprocessor/application/src/main/resources/atomix/atomix-multicast.conf
new file mode 100644
index 000000000..fd161879c
--- /dev/null
+++ b/ms/blueprintsprocessor/application/src/main/resources/atomix/atomix-multicast.conf
@@ -0,0 +1,40 @@
+cluster {
+  # Configure the cluster node information.
+  node {
+    id: ${CLUSTER_NODE_ID}
+    address: ${CLUSTER_NODE_ADDRESS}
+  }
+  # Configure the node discovery protocol.
+  discovery {
+    type: multicast
+  }
+  multicast: {
+    enabled: true
+    port: 54321
+  }
+  # Configure the SWIM membership protocol.
+  protocol {
+    type: swim
+    broadcastUpdates: true
+    gossipInterval: 500ms
+    probeInterval: 2s
+    suspectProbes: 2
+  }
+}
+# Configure the system management group.
+managementGroup {
+  type: raft
+  name: system
+  partitions: 1
+  members: [${CLUSTER_MEMBERS}]
+  storage {
+    directory: ${CLUSTER_STORAGE_PATH}/data-${CLUSTER_NODE_ID}
+    level: DISK
+  }
+}
+
+# Configure a Raft partition group.
+partitionGroups.data {
+  type: primary-backup
+  partitions: 7
+}
diff --git a/ms/blueprintsprocessor/application/src/main/resources/logback.xml b/ms/blueprintsprocessor/application/src/main/resources/logback.xml
index e1389a66f..d58be8ac7 100644
--- a/ms/blueprintsprocessor/application/src/main/resources/logback.xml
+++ b/ms/blueprintsprocessor/application/src/main/resources/logback.xml
@@ -39,6 +39,7 @@
     <logger name="org.springframework" level="info"/>
     <logger name="org.springframework.web" level="info"/>
     <logger name="org.hibernate" level="error"/>
+    <logger name="io.atomix" level="warn"/>
     <logger name="org.onap.ccsdk.cds" level="info"/>
 
     <root level="info">