(entry *core.Entry)
| 436 | } |
| 437 | |
| 438 | func (tx *Tx) getEntryNewAddRecordCount(entry *core.Entry) (int64, error) { |
| 439 | var res int64 |
| 440 | var err error |
| 441 | |
| 442 | bucket, err := tx.db.bucketMgr.GetBucketById(entry.Meta.BucketId) |
| 443 | if err != nil { |
| 444 | return 0, err |
| 445 | } |
| 446 | bucketId := bucket.Id |
| 447 | |
| 448 | if entry.Meta.Ds == DataStructureBTree { |
| 449 | res, err = tx.getKvEntryNewAddRecordCount(bucketId, entry) |
| 450 | } |
| 451 | |
| 452 | if entry.Meta.Ds == DataStructureList { |
| 453 | res, err = tx.getListEntryNewAddRecordCount(bucketId, entry) |
| 454 | } |
| 455 | |
| 456 | if entry.Meta.Ds == DataStructureSet { |
| 457 | res, err = tx.getSetEntryNewAddRecordCount(bucketId, entry) |
| 458 | } |
| 459 | |
| 460 | if entry.Meta.Ds == DataStructureSortedSet { |
| 461 | res, err = tx.getSortedSetEntryNewAddRecordCount(bucketId, entry) |
| 462 | } |
| 463 | |
| 464 | return res, err |
| 465 | } |
| 466 | |
| 467 | func (tx *Tx) allocCommitBuffer() *bytes.Buffer { |
| 468 | var buff *bytes.Buffer |
no test coverage detected