()
| 43 | } |
| 44 | |
| 45 | func (em *EventManager) GetEventsProcessedFail() int64 { |
| 46 | return atomic.LoadInt64(&em.eventsProcessedFail) |
| 47 | } |
| 48 | |
| 49 | func (em *EventManager) IncrementEventsProcessedFail(delta int64) int64 { |
| 50 | return atomic.AddInt64(&em.eventsProcessedFail, delta) |
no outgoing calls