Method IncrementEventsProcessedFail

db/event_manager.go:49–51

(delta int64)

}

func (em *EventManager) IncrementEventsProcessedFail(delta int64) int64 {
	return atomic.AddInt64(&em.eventsProcessedFail, delta)
}

const kMaxActiveEvents = 500 // number of events that are processed concurrently
const kEventWaitTime = 100   // time (ms) to wait before dropping event, when event queue is full