fix(dynamic_conf) fix watch

fix(dynamic_conf) fix watch fix(dynamic_conf) fix watch fix(dynamic_conf) fix watch
jzero-io · Dec 19, 2024 · 9c49528 · 9c49528
1 parent 07bad4b
commit 9c49528
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/dynamic_conf/fsnotify.go b/dynamic_conf/fsnotify.go
@@ -35,8 +35,12 @@ func (lf *FsNotify) AddListener(listener func()) error {
 				if !ok {
 					return
 				}
-				if event.Has(fsnotify.Write) {
+				logx.Infof("%s %s", event.Name, event.Op)
+				if event.Has(fsnotify.Write) || event.Has(fsnotify.Rename) {
 					listener()
+					if err := lf.Watcher.Add(event.Name); err != nil {
+						logx.Errorf("add watch error: %v", err)
+					}
 				}
 			case err, ok := <-lf.Watcher.Errors:
 				if !ok {