(key []byte)
| 281 | } |
| 282 | |
| 283 | func fromBackupKey(key []byte) ([]byte, uint64, error) { |
| 284 | backupKey := &pb.BackupKey{} |
| 285 | if err := proto.Unmarshal(key, backupKey); err != nil { |
| 286 | return nil, 0, errors.Wrapf(err, "while reading backup key %s", hex.Dump(key)) |
| 287 | } |
| 288 | return x.FromBackupKey(backupKey), backupKey.Namespace, nil |
| 289 | } |
| 290 | |
| 291 | func (m *mapper) processReqCh(ctx context.Context) error { |
| 292 | buf := z.NewBuffer(20<<20, "processKVList") |
no test coverage detected