SQuiz/core
2
0
Fork 0
Code Issues Pull Requests 3 Actions Packages Projects Releases Wiki Activity

Update app.go

Browse Source
This commit is contained in:
Mikhail 2024-12-23 19:29:18 +00:00
parent 15cb6b447f
commit 5d33e96a58
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
app/app.go
View File

@ -22,6 +22,7 @@ import (
"penahub.gitlab.yandexcloud.net/backend/quiz/core/server" "penahub.gitlab.yandexcloud.net/backend/quiz/core/server"
"penahub.gitlab.yandexcloud.net/backend/quiz/core/service" "penahub.gitlab.yandexcloud.net/backend/quiz/core/service"
"penahub.gitlab.yandexcloud.net/backend/quiz/core/tools" "penahub.gitlab.yandexcloud.net/backend/quiz/core/tools"
"penahub.gitlab.yandexcloud.net/external/trashlog/wrappers/zaptrashlog"
"time" "time"
) )
@ -102,8 +103,14 @@ func New(ctx context.Context, opts interface{}, ver appInit.Version) (appInit.Co
zap.String("SvcBuildTime", ver.BuildTime), zap.String("SvcBuildTime", ver.BuildTime),
) )
clickHouseLogger, err := zaptrashlog.NewCore(ctx, zap.InfoLevel, options.TrashLogHost, ver.Release, ver.Commit, time.Now().Unix())
if err != nil {
panic(err)
}
loggerForHlog := zapLogger.WithOptions(zap.WrapCore(func(core zapcore.Core) zapcore.Core { loggerForHlog := zapLogger.WithOptions(zap.WrapCore(func(core zapcore.Core) zapcore.Core {
return core return zapcore.NewTee(core, clickHouseLogger)
})) }))
loggerHlog := hlog.New(loggerForHlog).Module(options.ModuleLogger) loggerHlog := hlog.New(loggerForHlog).Module(options.ModuleLogger)
@ -121,7 +128,7 @@ func New(ctx context.Context, opts interface{}, ver appInit.Version) (appInit.Co
chDal, err := dal.NewClickHouseDAL(ctx, options.ClickHouseCred) chDal, err := dal.NewClickHouseDAL(ctx, options.ClickHouseCred)
if err != nil { if err != nil {
fmt.Println("failed init clickhouse", err) fmt.Println("failed init clickhouse", err)
//return nil, err return nil, err
} }
kafkaClient, err := initialize.KafkaInit(ctx, initialize.KafkaDeps{ kafkaClient, err := initialize.KafkaInit(ctx, initialize.KafkaDeps{