diff options
Diffstat (limited to 'src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/list_indexes.go')
| -rw-r--r-- | src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/list_indexes.go | 200 |
1 files changed, 0 insertions, 200 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/list_indexes.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/list_indexes.go deleted file mode 100644 index c224adb28ac..00000000000 --- a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/list_indexes.go +++ /dev/null @@ -1,200 +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" - - "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" -) - -// ListIndexes performs a listIndexes operation. -type ListIndexes struct { - batchSize *int32 - maxTimeMS *int64 - session *session.Client - clock *session.ClusterClock - collection string - monitor *event.CommandMonitor - database string - deployment driver.Deployment - selector description.ServerSelector - retry *driver.RetryMode - - result driver.CursorResponse -} - -// NewListIndexes constructs and returns a new ListIndexes. -func NewListIndexes() *ListIndexes { - return &ListIndexes{} -} - -// Result returns the result of executing this operation. -func (li *ListIndexes) Result(opts driver.CursorOptions) (*driver.BatchCursor, error) { - - clientSession := li.session - - clock := li.clock - return driver.NewBatchCursor(li.result, clientSession, clock, opts) -} - -func (li *ListIndexes) processResponse(response bsoncore.Document, srvr driver.Server, desc description.Server) error { - var err error - - li.result, err = driver.NewCursorResponse(response, srvr, desc) - return err - -} - -// Execute runs this operations and returns an error if the operaiton did not execute successfully. -func (li *ListIndexes) Execute(ctx context.Context) error { - if li.deployment == nil { - return errors.New("the ListIndexes operation must have a Deployment set before Execute can be called") - } - - return driver.Operation{ - CommandFn: li.command, - ProcessResponseFn: li.processResponse, - - Client: li.session, - Clock: li.clock, - CommandMonitor: li.monitor, - Database: li.database, - Deployment: li.deployment, - Selector: li.selector, - Legacy: driver.LegacyListIndexes, - RetryMode: li.retry, - Type: driver.Read, - }.Execute(ctx, nil) - -} - -func (li *ListIndexes) command(dst []byte, desc description.SelectedServer) ([]byte, error) { - dst = bsoncore.AppendStringElement(dst, "listIndexes", li.collection) - cursorIdx, cursorDoc := bsoncore.AppendDocumentStart(nil) - - if li.batchSize != nil { - - cursorDoc = bsoncore.AppendInt32Element(cursorDoc, "batchSize", *li.batchSize) - } - if li.maxTimeMS != nil { - - dst = bsoncore.AppendInt64Element(dst, "maxTimeMS", *li.maxTimeMS) - } - cursorDoc, _ = bsoncore.AppendDocumentEnd(cursorDoc, cursorIdx) - dst = bsoncore.AppendDocumentElement(dst, "cursor", cursorDoc) - - return dst, nil -} - -// BatchSize specifies the number of documents to return in every batch. -func (li *ListIndexes) BatchSize(batchSize int32) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.batchSize = &batchSize - return li -} - -// MaxTimeMS specifies the maximum amount of time to allow the query to run. -func (li *ListIndexes) MaxTimeMS(maxTimeMS int64) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.maxTimeMS = &maxTimeMS - return li -} - -// Session sets the session for this operation. -func (li *ListIndexes) Session(session *session.Client) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.session = session - return li -} - -// ClusterClock sets the cluster clock for this operation. -func (li *ListIndexes) ClusterClock(clock *session.ClusterClock) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.clock = clock - return li -} - -// Collection sets the collection that this command will run against. -func (li *ListIndexes) Collection(collection string) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.collection = collection - return li -} - -// CommandMonitor sets the monitor to use for APM events. -func (li *ListIndexes) CommandMonitor(monitor *event.CommandMonitor) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.monitor = monitor - return li -} - -// Database sets the database to run this operation against. -func (li *ListIndexes) Database(database string) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.database = database - return li -} - -// Deployment sets the deployment to use for this operation. -func (li *ListIndexes) Deployment(deployment driver.Deployment) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.deployment = deployment - return li -} - -// ServerSelector sets the selector used to retrieve a server. -func (li *ListIndexes) ServerSelector(selector description.ServerSelector) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.selector = selector - return li -} - -// Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based -// on how the operation is set. -func (li *ListIndexes) Retry(retry driver.RetryMode) *ListIndexes { - if li == nil { - li = new(ListIndexes) - } - - li.retry = &retry - return li -} |