From a59ed65c48a41fde97670bdc4cde6a2bc7d3230a Mon Sep 17 00:00:00 2001 From: ArenaSu <704427617@qq.com> Date: Mon, 27 May 2024 20:51:42 +0800 Subject: [PATCH] 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> --- internal/proxy/task_scheduler.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/proxy/task_scheduler.go b/internal/proxy/task_scheduler.go index 9d8b899f81..6c3adbfda3 100644 --- a/internal/proxy/task_scheduler.go +++ b/internal/proxy/task_scheduler.go @@ -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 }