Method AddEvent

backend/event/event.go:36–55

AddEvent adds a count to the event counter.

(key string, f func())

// AddEvent adds a count to the event counter.
func (ec *EventProcessor) AddEvent(key string, f func()) {
	ec.mu.Lock()
	defer ec.mu.Unlock()

	if elem, exists := ec.events[key]; exists {
		ec.order.Remove(elem)
		delete(ec.events, key)
	}
	if len(ec.events) >= ec.maxEvents {
		oldest := ec.order.Front()
		if oldest != nil {
			entry := oldest.Value.(*eventEntry)
			delete(ec.events, entry.key)
			ec.order.Remove(oldest)
		}
	}
	entry := &eventEntry{key: key, fn: f}
	elem := ec.order.PushBack(entry)
	ec.events[key] = elem
}

func (ec *EventProcessor) Run() {
	defer ec.ticker.Stop()