diff --git a/pkg/event/driver.go b/pkg/event/driver.go
index b5c5636..764ff22 100644
--- a/pkg/event/driver.go
+++ b/pkg/event/driver.go
@@ -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{