Versions in this module Expand all Collapse all v2 v2.6.6 Dec 3, 2025 Changes in this version + type MergeTask interface + MergeWith func(Task) bool + type Scheduler interface + Add func(task Task) error + GetWaitingTaskTotal func() int64 + GetWaitingTaskTotalNQ func() int64 + Start func() + Stop func() + func NewScheduler(policyName string) Scheduler + type Task interface + Canceled func() error + Done func(err error) + Execute func() error + IsGpuIndex func() bool + NQ func() int64 + PreExecute func() error + SearchResult func() *internalpb.SearchResults + Username func() string + Wait func() error