blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-11-05 21:02:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: unified naming for module startup functions.

Browse Source
This commit is contained in:
Gordon 2024-03-19 19:57:33 +08:00
parent 3e25deef07
commit 952160e0c9
5 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/api/route.go
View File

@ -104,7 +104,7 @@ func Start(ctx context.Context, config *config.GlobalConfig, port int, proPort i
} }
server := http.Server{Addr: address, Handler: router} server := http.Server{Addr: address, Handler: router}
log.CInfo(ctx, "api server starting", "address", address, "apiPort", port, log.CInfo(ctx, "API server is initializing", "address", address, "apiPort", port,
"prometheusPort", proPort) "prometheusPort", proPort)
go func() { go func() {
err = server.ListenAndServe() err = server.ListenAndServe()

2
internal/msggateway/init.go
View File

@ -24,7 +24,7 @@ import (
// Start run ws server. // Start run ws server.
func Start(ctx context.Context, conf *config.GlobalConfig, rpcPort, wsPort, prometheusPort int) error { func Start(ctx context.Context, conf *config.GlobalConfig, rpcPort, wsPort, prometheusPort int) error {
log.CInfo(ctx, "msg_gateway server starting", "rpcPort", rpcPort, "wsPort", wsPort, log.CInfo(ctx, "MSG-GATEWAY server is initializing", "rpcPort", rpcPort, "wsPort", wsPort,
"prometheusPort", prometheusPort) "prometheusPort", prometheusPort)
longServer, err := NewWsServer( longServer, err := NewWsServer(
conf, conf,

8
internal/msgtransfer/init.go
View File

@ -54,6 +54,8 @@ type MsgTransfer struct {
} }
func Start(ctx context.Context, config *config.GlobalConfig, prometheusPort, index int) error { func Start(ctx context.Context, config *config.GlobalConfig, prometheusPort, index int) error {
log.CInfo(ctx, "MSG-TRANSFER server is initializing",
"prometheusPort", prometheusPort, "index", index)
rdb, err := cache.NewRedis(ctx, &config.Redis) rdb, err := cache.NewRedis(ctx, &config.Redis)
if err != nil { if err != nil {
return err return err
@ -89,7 +91,7 @@ func Start(ctx context.Context, config *config.GlobalConfig, prometheusPort, ind
if err != nil { if err != nil {
return err return err
} }
return msgTransfer.Start(ctx, prometheusPort, config, index) return msgTransfer.Start(prometheusPort, config, index)
} }
func NewMsgTransfer(kafkaConf *config.Kafka, msgDatabase controller.CommonMsgDatabase, conversationRpcClient *rpcclient.ConversationRpcClient, groupRpcClient *rpcclient.GroupRpcClient) (*MsgTransfer, error) { func NewMsgTransfer(kafkaConf *config.Kafka, msgDatabase controller.CommonMsgDatabase, conversationRpcClient *rpcclient.ConversationRpcClient, groupRpcClient *rpcclient.GroupRpcClient) (*MsgTransfer, error) {
@ -108,9 +110,7 @@ func NewMsgTransfer(kafkaConf *config.Kafka, msgDatabase controller.CommonMsgDat
}, nil }, nil
} }
func (m *MsgTransfer) Start(ctx context.Context, prometheusPort int, config *config.GlobalConfig, index int) error { func (m *MsgTransfer) Start(prometheusPort int, config *config.GlobalConfig, index int) error {
log.CInfo(ctx, "msg_transfer server starting",
"prometheusPort", prometheusPort, "index", index)
if prometheusPort <= 0 { if prometheusPort <= 0 {
return errs.WrapMsg(errors.New("invalid prometheus port"), "prometheusPort validation failed", "providedPort", prometheusPort) return errs.WrapMsg(errors.New("invalid prometheus port"), "prometheusPort validation failed", "providedPort", prometheusPort)
} }

2
internal/tools/cron_task.go
View File

@ -31,7 +31,7 @@ import (
func StartTask(ctx context.Context, config *config.GlobalConfig) error { 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 is initializing", "chatRecordsClearTime", config.ChatRecordsClearTime, "msgDestructTime", config.MsgDestructTime)
msgTool, err := InitMsgTool(ctx, config) msgTool, err := InitMsgTool(ctx, config)
if err != nil { if err != nil {

2
pkg/common/startrpc/start.go
View File

@ -48,7 +48,7 @@ import (
// Start rpc server. // Start rpc server.
func Start(ctx context.Context, rpcPort int, rpcRegisterName string, prometheusPort int, config *config2.GlobalConfig, rpcFn func(ctx context.Context, config *config.GlobalConfig, client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error, options ...grpc.ServerOption) error { func Start(ctx context.Context, rpcPort int, rpcRegisterName string, prometheusPort int, config *config2.GlobalConfig, rpcFn func(ctx context.Context, config *config.GlobalConfig, client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error, options ...grpc.ServerOption) error {
log.CInfo(ctx, "rpc server starting", "rpcRegisterName", rpcRegisterName, "rpcPort", rpcPort, log.CInfo(ctx, "RPC server is initializing", "rpcRegisterName", rpcRegisterName, "rpcPort", rpcPort,
"prometheusPort", prometheusPort) "prometheusPort", prometheusPort)
rpcTcpAddr := net.JoinHostPort(network.GetListenIP(config.Rpc.ListenIP), strconv.Itoa(rpcPort)) rpcTcpAddr := net.JoinHostPort(network.GetListenIP(config.Rpc.ListenIP), strconv.Itoa(rpcPort))
listener, err := net.Listen( listener, err := net.Listen(