(bucketId core.BucketId, key, value string)
| 424 | } |
| 425 | |
| 426 | func (tx *Tx) keyExistsInSortedSet(bucketId core.BucketId, key, value string) bool { |
| 427 | if _, exist := tx.db.Index.SortedSet.exist(bucketId); !exist { |
| 428 | return false |
| 429 | } |
| 430 | newKey := key |
| 431 | if strings.Contains(key, SeparatorForZSetKey) { |
| 432 | newKey, _ = splitStringFloat64Str(key, SeparatorForZSetKey) |
| 433 | } |
| 434 | exists, _ := tx.db.Index.SortedSet.Idx[bucketId].ZExist(newKey, []byte(value)) |
| 435 | return exists |
| 436 | } |
| 437 | |
| 438 | func (tx *Tx) getEntryNewAddRecordCount(entry *core.Entry) (int64, error) { |
| 439 | var res int64 |
no test coverage detected