code: func (eq *LimitQueue) Len() int {
  	eq.mu.Lock()
  	defer eq.mu.Unlock()
  	return eq.events.Len()
  }
docs: // Len returns the number of items that are currently stored in the queue and
  // not consumed by its sink.