Skip to content

Commit

Permalink
Adding debug logs for change detection
Browse files Browse the repository at this point in the history
  • Loading branch information
Zohaib Sibte Hassan committed Dec 28, 2023
1 parent 57177a2 commit 6de1089
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions db/change_log.go
Original file line number Diff line number Diff line change
Expand Up @@ -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()
}

Expand Down

0 comments on commit 6de1089

Please sign in to comment.