code: func NewBroadcaster() EventBroadcaster {
  	return &eventBroadcasterImpl{
  		Broadcaster:   watch.NewBroadcaster(maxQueuedEvents, watch.DropIfChannelFull),
  		sleepDuration: defaultSleepDuration,
  	}
  }
docs: // Creates a new event broadcaster.