ayo/gocommon
8
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

mongo ping go rountine 막음

Browse Source
This commit is contained in:
mountain
2023-11-22 18:23:41 +09:00
parent 6ad727c728
commit 343754ba7f
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
mongo.go
View File

@ -106,21 +106,21 @@ func newMongoClient(ctx context.Context, ci *ConnectionInfo) (MongoClient, error
return MongoClient{}, err return MongoClient{}, err
} }
go func() { // go func() {
for { // for {
if err := client.Ping(ctx, nil); err != nil { // if err := client.Ping(ctx, nil); err != nil {
logger.Error("mongo client ping err :", err) // logger.Error("mongo client ping err :", err)
} // }
select { // select {
case <-time.After(10 * time.Second): // case <-time.After(10 * time.Second):
continue // continue
case <-ctx.Done(): // case <-ctx.Done():
return // return
} // }
} // }
}() // }()
mdb := client.Database(ci.Database, nil) mdb := client.Database(ci.Database, nil)
return MongoClient{c: client, db: mdb}, nil return MongoClient{c: client, db: mdb}, nil