Method Start

db/event_manager.go:67–101

Starts the listener queue for the event manager

(ctx context.Context, maxProcesses uint, waitTime int)

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

	if maxProcesses == 0 {
		maxProcesses = kMaxActiveEvents
	}
	if waitTime < 0 {
		em.waitTime = kEventWaitTime
	} else {
		em.waitTime = waitTime
	}

	base.InfofCtx(ctx, base.KeyEvents, "Starting event manager with max processes:%d, wait time:%d ms", maxProcesses, em.waitTime)
	// activeCountChannel limits the number of concurrent events being processed
	em.activeCountChannel = make(chan bool, maxProcesses)

	// asyncEventChannel stores the incoming events.  It's set to 3x activeCountChannel, to
	// handle temporary spikes in event inflow
	em.asyncEventChannel = make(chan Event, 3*maxProcesses)

	// Start the event channel worker go routine, which will work the event queue and spawn goroutines to process the
	// event.  Blocks if the activeCountChannel is full, to prevent spawning more than cap(activeCountChannel)
	// goroutines.
	go func() {
		for {
			select {
			case <-em.terminator:
				return
			case event := <-em.asyncEventChannel:
				em.activeCountChannel <- true
				go em.ProcessEvent(ctx, event)
			}
		}
	}()

}

// Concurrent processing of all async event handlers registered for the event type
func (em *EventManager) ProcessEvent(ctx context.Context, event Event) {