code: func (p *ExamplePlugin) Close() error {
  	p.Log.Info("Close plugin..")
  	// Close the watcher
  	p.cancel()
  	p.wg.Wait()
  	return nil
  }
docs: // Close shutdowns both the publisher and the consumer.
  // Channels used to propagate data resync and data change events are closed
  // as well.