1 files changed, 212 insertions, 0 deletions
diff --git a/grToolkit/provider/src/main/java/org/onap/ccsdk/sli/plugins/data/ClusterActor.java b/grToolkit/provider/src/main/java/org/onap/ccsdk/sli/plugins/data/ClusterActor.java
new file mode 100755
index 00000000..34a51192
--- /dev/null
+++ b/grToolkit/provider/src/main/java/org/onap/ccsdk/sli/plugins/data/ClusterActor.java
@@ -0,0 +1,212 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * openECOMP : SDN-C
+ * ================================================================================
+ * Copyright (C) 2018 AT&T Intellectual Property. All rights
+ * 			reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.ccsdk.sli.plugins.data;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+
+public class ClusterActor {
+    private String node;
+    private String member;
+    private String site;
+    private String akkaPort;
+    private boolean voting;
+    private boolean up;
+    private boolean unreachable;
+    private ArrayList<String> shardLeader;
+    private ArrayList<String> replicaShards;
+    private ArrayList<String> nonReplicaShards;
+    private HashMap<String, Integer> commits;
+
+    public static final String SITE_1 = "Site 1";
+    public static final String SITE_2 = "Site 2";
+
+    public ClusterActor() {
+        node = "";
+        member = "";
+        site = "";
+        voting = false;
+        up = false;
+        unreachable = false;
+        shardLeader = new ArrayList<>();
+        replicaShards = new ArrayList<>();
+        nonReplicaShards = new ArrayList<>();
+        commits = new HashMap<>();
+    }
+
+    public String getNode() {
+        return node;
+    }
+
+    public void setNode(String node) {
+        this.node = node;
+    }
+
+    public String getMember() {
+        return member;
+    }
+
+    public void setMember(String member) {
+        this.member = member;
+    }
+
+    public String getSite() {
+        return site;
+    }
+
+    public void setSite(String site) {
+        this.site = site;
+    }
+
+    public String getAkkaPort() {
+        return akkaPort;
+    }
+
+    public void setAkkaPort(String akkaPort) {
+        this.akkaPort = akkaPort;
+    }
+
+    public boolean isVoting() {
+        return voting;
+    }
+
+    public void setVoting(boolean voting) {
+        this.voting = voting;
+    }
+
+    public boolean isUp() {
+        return up;
+    }
+
+    public void setUp(boolean up) {
+        this.up = up;
+    }
+
+    public boolean isUnreachable() {
+        return unreachable;
+    }
+
+    public void setUnreachable(boolean unreachable) {
+        this.unreachable = unreachable;
+    }
+
+    public ArrayList<String> getShardLeader() {
+        return shardLeader;
+    }
+
+    public void setShardLeader(ArrayList<String> shardLeader) {
+        this.shardLeader = shardLeader;
+    }
+
+    public ArrayList<String> getReplicaShards() {
+        return replicaShards;
+    }
+
+    public void setReplicaShards(ArrayList<String> replicaShards) {
+        this.replicaShards = replicaShards;
+    }
+
+    public ArrayList<String> getNonReplicaShards() {
+        return nonReplicaShards;
+    }
+
+    public void setNonReplicaShards(ArrayList<String> nonReplicaShards) {
+        this.nonReplicaShards = nonReplicaShards;
+    }
+
+    public HashMap<String, Integer> getCommits() {
+        return commits;
+    }
+
+    public void setCommits(HashMap<String, Integer> commits) {
+        this.commits = commits;
+    }
+
+    public void flush() {
+        shardLeader.clear();
+        replicaShards.clear();
+        nonReplicaShards.clear();
+        commits.clear();
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder builder = new StringBuilder();
+        builder.append("[ ");
+        builder.append(this.member);
+        builder.append(" ] ");
+
+        builder.append(this.node);
+        builder.append(":");
+        builder.append(this.akkaPort);
+        builder.append(" is");
+        if(up)
+            builder.append(" Up");
+        else
+            builder.append(" Down");
+        if(unreachable)
+            builder.append(" [ UNREACHABLE ]");
+
+        if(voting)
+            builder.append(" (Voting)");
+
+        builder.append("\n");
+
+        for(String l : this.shardLeader) {
+            builder.append("\tLeader: ");
+            builder.append(l);
+            builder.append("\n");
+        }
+
+        for(String r : this.replicaShards) {
+            builder.append("\tReplicating: ");
+            builder.append(r);
+            builder.append("\n");
+        }
+
+        for(String n : this.nonReplicaShards) {
+            builder.append("\tNot replicating: ");
+            builder.append(n);
+            builder.append("\n");
+        }
+
+        for(String key : commits.keySet()) {
+            int value = commits.get(key);
+            if(value > 0) {
+                builder.append("\t");
+                builder.append(value);
+                builder.append(" commits ahead of ");
+                builder.append(key);
+                builder.append("\n");
+            }
+            else if(value < 0) {
+                builder.append("\t");
+                builder.append(value);
+                builder.append(" commits behind ");
+                builder.append(key);
+                builder.append("\n");
+            }
+        }
+
+        return builder.toString();
+    }
+}