+
+ @Override
+ public long getLeadershipChangeCount() {
+ return leadershipChangeCount;
+ }
+
+ public void incrementLeadershipChangeCount() {
+ leadershipChangeCount++;
+ lastLeadershipChangeTime = System.currentTimeMillis();
+ }
+
+ @Override
+ public String getLastLeadershipChangeTime() {
+ return formatMillis(lastLeadershipChangeTime);
+ }
+
+ @Override
+ public int getPendingTxCommitQueueSize() {
+ return shard != null ? shard.getPendingTxCommitQueueSize() : -1;
+ }
+
+ @Override
+ public int getTxCohortCacheSize() {
+ return shard != null ? shard.getCohortCacheSize() : -1;
+ }
+
+ @Override
+ public void captureSnapshot() {
+ if (shard != null) {
+ shard.getSelf().tell(new InitiateCaptureSnapshot(), ActorRef.noSender());
+ }
+ }