refactor: unified naming for module startup functions.

pull/2100/head
Gordon 2 years ago
parent 952160e0c9
commit 8ad2913811

@ -81,7 +81,7 @@ func NewRedis(ctx context.Context, redisConf *config.Redis) (redis.UniversalClie
return nil, errs.WrapMsg(err, errMsg) return nil, errs.WrapMsg(err, errMsg)
} }
redisClient = rdb redisClient = rdb
log.CInfo(ctx, "redis connected successfully", "address", redisConf.Address, "username", redisConf.Username, "password", redisConf.Password, "clusterMode", redisConf.ClusterMode, "enablePipeline", redisConf.EnablePipeline) log.CInfo(ctx, "REDIS connected successfully", "address", redisConf.Address, "username", redisConf.Username, "password", redisConf.Password, "clusterMode", redisConf.ClusterMode, "enablePipeline", redisConf.EnablePipeline)
return rdb, err return rdb, err
} }

@ -58,7 +58,7 @@ func NewMongoDB(ctx context.Context, mongoConf *config.Mongo) (*Mongo, error) {
if err = mongoClient.Ping(ctx, nil); err != nil { if err = mongoClient.Ping(ctx, nil); err != nil {
return nil, errs.WrapMsg(err, uri) return nil, errs.WrapMsg(err, uri)
} }
log.CInfo(ctx, "MongoDB connected", "uri", uri) log.CInfo(ctx, "MONGODB connected successfully", "uri", uri)
return &Mongo{db: mongoClient, mongoConf: mongoConf}, nil return &Mongo{db: mongoClient, mongoConf: mongoConf}, nil
} }
if shouldRetry(err) { if shouldRetry(err) {

Loading…
Cancel
Save