SQuiz/answerer
2
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix layout

Browse Source
This commit is contained in:
Pavel 2024-11-01 15:23:11 +03:00
parent ee87358441
commit e2386df0ad
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/app/app.go
View File

@ -9,7 +9,7 @@ import (
"go.uber.org/zap/zapcore" "go.uber.org/zap/zapcore"
"penahub.gitlab.yandexcloud.net/backend/quiz/answerer/internal/initialize" "penahub.gitlab.yandexcloud.net/backend/quiz/answerer/internal/initialize"
"penahub.gitlab.yandexcloud.net/backend/quiz/answerer/internal/models" "penahub.gitlab.yandexcloud.net/backend/quiz/answerer/internal/models"
savewc2 "penahub.gitlab.yandexcloud.net/backend/quiz/answerer/internal/savewc" savewc "penahub.gitlab.yandexcloud.net/backend/quiz/answerer/internal/savewc"
"penahub.gitlab.yandexcloud.net/backend/quiz/answerer/internal/server/http" "penahub.gitlab.yandexcloud.net/backend/quiz/answerer/internal/server/http"
"penahub.gitlab.yandexcloud.net/backend/quiz/answerer/pkg/closer" "penahub.gitlab.yandexcloud.net/backend/quiz/answerer/pkg/closer"
"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/model" "penahub.gitlab.yandexcloud.net/backend/quiz/common.git/model"
@ -102,17 +102,17 @@ func New(ctx context.Context, cfg initialize.Config, build Build) error {
workerSendClientCh := make(chan model.Answer, 50) workerSendClientCh := make(chan model.Answer, 50)
workerRespondentCh := make(chan []model.Answer, 50) workerRespondentCh := make(chan []model.Answer, 50)
saveRespWcData := savewc2.DepsForResp{ saveRespWcData := savewc.DepsForResp{
WorkerRespondentCh: workerRespondentCh, WorkerRespondentCh: workerRespondentCh,
Redis: redisClient, Redis: redisClient,
} }
saveClientWcData := savewc2.DepsForClient{ saveClientWcData := savewc.DepsForClient{
WorkerSendClientCh: workerSendClientCh, WorkerSendClientCh: workerSendClientCh,
Redis: redisClient, Redis: redisClient,
} }
saveRespWorker := savewc2.NewSaveRespWorker(saveRespWcData, errChan, loggerHlog) saveRespWorker := savewc.NewSaveRespWorker(saveRespWcData, errChan, loggerHlog)
saveClientWorker := savewc2.NewSaveClientWorker(saveClientWcData, errChan, loggerHlog) saveClientWorker := savewc.NewSaveClientWorker(saveClientWcData, errChan, loggerHlog)
go saveRespWorker.Start(ctx) go saveRespWorker.Start(ctx)
go saveClientWorker.Start(ctx) go saveClientWorker.Start(ctx)