Method getChangeCountInBucketChanges

tx.go:771–809

()

}

func (tx *Tx) getChangeCountInBucketChanges() int64 {
	var res int64
	f := func(bucket *core.Bucket) error {
		bucketId := bucket.Id
		if bucket.Meta.Op == core.BucketDeleteOperation {
			switch bucket.Ds {
			case DataStructureBTree:
				if bTree, ok := tx.db.Index.BTree.Idx[bucketId]; ok {
					res -= int64(bTree.Count())
				}
			case DataStructureSet:
				if set, ok := tx.db.Index.Set.Idx[bucketId]; ok {
					for key := range set.M {
						res -= int64(set.SCard(key))
					}
				}
			case DataStructureSortedSet:
				if sortedSet, ok := tx.db.Index.SortedSet.Idx[bucketId]; ok {
					for key := range sortedSet.M {
						curLen, _ := sortedSet.ZCard(key)
						res -= int64(curLen)
					}
				}
			case DataStructureList:
				if list, ok := tx.db.Index.List.Idx[bucketId]; ok {
					for key := range list.Items {
						curLen, _ := list.Size(key)
						res -= int64(curLen)
					}
				}
			default:
				panic(fmt.Sprintf("there is an unexpected data structure that is unimplemented in our database.:%d", bucket.Ds))
			}
		}
		return nil
	}
	_ = tx.pendingBucketList.rangeBucket(f)
	return res
}

// getBucketAndItsStatus, get bucket and it is status in pendingBucketList,
// if bucket is already in bucket manager but not in pendingList, will return BucketStatusExistAlready.