From c4a89ede8d80db5d7b236388ccc22532ba550abd Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Mon, 13 Apr 2020 09:28:43 -0400 Subject: [PATCH] Add helper function for Raft log size --- store/store.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/store/store.go b/store/store.go index 5b8bcbda..abea1d0a 100644 --- a/store/store.go +++ b/store/store.go @@ -986,6 +986,15 @@ func (s *Store) DeregisterObserver(o *raft.Observer) { s.raft.DeregisterObserver(o) } +// logSize returns the size of the Raft log on disk. +func (s *Store) logSize() (int64, error) { + fi, err := os.Stat(filepath.Join(s.raftDir, "raft.db")) + if err != nil { + return 0, err + } + return fi.Size(), nil +} + type fsmSnapshot struct { database []byte meta []byte