Schedule periodic scan before starting initial scan
This commit is contained in:
+6
-6
@@ -117,15 +117,9 @@ func startSignaler() (func() error, func(err error)) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func schedulePeriodicScan(schedule string) {
|
func schedulePeriodicScan(schedule string) {
|
||||||
time.Sleep(2 * time.Second) // Wait 2 seconds before the first scan
|
|
||||||
scanner := GetScanner()
|
scanner := GetScanner()
|
||||||
scheduler := GetScheduler()
|
scheduler := GetScheduler()
|
||||||
|
|
||||||
log.Info("Executing initial scan")
|
|
||||||
if err := scanner.RescanAll(context.Background(), false); err != nil {
|
|
||||||
log.Error("Error executing initial scan", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Info("Scheduling periodic scan", "schedule", schedule)
|
log.Info("Scheduling periodic scan", "schedule", schedule)
|
||||||
err := scheduler.Add(schedule, func() {
|
err := scheduler.Add(schedule, func() {
|
||||||
_ = scanner.RescanAll(context.Background(), false)
|
_ = scanner.RescanAll(context.Background(), false)
|
||||||
@@ -133,6 +127,12 @@ func schedulePeriodicScan(schedule string) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error("Error scheduling periodic scan", err)
|
log.Error("Error scheduling periodic scan", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
time.Sleep(2 * time.Second) // Wait 2 seconds before the initial scan
|
||||||
|
log.Info("Executing initial scan")
|
||||||
|
if err := scanner.RescanAll(context.Background(), false); err != nil {
|
||||||
|
log.Error("Error executing initial scan", err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func startScheduler() (func() error, func(err error)) {
|
func startScheduler() (func() error, func(err error)) {
|
||||||
|
|||||||
Reference in New Issue
Block a user