(store *raftwal.DiskStorage)
| 201 | } |
| 202 | |
| 203 | func handleWal(store *raftwal.DiskStorage) error { |
| 204 | rid := store.Uint(raftwal.RaftId) |
| 205 | gid := store.Uint(raftwal.GroupId) |
| 206 | |
| 207 | fmt.Printf("Raft Id = %d Groupd Id = %d\n", rid, gid) |
| 208 | switch { |
| 209 | case len(opt.wsetSnapshot) > 0: |
| 210 | return overwriteSnapshot(store) |
| 211 | case opt.wtruncateUntil != 0: |
| 212 | store.TruncateEntriesUntil(opt.wtruncateUntil) |
| 213 | default: |
| 214 | printRaft(store) |
| 215 | } |
| 216 | return nil |
| 217 | } |
no test coverage detected