diff options
| author | nsfisis <nsfisis@gmail.com> | 2024-08-05 05:35:37 +0900 |
|---|---|---|
| committer | nsfisis <nsfisis@gmail.com> | 2024-08-05 05:35:37 +0900 |
| commit | dc16e903999af89d87364ad6619e7c8b41301da4 (patch) | |
| tree | 529f1debc2972ac1486e8c0ca4b25827ccd069a6 /backend/taskqueue/worker_server.go | |
| parent | 2a551a05d714657d7cd3b581290054c97398e968 (diff) | |
| download | phperkaigi-2025-albatross-dc16e903999af89d87364ad6619e7c8b41301da4.tar.gz phperkaigi-2025-albatross-dc16e903999af89d87364ad6619e7c8b41301da4.tar.zst phperkaigi-2025-albatross-dc16e903999af89d87364ad6619e7c8b41301da4.zip | |
feat: show execution result in play page
Diffstat (limited to 'backend/taskqueue/worker_server.go')
| -rw-r--r-- | backend/taskqueue/worker_server.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/backend/taskqueue/worker_server.go b/backend/taskqueue/worker_server.go index 09d9761..485d6d3 100644 --- a/backend/taskqueue/worker_server.go +++ b/backend/taskqueue/worker_server.go @@ -9,9 +9,10 @@ import ( type WorkerServer struct { server *asynq.Server queries *db.Queries + c chan string } -func NewWorkerServer(redisAddr string, queries *db.Queries) *WorkerServer { +func NewWorkerServer(redisAddr string, queries *db.Queries, c chan string) *WorkerServer { return &WorkerServer{ server: asynq.NewServer( asynq.RedisClientOpt{ @@ -19,12 +20,14 @@ func NewWorkerServer(redisAddr string, queries *db.Queries) *WorkerServer { }, asynq.Config{}, ), + queries: queries, + c: c, } } func (s *WorkerServer) Run() error { mux := asynq.NewServeMux() - mux.Handle(TaskTypeExec, NewExecProcessor(s.queries)) + mux.Handle(TaskTypeExec, NewExecProcessor(s.queries, s.c)) return s.server.Run(mux) } |