code: func (p *ExamplePlugin) subscribeWatcher() (err error) {
  	prefix := etcdKeyPrefix(p.ServiceLabel.GetAgentLabel())
  	p.Log.Infof("Prefix: %v", prefix)
  
  	p.watchDataReg, err = p.Watcher.Watch("ExamplePlugin",
  		p.changeChannel, p.resyncChannel, prefix)
  	if err != nil {
  		return err
  	}
  
  	p.Log.Info("KeyValProtoWatcher subscribed")
  
  	return nil
  }
docs: // subscribeWatcher subscribes for data change and data resync events.
  // Events are delivered to the consumer via the selected channels.
  // ETCD watcher adapter is used to perform the registration behind the scenes.