code: func (p *ExamplePlugin) Init() error {
  	p.Log.Info("Init plugin..")
  	// Initialize plugin fields.
  	p.resyncChannel = make(chan datasync.ResyncEvent)
  	p.changeChannel = make(chan datasync.ChangeEvent)
  
  	p.context, p.cancel = context.WithCancel(context.Background())
  
  	// Start the consumer (ETCD watcher).
  	p.wg.Add(1)
  	go p.consumer()
  
  	// Subscribe watcher to be able to watch on data changes and resync events.
  	err := p.subscribeWatcher()
  	if err != nil {
  		return err
  	}
  
  	p.Log.Info("Plugin Init for datasync example done")
  
  	return nil
  }
docs: // Init starts the consumer.