milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

doc: [skip-e2e] add comments for task queue (#33388) 

Add comments for task queue in internal/proxy/task_scheduler.go.

Signed-off-by: ArenaSu <704427617@qq.com>
pull/33378/head
ArenaSu 2024-05-27 20:51:42 +08:00 committed by GitHub
parent 0d3272ed6d
commit a59ed65c48
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/proxy/task_scheduler.go
View File

@ -219,6 +219,7 @@ func newBaseTaskQueue(tsoAllocatorIns tsoAllocator) *baseTaskQueue {
}
}
// ddTaskQueue represents queue for DDL task such as createCollection/createPartition/dropCollection/dropPartition/hasCollection/hasPartition
type ddTaskQueue struct {
*baseTaskQueue
lock sync.Mutex
@ -229,6 +230,7 @@ type pChanStatInfo struct {
tsSet map[Timestamp]struct{}
}
// dmTaskQueue represents queue for DML task such as insert/delete/upsert
type dmTaskQueue struct {
*baseTaskQueue
@ -351,6 +353,7 @@ func (queue *dmTaskQueue) getPChanStatsInfo() (map[pChan]*pChanStatistics, error
return ret, nil
}
// dqTaskQueue represents queue for DQL task such as search/query
type dqTaskQueue struct {
*baseTaskQueue
}