code: func (daemon *Daemon) ProcessClusterNotifications(ctx context.Context, watchStream chan *swarmapi.WatchMessage) {
  	for {
  		select {
  		case <-ctx.Done():
  			return
  		case message, ok := <-watchStream:
  			if !ok {
  				logrus.Debug("cluster event channel has stopped")
  				return
  			}
  			daemon.generateClusterEvent(message)
  		}
  	}
  }
docs: // ProcessClusterNotifications gets changes from store and add them to event list