From 6de10892a85a1689ac1445c6bc8acb5e4e6d9e8d Mon Sep 17 00:00:00 2001 From: Zohaib Sibte Hassan Date: Thu, 28 Dec 2023 09:27:55 -0800 Subject: [PATCH] Adding debug logs for change detection --- db/change_log.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/db/change_log.go b/db/change_log.go index 64e4aab..3f961d3 100644 --- a/db/change_log.go +++ b/db/change_log.go @@ -278,9 +278,11 @@ func (conn *SqliteStreamDB) watchChanges(watcher *fsnotify.Watcher, path string) } if ev.Op != fsnotify.Chmod { + log.Debug().Int("change", int(ev.Op)).Msg("Change detected") conn.publishChangeLog() } case <-changeLogTicker.Channel(): + log.Debug().Dur("timeout", tickerDur).Msg("Change polling timeout") conn.publishChangeLog() }