(shardIdx uint64, kvSize uint64, kvEntries uint64, chunkSize uint64)
| 29 | } |
| 30 | |
| 31 | func NewDataShard(shardIdx uint64, kvSize uint64, kvEntries uint64, chunkSize uint64) *DataShard { |
| 32 | if kvSize%chunkSize != 0 { |
| 33 | panic("kvSize must be CHUNK_SIZE at the moment") |
| 34 | } |
| 35 | |
| 36 | return &DataShard{shardIdx: shardIdx, kvSize: kvSize, chunksPerKv: kvSize / chunkSize, kvEntries: kvEntries, chunkSize: chunkSize} |
| 37 | } |
| 38 | |
| 39 | func (ds *DataShard) AddDataFile(df *DataFile) error { |
| 40 | if len(ds.dataFiles) != 0 { |
no outgoing calls
no test coverage detected