(kvIdx uint64)
| 417 | } |
| 418 | |
| 419 | func (ds *DataShard) ReadMeta(kvIdx uint64) ([]byte, error) { |
| 420 | for _, df := range ds.dataFiles { |
| 421 | if df.ContainsKv(kvIdx) { |
| 422 | return df.ReadMeta(kvIdx) |
| 423 | } |
| 424 | } |
| 425 | return nil, fmt.Errorf("kv not found: the shard is not completed?") |
| 426 | } |
| 427 | |
| 428 | func (ds *DataShard) Close() error { |
| 429 | for _, df := range ds.dataFiles { |
no test coverage detected