diff options
Diffstat (limited to 'backend/main.go')
| -rw-r--r-- | backend/main.go | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/backend/main.go b/backend/main.go index e74a62f..2825b84 100644 --- a/backend/main.go +++ b/backend/main.go @@ -8,6 +8,8 @@ import ( "os" "time" + "github.com/hibiken/asynq" + "github.com/hibiken/asynqmon" "github.com/jackc/pgx/v5/pgxpool" "github.com/labstack/echo/v4" "github.com/labstack/echo/v4/middleware" @@ -111,6 +113,13 @@ func main() { adminGroup.Use(api.SessionCookieMiddleware(queries)) adminHandler.RegisterHandlers(adminGroup) + queueMonitor := asynqmon.New(asynqmon.Options{ + RootPath: conf.BasePath + "admin/queue", + RedisConnOpt: asynq.RedisClientOpt{Addr: "task-db:6379"}, + }) + adminGroup.Any("/queue/*", echo.WrapHandler(queueMonitor)) + adminGroup.Any("/queue", echo.WrapHandler(queueMonitor)) + if conf.IsLocal { filesGroup := e.Group(conf.BasePath + "files") filesGroup.Use(middleware.StaticWithConfig(middleware.StaticConfig{ |