INNER CODE UNIT · Go

testStorage

percona/percona-backup-mongodb · cmd/pbm-speed-test/main.go:196

func testStorage(mURL string, compression compress.CompressionType, level *int, sizeGb float64, collection string) {
	sess, err := connect.MongoConnect(context.Background(), mURL, connect.Direct(true))
	if err != nil {
		stdlog.Fatalln("Error: connect to mongodb-node:", err)
	}
	defer sess.Disconnect(context.Background()) //nolint:errcheck

	client, err := connect.Connect(context.Background(), mURL, "pbm-speed-test")
	if err != nil {
		stdlog.Fatalln("Error: connect to mongodb-pbm:", err)
	}
	defer client.Disconnect(context.Background()) //nolint:errcheck

	stg, err := util.GetStorage(context.Background(), client, "", log.DiscardEvent)
	if err != nil {
		stdlog.Fatalln("Error: get storage:", err)
	}
	defer storage.Close(stg, nil)

View source record →