feat(worker): feat get the io

This commit is contained in:
HuangJiaLuo 2021-10-09 10:35:03 +08:00
parent aac12f93f4
commit cf1c90442b
1 changed files with 4 additions and 0 deletions
pkg/event

View File

@ -137,6 +137,10 @@ func (d *Driver) Put(event *Event) {
d.queue <- event
}
func (d *Driver) GetLength() int {
return len(d.queue)
}
// NewDriver 新建 Driver
func NewDriver(maxSize int) DriverInterface {
return &Driver{