|
9 | 9 | "time"
|
10 | 10 |
|
11 | 11 | "github.com/alecthomas/kingpin"
|
12 |
| - "go.mongodb.org/mongo-driver/bson/primitive" |
13 | 12 | "go.mongodb.org/mongo-driver/mongo"
|
14 | 13 |
|
15 | 14 | "github.com/percona/percona-backup-mongodb/pbm/compress"
|
@@ -112,23 +111,19 @@ func testCompression(mURL string, compression compress.CompressionType, level *i
|
112 | 111 | }
|
113 | 112 |
|
114 | 113 | func testStorage(mURL string, compression compress.CompressionType, level *int, sizeGb float64, collection string) {
|
115 |
| - ctx := context.Background() |
116 |
| - |
117 |
| - sess, err := connect.MongoConnect(ctx, mURL, &connect.MongoConnectOptions{Direct: true}) |
| 114 | + sess, err := connect.MongoConnect(context.Background(), mURL, &connect.MongoConnectOptions{Direct: true}) |
118 | 115 | if err != nil {
|
119 | 116 | stdlog.Fatalln("Error: connect to mongodb-node:", err)
|
120 | 117 | }
|
121 |
| - defer sess.Disconnect(ctx) //nolint:errcheck |
| 118 | + defer sess.Disconnect(context.Background()) //nolint:errcheck |
122 | 119 |
|
123 |
| - client, err := connect.Connect(ctx, mURL, &connect.ConnectOptions{AppName: "pbm-speed-test"}) |
| 120 | + client, err := connect.Connect(context.Background(), mURL, &connect.ConnectOptions{AppName: "pbm-speed-test"}) |
124 | 121 | if err != nil {
|
125 | 122 | stdlog.Fatalln("Error: connect to mongodb-pbm:", err)
|
126 | 123 | }
|
127 |
| - defer client.Disconnect(ctx) //nolint:errcheck |
| 124 | + defer client.Disconnect(context.Background()) //nolint:errcheck |
128 | 125 |
|
129 |
| - l := log.FromContext(ctx). |
130 |
| - NewEvent("", "", "", primitive.Timestamp{}) |
131 |
| - stg, err := util.GetStorage(ctx, client, l) |
| 126 | + stg, err := util.GetStorage(context.Background(), client, log.DiscardEvent) |
132 | 127 | if err != nil {
|
133 | 128 | stdlog.Fatalln("Error: get storage:", err)
|
134 | 129 | }
|
|
0 commit comments