diff options
Diffstat (limited to 'src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/createIndexes.go')
| -rw-r--r-- | src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/createIndexes.go | 211 |
1 files changed, 0 insertions, 211 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/createIndexes.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/createIndexes.go deleted file mode 100644 index d44a965409e..00000000000 --- a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/createIndexes.go +++ /dev/null @@ -1,211 +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 - -// Code generated by operationgen. DO NOT EDIT. - -package operation - -import ( - "context" - "errors" - "fmt" - - "go.mongodb.org/mongo-driver/event" - "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" -) - -// CreateIndexes performs a createIndexes operation. -type CreateIndexes struct { - indexes bsoncore.Document - maxTimeMS *int64 - session *session.Client - clock *session.ClusterClock - collection string - monitor *event.CommandMonitor - database string - deployment driver.Deployment - selector description.ServerSelector - result CreateIndexesResult -} - -type CreateIndexesResult struct { - // If the collection was created automatically. - CreatedCollectionAutomatically bool - // The number of indexes existing after this command. - IndexesAfter int32 - // The number of indexes existing before this command. - IndexesBefore int32 -} - -func buildCreateIndexesResult(response bsoncore.Document, srvr driver.Server) (CreateIndexesResult, error) { - elements, err := response.Elements() - if err != nil { - return CreateIndexesResult{}, err - } - cir := CreateIndexesResult{} - for _, element := range elements { - switch element.Key() { - case "createdCollectionAutomatically": - var ok bool - cir.CreatedCollectionAutomatically, ok = element.Value().BooleanOK() - if !ok { - err = fmt.Errorf("response field 'createdCollectionAutomatically' is type bool, but received BSON type %s", element.Value().Type) - } - case "indexesAfter": - var ok bool - cir.IndexesAfter, ok = element.Value().AsInt32OK() - if !ok { - err = fmt.Errorf("response field 'indexesAfter' is type int32, but received BSON type %s", element.Value().Type) - } - case "indexesBefore": - var ok bool - cir.IndexesBefore, ok = element.Value().AsInt32OK() - if !ok { - err = fmt.Errorf("response field 'indexesBefore' is type int32, but received BSON type %s", element.Value().Type) - } - } - } - return cir, nil -} - -// NewCreateIndexes constructs and returns a new CreateIndexes. -func NewCreateIndexes(indexes bsoncore.Document) *CreateIndexes { - return &CreateIndexes{ - indexes: indexes, - } -} - -// Result returns the result of executing this operation. -func (ci *CreateIndexes) Result() CreateIndexesResult { return ci.result } - -func (ci *CreateIndexes) processResponse(response bsoncore.Document, srvr driver.Server, desc description.Server) error { - var err error - ci.result, err = buildCreateIndexesResult(response, srvr) - return err -} - -// Execute runs this operations and returns an error if the operaiton did not execute successfully. -func (ci *CreateIndexes) Execute(ctx context.Context) error { - if ci.deployment == nil { - return errors.New("the CreateIndexes operation must have a Deployment set before Execute can be called") - } - - return driver.Operation{ - CommandFn: ci.command, - ProcessResponseFn: ci.processResponse, - Client: ci.session, - Clock: ci.clock, - CommandMonitor: ci.monitor, - Database: ci.database, - Deployment: ci.deployment, - Selector: ci.selector, - }.Execute(ctx, nil) - -} - -func (ci *CreateIndexes) command(dst []byte, desc description.SelectedServer) ([]byte, error) { - dst = bsoncore.AppendStringElement(dst, "createIndexes", ci.collection) - if ci.indexes != nil { - dst = bsoncore.AppendArrayElement(dst, "indexes", ci.indexes) - } - if ci.maxTimeMS != nil { - dst = bsoncore.AppendInt64Element(dst, "maxTimeMS", *ci.maxTimeMS) - } - return dst, nil -} - -// An array containing index specification documents for the indexes being created. -func (ci *CreateIndexes) Indexes(indexes bsoncore.Document) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.indexes = indexes - return ci -} - -// MaxTimeMS specifies the maximum amount of time to allow the query to run. -func (ci *CreateIndexes) MaxTimeMS(maxTimeMS int64) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.maxTimeMS = &maxTimeMS - return ci -} - -// Session sets the session for this operation. -func (ci *CreateIndexes) Session(session *session.Client) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.session = session - return ci -} - -// ClusterClock sets the cluster clock for this operation. -func (ci *CreateIndexes) ClusterClock(clock *session.ClusterClock) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.clock = clock - return ci -} - -// Collection sets the collection that this command will run against. -func (ci *CreateIndexes) Collection(collection string) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.collection = collection - return ci -} - -// CommandMonitor sets the monitor to use for APM events. -func (ci *CreateIndexes) CommandMonitor(monitor *event.CommandMonitor) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.monitor = monitor - return ci -} - -// Database sets the database to run this operation against. -func (ci *CreateIndexes) Database(database string) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.database = database - return ci -} - -// Deployment sets the deployment to use for this operation. -func (ci *CreateIndexes) Deployment(deployment driver.Deployment) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.deployment = deployment - return ci -} - -// ServerSelector sets the selector used to retrieve a server. -func (ci *CreateIndexes) ServerSelector(selector description.ServerSelector) *CreateIndexes { - if ci == nil { - ci = new(CreateIndexes) - } - - ci.selector = selector - return ci -} |