change tron scan logic

This commit is contained in:
line-6000
2026-04-28 15:28:00 +08:00
parent 51a2accd9f
commit d17d212c24
2 changed files with 34 additions and 2 deletions
+12 -1
View File
@@ -16,13 +16,24 @@ func Start() {
go StartTronBlockScannerListener()
c := cron.New()
// Solana polling
_, err := c.AddJob("@every 5s", ListenSolJob{})
if err != nil {
log.Sugar.Errorf("[task] Failed to add ListenSolJob: %v", err)
return
}
log.Sugar.Info("[task] ListenSolJob scheduled successfully (@every 5s)")
// RPC node health checks
_, err := c.AddJob("@every 30s", RpcHealthJob{})
_, err = c.AddJob("@every 30s", RpcHealthJob{})
if err != nil {
log.Sugar.Errorf("[task] Failed to add RpcHealthJob: %v", err)
return
}
log.Sugar.Info("[task] RpcHealthJob scheduled successfully (@every 30s)")
c.Start()
log.Sugar.Info("[task] Task scheduler started")
}