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;
13 ShardStats(String shardName){
14 this.shardName = shardName;
15 committedTransactionsCount =0L;
16 journalMessagesCount = 0L;
21 public String getShardName() {
26 public Long getCommittedTransactionsCount() {
27 return committedTransactionsCount;
31 public Long getJournalMessagesCount() {
32 //FIXME: this will be populated once after integration with Raft stuff
33 return journalMessagesCount;
37 public Long incrementCommittedTransactionCount() {
38 return committedTransactionsCount++;
42 public void updateCommittedTransactionsCount(long currentCount){
43 committedTransactionsCount = currentCount;
47 public void updateJournalMessagesCount(long currentCount){
48 journalMessagesCount = currentCount;
55 protected String getMBeanName() {
60 protected String getMBeanType() {
61 return JMX_TYPE_DISTRIBUTED_DATASTORE;
65 protected String getMBeanCategory() {
66 return JMX_CATEGORY_SHARD;