From c5580446462cb1c1eb92aa58fe3780169e9f23fb Mon Sep 17 00:00:00 2001 From: LittleSheep Date: Sun, 23 Feb 2025 11:43:09 +0800 Subject: [PATCH] :zap: Reduce the flush reading anchor delay --- pkg/main.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/pkg/main.go b/pkg/main.go index 8d272b5..8d586ef 100644 --- a/pkg/main.go +++ b/pkg/main.go @@ -2,12 +2,13 @@ package main import ( "fmt" - "git.solsynth.dev/hypernet/nexus/pkg/nex/sec" - "github.com/fatih/color" "os" "os/signal" "syscall" + "git.solsynth.dev/hypernet/nexus/pkg/nex/sec" + "github.com/fatih/color" + "git.solsynth.dev/hypernet/messaging/pkg/internal/gap" "git.solsynth.dev/hypernet/messaging/pkg/internal/grpc" @@ -83,7 +84,7 @@ func main() { // Configure timed tasks quartz := cron.New(cron.WithLogger(cron.VerbosePrintfLogger(&log.Logger))) quartz.AddFunc("@every 60m", services.DoAutoDatabaseCleanup) - quartz.AddFunc("@every 1m", services.FlushReadingAnchor) + quartz.AddFunc("@every 30s", services.FlushReadingAnchor) quartz.Start() // Messages