(op clientv3.Op)
| 265 | } |
| 266 | |
| 267 | func (m *mockKV) doDelete(op clientv3.Op) (clientv3.OpResponse, error) { |
| 268 | matching := m.matchingKeys(op, m.values) |
| 269 | |
| 270 | for _, k := range matching { |
| 271 | kv := m.values[k] |
| 272 | kv.ModRevision = kv.Version |
| 273 | |
| 274 | m.sendEvent(clientv3.Event{ |
| 275 | Type: mvccpb.DELETE, |
| 276 | Kv: &kv, |
| 277 | }) |
| 278 | |
| 279 | delete(m.values, k) |
| 280 | } |
| 281 | |
| 282 | res := clientv3.DeleteResponse{Deleted: int64(len(matching))} |
| 283 | return res.OpResponse(), nil |
| 284 | } |
| 285 | |
| 286 | func (m *mockKV) doPut(op clientv3.Op) (clientv3.OpResponse, error) { |
| 287 | keyBytes := op.KeyBytes() |
no test coverage detected