test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-01 19:39:21 +08:00
Code Issues Actions 12 Packages Projects Releases Wiki Activity

Add joinIDPath for reuse (#9650)

Browse Source 
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
This commit is contained in:
godchen 2021-10-12 17:20:33 +08:00 committed by GitHub
parent f85271cf3f
commit 13c1a1c746
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/datanode/allocator.go
View File

@ -68,7 +68,7 @@ func (alloc *allocator) allocID() (UniqueID, error) {
// genKey gives a valid key string for lists of UniqueIDs:
// if alloc is true, the returned keys will have a generated-unique ID at the end.
// if alloc is false, the returned keys will only consist of provided ids.
func (alloc *allocator) genKey(isalloc bool, ids ...UniqueID) (key string, err error) {
func (alloc *allocator) genKey(isalloc bool, ids ...UniqueID) (string, error) {
if isalloc {
idx, err := alloc.allocID()
if err != nil {
@ -76,12 +76,13 @@ func (alloc *allocator) genKey(isalloc bool, ids ...UniqueID) (key string, err e
}
ids = append(ids, idx)
}
return JoinIDPath(ids...), nil
}
func JoinIDPath(ids ...UniqueID) string {
idStr := make([]string, len(ids))
for _, id := range ids {
idStr = append(idStr, strconv.FormatInt(id, 10))
}
key = path.Join(idStr...)
return
return path.Join(idStr...)
}