(store *raftwal.DiskStorage)
| 129 | } |
| 130 | |
| 131 | func printRaft(store *raftwal.DiskStorage) { |
| 132 | isZero := store.Uint(raftwal.GroupId) == 0 |
| 133 | |
| 134 | pending := make(map[uint64]bool) |
| 135 | startIdx, lastIdx := printBasic(store) |
| 136 | |
| 137 | for startIdx < lastIdx { |
| 138 | entries, err := store.Entries(startIdx, lastIdx+1, 64<<20) |
| 139 | x.Check(err) |
| 140 | for _, ent := range entries { |
| 141 | printEntry(ent, pending, isZero) |
| 142 | startIdx = x.Max(startIdx, ent.Index) |
| 143 | } |
| 144 | startIdx = startIdx + 1 |
| 145 | } |
| 146 | } |
| 147 | |
| 148 | func overwriteSnapshot(store *raftwal.DiskStorage) error { |
| 149 | snap, err := store.Snapshot() |
no test coverage detected