func()

in pkg/events/events.go [178:191]


func (ev *events) reconcileEventsDataChannelHandler(pollerCh <-chan int) {
	for {
		select {
		case bufferPtr, ok := <-pollerCh:
			if !ok {
				return
			}
			ev.readRingBuffer(ev.RingBuffers[bufferPtr])

		case <-ev.eventsStopChannel:
			return
		}
	}
}