(op clientv3.Op)
| 248 | } |
| 249 | |
| 250 | func (m *mockKV) doGet(op clientv3.Op) (clientv3.OpResponse, error) { |
| 251 | matching := m.matchingKeys(op, m.values) |
| 252 | kvs := make([]*mvccpb.KeyValue, 0, len(matching)) |
| 253 | |
| 254 | for _, k := range matching { |
| 255 | kv := m.values[k] |
| 256 | kvs = append(kvs, &kv) |
| 257 | } |
| 258 | |
| 259 | res := clientv3.GetResponse{ |
| 260 | Kvs: kvs, |
| 261 | Count: int64(len(kvs)), |
| 262 | } |
| 263 | |
| 264 | return res.OpResponse(), nil |
| 265 | } |
| 266 | |
| 267 | func (m *mockKV) doDelete(op clientv3.Op) (clientv3.OpResponse, error) { |
| 268 | matching := m.matchingKeys(op, m.values) |
no test coverage detected