1 package org.opendaylight.controller.cluster.datastore.jmx.mbeans.shard;
3 import org.opendaylight.controller.cluster.datastore.jmx.mbeans.AbstractBaseMBean;
8 public class ShardStats extends AbstractBaseMBean implements ShardStatsMBean {
9 private Long committedTransactionsCount;
10 private Long journalMessagesCount;
11 final private String shardName;
12 private String leader;
13 private String raftState;
15 ShardStats(String shardName){
16 this.shardName = shardName;
17 committedTransactionsCount =0L;
18 journalMessagesCount = 0L;
23 public String getShardName() {
28 public Long getCommittedTransactionsCount() {
29 return committedTransactionsCount;
33 public Long getJournalMessagesCount() {
34 //FIXME: this will be populated once after integration with Raft stuff
35 return journalMessagesCount;
38 @Override public String getLeader() {
42 @Override public String getRaftState() {
46 public Long incrementCommittedTransactionCount() {
47 return committedTransactionsCount++;
51 public void updateCommittedTransactionsCount(long currentCount){
52 committedTransactionsCount = currentCount;
56 public void updateJournalMessagesCount(long currentCount){
57 journalMessagesCount = currentCount;
61 public void setLeader(String leader){
65 public void setRaftState(String raftState){
66 this.raftState = raftState;
71 protected String getMBeanName() {
76 protected String getMBeanType() {
77 return JMX_TYPE_DISTRIBUTED_DATASTORE;
81 protected String getMBeanCategory() {
82 return JMX_CATEGORY_SHARD;