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