add worker for refresh

KyberNetwork · Feb 14, 2025 · ffadf9e · ffadf9e
1 parent 1bdaf1f
commit ffadf9e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/v2/cmd/tradelogs/main.go b/v2/cmd/tradelogs/main.go
@@ -71,7 +71,7 @@ func run(c *cli.Context) error {
 	}
 	dashStorage := dashboardStorage.New(l, db)
 	mviewRefresher := worker.NewRefresher(dashStorage, l)
-	go mviewRefresher.ScheduleMViewRefresh()
+	go mviewRefresher.Run()
 	s := server.NewTradeLogs(l, storage, dashStorage, c.String(libapp.HTTPTradeLogsServerFlag.Name))
 	return s.Run()
 }

diff --git a/v2/internal/worker/mview_refresher.go b/v2/internal/worker/mview_refresher.go
@@ -19,6 +19,10 @@ func NewRefresher(dashStorage *dashboardStorage.Storage, l *zap.SugaredLogger) *
 	}
 }
 
+func (r *Refresher) Run() {
+	r.ScheduleMViewRefresh()
+}
+
 func (r *Refresher) ScheduleMViewRefresh() {
 	ticker := time.NewTicker(24 * time.Hour)
 	defer ticker.Stop()