()
| 237 | } |
| 238 | |
| 239 | func (m *mockKV) ResetIndex() { |
| 240 | m.mtx.Lock() |
| 241 | defer m.mtx.Unlock() |
| 242 | |
| 243 | m.current = 0 |
| 244 | m.cond.Broadcast() |
| 245 | |
| 246 | level.Debug(m.logger).Log("msg", "Reset") |
| 247 | } |
| 248 | |
| 249 | func (m *mockKV) ResetIndexForKey(key string) { |
| 250 | m.mtx.Lock() |