From d804941a181edfbb07ee0a6b841bf05301ca86e4 Mon Sep 17 00:00:00 2001
From: Chai Nadig <chaitanya.nadig@gmail.com>
Date: Thu, 14 May 2020 00:02:20 -0700
Subject: [PATCH] Set Flush Interval on EventQueue

Signed-off-by: Chai Nadig <chaitanya.nadig@gmail.com>
---
 pkg/event/event.go | 1 +
 1 file changed, 1 insertion(+)

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,