code: func (p *MyPlugin) Init() error {
  	if p.KVStore.Disabled() {
  		return fmt.Errorf("KV store is disabled")
  	}
  
  	watcher := p.KVStore.NewWatcher(keyPrefix)
  
  	// Start watching for changes
  	err := watcher.Watch(p.onChange, p.watchCloser, "greetings/")
  	if err != nil {
  		return err
  	}
  
  	return nil
  }
docs: // Init is executed on agent initialization.