(_ context.Context, k string)
| 64 | } |
| 65 | |
| 66 | func (s *fakeStore) Delete(_ context.Context, k string) error { |
| 67 | s.mu.Lock() |
| 68 | defer s.mu.Unlock() |
| 69 | s.deleteCalls++ |
| 70 | delete(s.data, k) |
| 71 | return nil |
| 72 | } |
| 73 | |
| 74 | // add simulates a peer replica writing to the shared DB out-of-band (e.g. while |
| 75 | // this replica was partitioned), so a re-hydrate can be observed to pick it up. |