Commit f639c467 authored by Vivek Naik's avatar Vivek Naik
Browse files

add: method to get bucket by index id in corefdb

parent f32e1c47
2 merge requests!11331 Aug MEP Merge Dev to Stg,!107Add: Pack bucket and lazy writing indexes
Showing with 23 additions and 0 deletions
...@@ -1945,3 +1945,26 @@ func DeleteDataFromFDB(dbName string, indexID string, rs *gjson.Result, queries ...@@ -1945,3 +1945,26 @@ func DeleteDataFromFDB(dbName string, indexID string, rs *gjson.Result, queries
} }
return errList return errList
} }
// GetBucketByIndexID - return bucket by specified indexID
func GetBucketByIndexID(dbName, indexID string) (Bucket, error) {
fdb, err := GetFDBInstance(dbName)
bucket := Bucket{}
if err != nil {
loggermdl.LogError("fdb instance not found for: ", dbName)
return bucket, err
}
index, ok := fdb.GetFDBIndex(indexID)
if !ok {
loggermdl.LogError("index not found: " + indexID)
return bucket, errormdl.Wrap("index not found: " + indexID)
}
bucketID := index.BucketSequence[len(index.BucketSequence)-1]
bucketPtr, ok := fdb.buckets[bucketID]
if !ok {
loggermdl.LogError("Bucket not found: " + bucketID)
return bucket, errormdl.Wrap("Bucket not found: " + bucketID)
}
return *bucketPtr, nil
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment