diff --git a/internal/proxy/task_scheduler.go b/internal/proxy/task_scheduler.go index 64b65a35b8..132cbac0ff 100644 --- a/internal/proxy/task_scheduler.go +++ b/internal/proxy/task_scheduler.go @@ -373,6 +373,7 @@ func newDqTaskQueue(tsoAllocatorIns tsoAllocator, idAllocatorIns idAllocatorInte } } +// taskScheduler schedules the gRPC tasks. type taskScheduler struct { ddQueue *ddTaskQueue dmQueue *dmTaskQueue