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 {
10 private final String shardName;
12 private Long committedTransactionsCount = 0L;
14 private Long readOnlyTransactionCount = 0L;
16 private Long writeOnlyTransactionCount = 0L;
18 private Long readWriteTransactionCount = 0L;
20 private String leader;
22 private String raftState;
24 private Long lastLogTerm = -1L;
26 private Long lastLogIndex = -1L;
28 private Long currentTerm = -1L;
30 private Long commitIndex = -1L;
32 private Long lastApplied = -1L;
34 ShardStats(String shardName) {
35 this.shardName = shardName;
40 public String getShardName() {
45 public Long getCommittedTransactionsCount() {
46 return committedTransactionsCount;
49 @Override public String getLeader() {
53 @Override public String getRaftState() {
57 @Override public Long getReadOnlyTransactionCount() {
58 return readOnlyTransactionCount;
61 @Override public Long getWriteOnlyTransactionCount() {
62 return writeOnlyTransactionCount;
65 @Override public Long getReadWriteTransactionCount() {
66 return readWriteTransactionCount;
69 @Override public Long getLastLogIndex() {
73 @Override public Long getLastLogTerm() {
77 @Override public Long getCurrentTerm() {
81 @Override public Long getCommitIndex() {
85 @Override public Long getLastApplied() {
89 public Long incrementCommittedTransactionCount() {
90 return committedTransactionsCount++;
93 public Long incrementReadOnlyTransactionCount() {
94 return readOnlyTransactionCount++;
97 public Long incrementWriteOnlyTransactionCount() {
98 return writeOnlyTransactionCount++;
101 public Long incrementReadWriteTransactionCount() {
102 return readWriteTransactionCount++;
105 public void setLeader(String leader) {
106 this.leader = leader;
109 public void setRaftState(String raftState) {
110 this.raftState = raftState;
113 public void setLastLogTerm(Long lastLogTerm) {
114 this.lastLogTerm = lastLogTerm;
117 public void setLastLogIndex(Long lastLogIndex) {
118 this.lastLogIndex = lastLogIndex;
121 public void setCurrentTerm(Long currentTerm) {
122 this.currentTerm = currentTerm;
125 public void setCommitIndex(Long commitIndex) {
126 this.commitIndex = commitIndex;
129 public void setLastApplied(Long lastApplied) {
130 this.lastApplied = lastApplied;
134 protected String getMBeanName() {
139 protected String getMBeanType() {
140 return JMX_TYPE_DISTRIBUTED_DATASTORE;
144 protected String getMBeanCategory() {
145 return JMX_CATEGORY_SHARD;