Notification des changements sur des fichiers ou des répertoires

Imaginons que souhaitiez rafraîchir la configuration de votre application ou la map des templates que vous avez en cache sans relancer l'application. Dans cet article, nous verrons comment faire. C'est-à-dire comment appeler une fonction dès qu'un fichier ou un répertoire est modifié.

Pour commencer, il faut inclure le package experimental fsnotify (développé par l'équipe golang, mais pas encore inclut dans la distribution officielle).

import "code.google.com/p/go.exp/fsnotify"

Il faut ensuite :

1. Créer un objet watcher (fsnotify.NewWatcher()).
2. Créer un processus léger contenant une boucle infine qui attend un évènement de modification.
3. S'abonner à un ou plusieurs types de modifications en modifiant les drapeaux (watcher.WatchFlags("./conf/config.json", fsnotify.FSN_MODIFY)). Pour s'abonner à plusieurs modifications, il suffit de cumuler les options à l'aide d'un OR (watcher.WatchFlags("./conf/config.json", fsnotify.FSN_DELETE | fsnotify.FSN_RENAME)).

// fsConfigWatcher watches if the configuration file is modified and reload the
// configuration dynamically is the file has been changed
func fsConfigWatcher() {
	watcher, err := fsnotify.NewWatcher()
	if err != nil {
		logFatal("(fsConfigWatcher) fsnotify.NewWatcher() : ", err)
	}

	go func() {
		for {
			select {
			case ev := <-watcher.Event:
				logInfo("event: %v", ev)
				file, err := ioutil.ReadFile(CONFIGURATION_FILE)
				if err != nil {
					logFatal("(main) Configuration file : ", err)
				}
				json.Unmarshal(file, &config)
			case err := <-watcher.Error:
				logInfo("error: %v", err)
			}
		}
	}()

	err = watcher.WatchFlags("./conf/config.json", fsnotify.FSN_MODIFY)
	if err != nil {
		logFatal("(fsConfigWatcher) watcher.WatchFlags(fsnotify.FSN_MODIFY) : ", err)
	}
}

S'abonner aux modifications d'un répertoire

Pour s'abonner aux modifications effectuées sur un répertoire (utile pour recharger les template mis en cache par votre application), il suffit d'indiquer un chemin vers un répertoire :

err = watcher.WatchFlags("./tmpl/", fsnotify.FSN_MODIFY)

Les autres types de modification

Les autres types de modification sont les suivants :