mirror of
https://gitee.com/milvus-io/milvus.git
synced 2026-01-06 19:02:18 +08:00
23 lines
494 B
Go
23 lines
494 B
Go
package master
|
|
|
|
type ddRequestScheduler struct {
|
|
globalIDAllocator func() (UniqueID, error)
|
|
reqQueue chan task
|
|
scheduleTimeStamp Timestamp
|
|
}
|
|
|
|
func NewDDRequestScheduler(allocGlobalID func() (UniqueID, error)) *ddRequestScheduler {
|
|
const channelSize = 1024
|
|
|
|
rs := ddRequestScheduler{
|
|
globalIDAllocator: allocGlobalID,
|
|
reqQueue: make(chan task, channelSize),
|
|
}
|
|
return &rs
|
|
}
|
|
|
|
func (rs *ddRequestScheduler) Enqueue(task task) error {
|
|
rs.reqQueue <- task
|
|
return nil
|
|
}
|