// NewEventQueue creates an EventQueue with a callback function. The callback
// function processFunc is executed for each event in the queue.
NewEventQueue creates an EventQueue with a callback function. The callback
function processFunc is executed for each event in the queue.
// NewEventQueue creates an EventQueue with a callback function . The callback // function processFunc is executed for each event in the queue .
func NewEventQueue(processFunc func(interface{}) (bool, error)) *EventQueue {
	q := &EventQueue{
		queue:              workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()),
		process:            processFunc,
		workerFinished:     make(chan struct{}),
		lastEventTimestamp: int64(0),
	}
	return q
}
func NewEventQueue ( processFunc func ( interface { } ) ( bool , error ) ) * EventQueue { q := & EventQueue { queue : workqueue . NewRateLimitingQueue ( workqueue . DefaultControllerRateLimiter ( ) ) , process : processFunc , workerFinished : make ( chan struct { } ) , lastEventTimestamp : int64 ( 0 ) , } return q }
NewEventQueue creates an EventQueue with a callback function.
NewEventQueue creates an EventQueue with a callback function .