()
| 35 | } |
| 36 | |
| 37 | func (em *EventManager) GetEventsProcessedSuccess() int64 { |
| 38 | return atomic.LoadInt64(&em.eventsProcessedSuccess) |
| 39 | } |
| 40 | |
| 41 | func (em *EventManager) IncrementEventsProcessedSuccess(delta int64) int64 { |
| 42 | return atomic.AddInt64(&em.eventsProcessedSuccess, delta) |
no outgoing calls