// EnqueueCanSkip adds an event with parameter el as payload. User can specify if
// this event should be skippable by setting the boolean parameter skip.
EnqueueCanSkip adds an event with parameter el as payload. User can specify if
this event should be skippable by setting the boolean parameter skip.
// EnqueueCanSkip adds an event with parameter el as payload . User can specify if // this event should be skippable by setting the boolean parameter skip .
func (q *EventQueue) EnqueueCanSkip(el interface{}, skip bool) {
	if q.queue.ShuttingDown() {
		glog.Errorf("queue is shutting down, unable to enqueue event")
		return
	}
	now := time.Now().UnixNano()
	glog.V(1).Infof("Enqueuing skip(%v) item", skip)
	v := eventQueueElement{
		Element:   el,
		Timestamp: now,
		CanSkip:   skip,
	}
	q.queue.Add(v)
}
func ( q * EventQueue ) EnqueueCanSkip ( el interface { } , skip bool ) { if q . queue . ShuttingDown ( ) { glog . Errorf ( " " ) return } now := time . Now ( ) . UnixNano ( ) glog . V ( 1 ) . Infof ( " " , skip ) v := eventQueueElement { Element : el , Timestamp : now , CanSkip : skip , } q . queue . Add ( v ) }
EnqueueCanSkip adds an event with parameter el as payload.
EnqueueCanSkip adds an event with parameter el as payload .
// Queue is shutting down will not be able to enqueue this.