blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-12-16 19:19:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

docker_script

Browse Source 
Signed-off-by: hanzhixiao <709674996@qq.com>
This commit is contained in:
hanzhixiao 2023-08-18 19:50:23 +08:00
parent 8e2ad0aadd
commit c3f0446b00
1 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
tools/component/main.go
View File

@ -49,7 +49,6 @@ func initCfg() error {
if err = yaml.Unmarshal(data, &config.Config); err != nil { if err = yaml.Unmarshal(data, &config.Config); err != nil {
return err return err
} }
fmt.Println(config.Config.Mysql.Address)
return nil return nil
} }
@ -143,12 +142,12 @@ func checkMysql() error {
config.Config.Mysql.Username, config.Config.Mysql.Password, config.Config.Mysql.Address[0], "mysql") config.Config.Mysql.Username, config.Config.Mysql.Password, config.Config.Mysql.Address[0], "mysql")
db, err := gorm.Open(mysql.Open(dsn), nil) db, err := gorm.Open(mysql.Open(dsn), nil)
if err != nil { if err != nil {
return err return errs.Wrap(err)
} else { } else {
sqlDB, err = db.DB() sqlDB, err = db.DB()
err = sqlDB.Ping() err = sqlDB.Ping()
if err != nil { if err != nil {
return err return errs.Wrap(err)
} }
} }
return nil return nil
@ -173,11 +172,11 @@ func checkMongo() error {
fmt.Sprintf("mongodb://%v:%v@%v/?authSource=admin", fmt.Sprintf("mongodb://%v:%v@%v/?authSource=admin",
config.Config.Mongo.Username, config.Config.Mongo.Password, mongodbHosts))) config.Config.Mongo.Username, config.Config.Mongo.Password, mongodbHosts)))
if err != nil { if err != nil {
return err return errs.Wrap(err)
} else { } else {
err = client.Ping(context.TODO(), &readpref.ReadPref{}) err = client.Ping(context.TODO(), &readpref.ReadPref{})
if err != nil { if err != nil {
return err return errs.Wrap(err)
} }
} }
return nil return nil
@ -192,7 +191,7 @@ func checkMinio() error {
Secure: u.Scheme == "https", Secure: u.Scheme == "https",
}) })
if err != nil { if err != nil {
return err return errs.Wrap(err)
} }
cancel, err := minioClient.HealthCheck(time.Duration(minioHealthCheckDuration) * time.Second) cancel, err := minioClient.HealthCheck(time.Duration(minioHealthCheckDuration) * time.Second)
@ -202,7 +201,7 @@ func checkMinio() error {
} }
}() }()
if err != nil { if err != nil {
return err return errs.Wrap(err)
} else { } else {
if minioClient.IsOffline() { if minioClient.IsOffline() {
return ErrComponentStart.Wrap("Minio server is offline") return ErrComponentStart.Wrap("Minio server is offline")
@ -237,7 +236,7 @@ func checkRedis() error {
} }
_, err := redisClient.Ping(context.Background()).Result() _, err := redisClient.Ping(context.Background()).Result()
if err != nil { if err != nil {
return err return errs.Wrap(err)
} }
return nil return nil
} }
@ -251,16 +250,16 @@ func checkZookeeper() error {
}() }()
c, _, err := zk.Connect(config.Config.Zookeeper.ZkAddr, time.Second) c, _, err := zk.Connect(config.Config.Zookeeper.ZkAddr, time.Second)
if err != nil { if err != nil {
return err return errs.Wrap(err)
} else { } else {
if config.Config.Zookeeper.Username != "" && config.Config.Zookeeper.Password != "" { if config.Config.Zookeeper.Username != "" && config.Config.Zookeeper.Password != "" {
if err := c.AddAuth("digest", []byte(config.Config.Zookeeper.Username+":"+config.Config.Zookeeper.Password)); err != nil { if err := c.AddAuth("digest", []byte(config.Config.Zookeeper.Username+":"+config.Config.Zookeeper.Password)); err != nil {
return err return errs.Wrap(err)
} }
} }
_, _, err = c.Get("/") _, _, err = c.Get("/")
if err != nil { if err != nil {
return err return errs.Wrap(err)
} }
} }
return nil return nil
@ -281,7 +280,7 @@ func checkKafka() error {
} }
kafkaClient, err := sarama.NewClient(config.Config.Kafka.Addr, cfg) kafkaClient, err := sarama.NewClient(config.Config.Kafka.Addr, cfg)
if err != nil { if err != nil {
return err return errs.Wrap(err)
} else { } else {
topics, err := kafkaClient.Topics() topics, err := kafkaClient.Topics()
if err != nil { if err != nil {