p25734189
/
wheat-cache
forked from p93542168/wheat-cache
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

feat(worker): feat get the io

This commit is contained in:
HuangJiaLuo 2021-10-09 10:35:03 +08:00
parent b168eecbb4
commit 929f931cd6
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/event/driver.go
View File

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