+ public long getInMemoryJournalDataSize() {
+ return getOnDemandRaftState().getInMemoryJournalDataSize();
+ }
+
+ @Override
+ public long getInMemoryJournalLogSize() {
+ return getOnDemandRaftState().getInMemoryJournalLogSize();
+ }
+
+ /**
+ * Resets the counters related to transactions.
+ */
+ @Override
+ public void resetTransactionCounters() {
+ committedTransactionsCount = 0;
+
+ readOnlyTransactionCount = 0;
+
+ writeOnlyTransactionCount = 0;
+
+ readWriteTransactionCount = 0;
+
+ lastCommittedTransactionTime = 0;
+
+ failedTransactionsCount = 0;
+
+ failedReadTransactionsCount.set(0);
+
+ abortTransactionsCount = 0;
+
+ }
+
+ public void setFollowerInitialSyncStatus(final boolean followerInitialSyncStatus) {
+ this.followerInitialSyncStatus = followerInitialSyncStatus;
+ }
+
+ @Override
+ public boolean getFollowerInitialSyncStatus() {
+ return followerInitialSyncStatus;
+ }
+
+ @Override
+ public List<FollowerInfo> getFollowerInfo() {
+ return getOnDemandRaftState().getFollowerInfoList();