mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-12-30 22:37:04 +08:00
refactor: unified naming for module startup functions.
This commit is contained in:
parent
1b62cb1b22
commit
6c8b7de786
@ -33,7 +33,7 @@ func StartTask(ctx context.Context, config *config.GlobalConfig) error {
|
|||||||
|
|
||||||
log.CInfo(ctx, "cron task server starting", "chatRecordsClearTime", config.ChatRecordsClearTime, "msgDestructTime", config.MsgDestructTime)
|
log.CInfo(ctx, "cron task server starting", "chatRecordsClearTime", config.ChatRecordsClearTime, "msgDestructTime", config.MsgDestructTime)
|
||||||
|
|
||||||
msgTool, err := InitMsgTool(config)
|
msgTool, err := InitMsgTool(ctx, config)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
@ -63,12 +63,12 @@ func NewMsgTool(msgDatabase controller.CommonMsgDatabase, userDatabase controlle
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func InitMsgTool(config *config.GlobalConfig) (*MsgTool, error) {
|
func InitMsgTool(ctx context.Context, config *config.GlobalConfig) (*MsgTool, error) {
|
||||||
rdb, err := cache.NewRedis(&config.Redis)
|
rdb, err := cache.NewRedis(ctx, &config.Redis)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
mongo, err := unrelation.NewMongoDB(&config.Mongo)
|
mongo, err := unrelation.NewMongoDB(ctx, &config.Mongo)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user