()
| 300 | } |
| 301 | |
| 302 | func (tx *Tx) getNewAddRecordCount() (int64, error) { |
| 303 | var res int64 |
| 304 | changeCountInEntries, err := tx.getChangeCountInEntriesChanges() |
| 305 | changeCountInBucket := tx.getChangeCountInBucketChanges() |
| 306 | res += changeCountInEntries |
| 307 | res += changeCountInBucket |
| 308 | return res, err |
| 309 | } |
| 310 | |
| 311 | func (tx *Tx) getListEntryNewAddRecordCount(bucketId core.BucketId, entry *core.Entry) (int64, error) { |
| 312 | if entry.Meta.Flag == DataExpireListFlag { |
no test coverage detected