1 files changed, 0 insertions, 295 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/update.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/update.go
deleted file mode 100644
index ab2a51b2c48..00000000000
--- a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/update.go
+++ /dev/null
@@ -1,295 +0,0 @@
-// Copyright (C) MongoDB, Inc. 2019-present.
-//
-// Licensed under the Apache License, Version 2.0 (the "License"); you may
-// not use this file except in compliance with the License. You may obtain
-// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
-
-// NOTE: This file is maintained by hand because operationgen cannot generate it.
-
-package operation
-
-import (
-	"context"
-	"errors"
-	"fmt"
-
-	"go.mongodb.org/mongo-driver/bson"
-	"go.mongodb.org/mongo-driver/event"
-	"go.mongodb.org/mongo-driver/mongo/writeconcern"
-	"go.mongodb.org/mongo-driver/x/bsonx/bsoncore"
-	"go.mongodb.org/mongo-driver/x/mongo/driver"
-	"go.mongodb.org/mongo-driver/x/mongo/driver/description"
-	"go.mongodb.org/mongo-driver/x/mongo/driver/session"
-)
-
-// Update performs an update operation.
-type Update struct {
-	bypassDocumentValidation *bool
-	ordered                  *bool
-	updates                  []bsoncore.Document
-	session                  *session.Client
-	clock                    *session.ClusterClock
-	collection               string
-	monitor                  *event.CommandMonitor
-	database                 string
-	deployment               driver.Deployment
-	selector                 description.ServerSelector
-	writeConcern             *writeconcern.WriteConcern
-	retry                    *driver.RetryMode
-	result                   UpdateResult
-}
-
-// Upsert contains the information for an upsert in an Update operation.
-type Upsert struct {
-	Index int64
-	ID    interface{} `bson:"_id"`
-}
-
-// UpdateResult contains information for the result of an Update operation.
-type UpdateResult struct {
-	// Number of documents matched.
-	N int32
-	// Number of documents modified.
-	NModified int32
-	// Information about upserted documents.
-	Upserted []Upsert
-}
-
-func buildUpdateResult(response bsoncore.Document, srvr driver.Server) (UpdateResult, error) {
-	elements, err := response.Elements()
-	if err != nil {
-		return UpdateResult{}, err
-	}
-	ur := UpdateResult{}
-	for _, element := range elements {
-		switch element.Key() {
-
-		case "nModified":
-			var ok bool
-			ur.NModified, ok = element.Value().Int32OK()
-			if !ok {
-				err = fmt.Errorf("response field 'nModified' is type int32, but received BSON type %s", element.Value().Type)
-			}
-
-		case "n":
-			var ok bool
-			ur.N, ok = element.Value().Int32OK()
-			if !ok {
-				err = fmt.Errorf("response field 'n' is type int32, but received BSON type %s", element.Value().Type)
-			}
-
-		case "upserted":
-			arr, ok := element.Value().ArrayOK()
-			if !ok {
-				err = fmt.Errorf("response field 'upserted' is type array, but received BSON type %s", element.Value().Type)
-				break
-			}
-
-			var values []bsoncore.Value
-			values, err = arr.Values()
-			if err != nil {
-				break
-			}
-
-			for _, val := range values {
-				valDoc, ok := val.DocumentOK()
-				if !ok {
-					err = fmt.Errorf("upserted value is type document, but received BSON type %s", val.Type)
-					break
-				}
-				var upsert Upsert
-				if err = bson.Unmarshal(valDoc, &upsert); err != nil {
-					break
-				}
-				ur.Upserted = append(ur.Upserted, upsert)
-			}
-		}
-	}
-	return ur, nil
-}
-
-// NewUpdate constructs and returns a new Update.
-func NewUpdate(updates ...bsoncore.Document) *Update {
-	return &Update{
-		updates: updates,
-	}
-}
-
-// Result returns the result of executing this operation.
-func (u *Update) Result() UpdateResult { return u.result }
-
-func (u *Update) processResponse(response bsoncore.Document, srvr driver.Server, desc description.Server) error {
-	var err error
-
-	u.result, err = buildUpdateResult(response, srvr)
-	return err
-
-}
-
-// Execute runs this operations and returns an error if the operaiton did not execute successfully.
-func (u *Update) Execute(ctx context.Context) error {
-	if u.deployment == nil {
-		return errors.New("the Update operation must have a Deployment set before Execute can be called")
-	}
-	batches := &driver.Batches{
-		Identifier: "updates",
-		Documents:  u.updates,
-		Ordered:    u.ordered,
-	}
-
-	return driver.Operation{
-		CommandFn:         u.command,
-		ProcessResponseFn: u.processResponse,
-		Batches:           batches,
-		RetryMode:         u.retry,
-		Type:              driver.Write,
-		Client:            u.session,
-		Clock:             u.clock,
-		CommandMonitor:    u.monitor,
-		Database:          u.database,
-		Deployment:        u.deployment,
-		Selector:          u.selector,
-		WriteConcern:      u.writeConcern,
-	}.Execute(ctx, nil)
-
-}
-
-func (u *Update) command(dst []byte, desc description.SelectedServer) ([]byte, error) {
-	dst = bsoncore.AppendStringElement(dst, "update", u.collection)
-	if u.bypassDocumentValidation != nil &&
-		(desc.WireVersion != nil && desc.WireVersion.Includes(4)) {
-
-		dst = bsoncore.AppendBooleanElement(dst, "bypassDocumentValidation", *u.bypassDocumentValidation)
-	}
-	if u.ordered != nil {
-
-		dst = bsoncore.AppendBooleanElement(dst, "ordered", *u.ordered)
-	}
-
-	return dst, nil
-}
-
-// BypassDocumentValidation allows the operation to opt-out of document level validation. Valid
-// for server versions >= 3.2. For servers < 3.2, this setting is ignored.
-func (u *Update) BypassDocumentValidation(bypassDocumentValidation bool) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.bypassDocumentValidation = &bypassDocumentValidation
-	return u
-}
-
-// Ordered sets ordered. If true, when a write fails, the operation will return the error, when
-// false write failures do not stop execution of the operation.
-func (u *Update) Ordered(ordered bool) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.ordered = &ordered
-	return u
-}
-
-// Updates specifies an array of update statements to perform when this operation is executed.
-// Each update document must have the following structure: {q: <query>, u: <update>, multi: <boolean>, collation: Optional<Document>, arrayFitlers: Optional<Array>}.
-func (u *Update) Updates(updates ...bsoncore.Document) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.updates = updates
-	return u
-}
-
-// Session sets the session for this operation.
-func (u *Update) Session(session *session.Client) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.session = session
-	return u
-}
-
-// ClusterClock sets the cluster clock for this operation.
-func (u *Update) ClusterClock(clock *session.ClusterClock) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.clock = clock
-	return u
-}
-
-// Collection sets the collection that this command will run against.
-func (u *Update) Collection(collection string) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.collection = collection
-	return u
-}
-
-// CommandMonitor sets the monitor to use for APM events.
-func (u *Update) CommandMonitor(monitor *event.CommandMonitor) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.monitor = monitor
-	return u
-}
-
-// Database sets the database to run this operation against.
-func (u *Update) Database(database string) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.database = database
-	return u
-}
-
-// Deployment sets the deployment to use for this operation.
-func (u *Update) Deployment(deployment driver.Deployment) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.deployment = deployment
-	return u
-}
-
-// ServerSelector sets the selector used to retrieve a server.
-func (u *Update) ServerSelector(selector description.ServerSelector) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.selector = selector
-	return u
-}
-
-// WriteConcern sets the write concern for this operation.
-func (u *Update) WriteConcern(writeConcern *writeconcern.WriteConcern) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.writeConcern = writeConcern
-	return u
-}
-
-// Retry enables retryable writes for this operation. Retries are not handled automatically,
-// instead a boolean is returned from Execute and SelectAndExecute that indicates if the
-// operation can be retried. Retrying is handled by calling RetryExecute.
-func (u *Update) Retry(retry driver.RetryMode) *Update {
-	if u == nil {
-		u = new(Update)
-	}
-
-	u.retry = &retry
-	return u
-}