(kvIdx uint64, b []byte)
| 408 | } |
| 409 | |
| 410 | func (ds *DataShard) WriteMeta(kvIdx uint64, b []byte) error { |
| 411 | for _, df := range ds.dataFiles { |
| 412 | if df.ContainsKv(kvIdx) { |
| 413 | return df.WriteMeta(kvIdx, b) |
| 414 | } |
| 415 | } |
| 416 | return fmt.Errorf("kv not found: the shard is not completed?") |
| 417 | } |
| 418 | |
| 419 | func (ds *DataShard) ReadMeta(kvIdx uint64) ([]byte, error) { |
| 420 | for _, df := range ds.dataFiles { |