diff --git a/pkg/event/event.go b/pkg/event/event.go index bc22629..54139be 100644 --- a/pkg/event/event.go +++ b/pkg/event/event.go @@ -84,6 +84,7 @@ func NewEventQueue(c chan Events, flushThreshold int, flushInterval time.Duratio eq := &EventQueue{ C: c, flushThreshold: flushThreshold, + flushInterval: flushInterval, flushTicker: ticker, q: make([]Event, 0, flushThreshold), eventsFlushed: eventsFlushed,