Function NewEventManager

db/event_manager.go:58–64

time (ms) to wait before dropping event, when event queue is full Creates a new event manager. Sets up the event channel for async events, and the goroutine to monitor and process that channel.

(terminator chan bool)

// Creates a new event manager.  Sets up the event channel for async events, and the goroutine to
// monitor and process that channel.
func NewEventManager(terminator chan bool) *EventManager {
	return &EventManager{
		eventHandlers:    make(map[EventType][]EventHandler, 0),
		activeEventTypes: make(map[EventType]bool),
		terminator:       terminator,
	}
}

// Starts the listener queue for the event manager
func (em *EventManager) Start(ctx context.Context, maxProcesses uint, waitTime int) {