Skip to content

Commit

Permalink
doc: [skip-e2e] add comments for task queue (#33388)
Browse files Browse the repository at this point in the history
Add comments for task queue in internal/proxy/task_scheduler.go.

Signed-off-by: ArenaSu <704427617@qq.com>
  • Loading branch information
ArenaSu committed May 27, 2024
1 parent 0d3272e commit a59ed65
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions internal/proxy/task_scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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

Expand Down Expand Up @@ -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
}
Expand Down

0 comments on commit a59ed65

Please sign in to comment.