Expose Raft transport stats

store/store.go

@@ -987,6 +987,7 @@ func (s *Store) Stats() (map[string]interface{}, error) {
 		return nil, err
 	}
 	raftStats["bolt"] = s.boltStore.Stats()
+	raftStats["transport"] = s.raftTn.Stats()
 
 	dirSz, err := dirSize(s.raftDir)
 	if err != nil {
@@ -998,15 +999,14 @@ func (s *Store) Stats() (map[string]interface{}, error) {
 		return nil, err
 	}
 	status := map[string]interface{}{
-		"open":                 s.open,
+		"open":               s.open,
-		"node_id":              s.raftID,
+		"node_id":            s.raftID,
-		"raft":                 raftStats,
+		"raft":               raftStats,
-		"fsm_index":            s.fsmIdx.Load(),
+		"fsm_index":          s.fsmIdx.Load(),
-		"fsm_update_time":      s.fsmUpdateTime.Load(),
+		"fsm_update_time":    s.fsmUpdateTime.Load(),
-		"db_applied_index":     s.dbAppliedIdx.Load(),
+		"db_applied_index":   s.dbAppliedIdx.Load(),
-		"last_applied_index":   lAppliedIdx,
+		"last_applied_index": lAppliedIdx,
-		"command_commit_index": s.raftTn.CommandCommitIndex(),
+		"addr":               s.Addr(),
-		"addr":                 s.Addr(),
 		"leader": map[string]string{
 			"node_id": leaderID,
 			"addr":    leaderAddr,

store/transport.go

@@ -136,3 +136,11 @@ func (n *NodeTransport) Consumer() <-chan raft.RPC {
 	}()
 	return ch
 }
+
+// Stats returns the current stats of the transport.
+func (n *NodeTransport) Stats() map[string]interface{} {
+	return map[string]interface{}{
+		"command_commit_index": n.CommandCommitIndex(),
+		"leader_commit_index":  n.LeaderCommitIndex(),
+	}
+}