(delta int64)
| 39 | } |
| 40 | |
| 41 | func (em *EventManager) IncrementEventsProcessedSuccess(delta int64) int64 { |
| 42 | return atomic.AddInt64(&em.eventsProcessedSuccess, delta) |
| 43 | } |
| 44 | |
| 45 | func (em *EventManager) GetEventsProcessedFail() int64 { |
| 46 | return atomic.LoadInt64(&em.eventsProcessedFail) |