diff options
Diffstat (limited to 'src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/find.go')
| -rw-r--r-- | src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/find.go | 483 |
1 files changed, 0 insertions, 483 deletions
diff --git a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/find.go b/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/find.go deleted file mode 100644 index 09aeccce9e9..00000000000 --- a/src/mongo/gotools/src/github.com/mongodb/mongo-tools/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/operation/find.go +++ /dev/null @@ -1,483 +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/bson/bsontype" - "go.mongodb.org/mongo-driver/event" - "go.mongodb.org/mongo-driver/mongo/readconcern" - "go.mongodb.org/mongo-driver/mongo/readpref" - "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" -) - -// Find performs a find operation. -type Find struct { - allowPartialResults *bool - awaitData *bool - batchSize *int32 - collation bsoncore.Document - comment *string - filter bsoncore.Document - hint bsoncore.Value - limit *int64 - max bsoncore.Document - maxTimeMS *int64 - min bsoncore.Document - noCursorTimeout *bool - oplogReplay *bool - projection bsoncore.Document - returnKey *bool - showRecordID *bool - singleBatch *bool - skip *int64 - snapshot *bool - sort bsoncore.Document - tailable *bool - session *session.Client - clock *session.ClusterClock - collection string - monitor *event.CommandMonitor - database string - deployment driver.Deployment - readConcern *readconcern.ReadConcern - readPreference *readpref.ReadPref - selector description.ServerSelector - retry *driver.RetryMode - result driver.CursorResponse -} - -// NewFind constructs and returns a new Find. -func NewFind(filter bsoncore.Document) *Find { - return &Find{ - filter: filter, - } -} - -// Result returns the result of executing this operation. -func (f *Find) Result(opts driver.CursorOptions) (*driver.BatchCursor, error) { - return driver.NewBatchCursor(f.result, f.session, f.clock, opts) -} - -func (f *Find) processResponse(response bsoncore.Document, srvr driver.Server, desc description.Server) error { - var err error - f.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 (f *Find) Execute(ctx context.Context) error { - if f.deployment == nil { - return errors.New("the Find operation must have a Deployment set before Execute can be called") - } - - return driver.Operation{ - CommandFn: f.command, - ProcessResponseFn: f.processResponse, - RetryMode: f.retry, - Type: driver.Read, - Client: f.session, - Clock: f.clock, - CommandMonitor: f.monitor, - Database: f.database, - Deployment: f.deployment, - ReadConcern: f.readConcern, - ReadPreference: f.readPreference, - Selector: f.selector, - Legacy: driver.LegacyFind, - }.Execute(ctx, nil) - -} - -func (f *Find) command(dst []byte, desc description.SelectedServer) ([]byte, error) { - dst = bsoncore.AppendStringElement(dst, "find", f.collection) - if f.allowPartialResults != nil { - dst = bsoncore.AppendBooleanElement(dst, "allowPartialResults", *f.allowPartialResults) - } - if f.awaitData != nil { - dst = bsoncore.AppendBooleanElement(dst, "awaitData", *f.awaitData) - } - if f.batchSize != nil { - dst = bsoncore.AppendInt32Element(dst, "batchSize", *f.batchSize) - } - if f.collation != nil { - if desc.WireVersion == nil || !desc.WireVersion.Includes(5) { - return nil, errors.New("the 'collation' command parameter requires a minimum server wire version of 5") - } - dst = bsoncore.AppendDocumentElement(dst, "collation", f.collation) - } - if f.comment != nil { - dst = bsoncore.AppendStringElement(dst, "comment", *f.comment) - } - if f.filter != nil { - dst = bsoncore.AppendDocumentElement(dst, "filter", f.filter) - } - if f.hint.Type != bsontype.Type(0) { - dst = bsoncore.AppendValueElement(dst, "hint", f.hint) - } - if f.limit != nil { - dst = bsoncore.AppendInt64Element(dst, "limit", *f.limit) - } - if f.max != nil { - dst = bsoncore.AppendDocumentElement(dst, "max", f.max) - } - if f.maxTimeMS != nil { - dst = bsoncore.AppendInt64Element(dst, "maxTimeMS", *f.maxTimeMS) - } - if f.min != nil { - dst = bsoncore.AppendDocumentElement(dst, "min", f.min) - } - if f.noCursorTimeout != nil { - dst = bsoncore.AppendBooleanElement(dst, "noCursorTimeout", *f.noCursorTimeout) - } - if f.oplogReplay != nil { - dst = bsoncore.AppendBooleanElement(dst, "oplogReplay", *f.oplogReplay) - } - if f.projection != nil { - dst = bsoncore.AppendDocumentElement(dst, "projection", f.projection) - } - if f.returnKey != nil { - dst = bsoncore.AppendBooleanElement(dst, "returnKey", *f.returnKey) - } - if f.showRecordID != nil { - dst = bsoncore.AppendBooleanElement(dst, "showRecordId", *f.showRecordID) - } - if f.singleBatch != nil { - dst = bsoncore.AppendBooleanElement(dst, "singleBatch", *f.singleBatch) - } - if f.skip != nil { - dst = bsoncore.AppendInt64Element(dst, "skip", *f.skip) - } - if f.snapshot != nil { - dst = bsoncore.AppendBooleanElement(dst, "snapshot", *f.snapshot) - } - if f.sort != nil { - dst = bsoncore.AppendDocumentElement(dst, "sort", f.sort) - } - if f.tailable != nil { - dst = bsoncore.AppendBooleanElement(dst, "tailable", *f.tailable) - } - return dst, nil -} - -// AllowPartialResults when true allows partial results to be returned if some shards are down. -func (f *Find) AllowPartialResults(allowPartialResults bool) *Find { - if f == nil { - f = new(Find) - } - - f.allowPartialResults = &allowPartialResults - return f -} - -// AwaitData when true makes a cursor block before returning when no data is available. -func (f *Find) AwaitData(awaitData bool) *Find { - if f == nil { - f = new(Find) - } - - f.awaitData = &awaitData - return f -} - -// BatchSize specifies the number of documents to return in every batch. -func (f *Find) BatchSize(batchSize int32) *Find { - if f == nil { - f = new(Find) - } - - f.batchSize = &batchSize - return f -} - -// Collation specifies a collation to be used. -func (f *Find) Collation(collation bsoncore.Document) *Find { - if f == nil { - f = new(Find) - } - - f.collation = collation - return f -} - -// Comment sets a string to help trace an operation. -func (f *Find) Comment(comment string) *Find { - if f == nil { - f = new(Find) - } - - f.comment = &comment - return f -} - -// Filter determines what results are returned from find. -func (f *Find) Filter(filter bsoncore.Document) *Find { - if f == nil { - f = new(Find) - } - - f.filter = filter - return f -} - -// Hint specifies the index to use. -func (f *Find) Hint(hint bsoncore.Value) *Find { - if f == nil { - f = new(Find) - } - - f.hint = hint - return f -} - -// Limit sets a limit on the number of documents to return. -func (f *Find) Limit(limit int64) *Find { - if f == nil { - f = new(Find) - } - - f.limit = &limit - return f -} - -// Max sets an exclusive upper bound for a specific index. -func (f *Find) Max(max bsoncore.Document) *Find { - if f == nil { - f = new(Find) - } - - f.max = max - return f -} - -// MaxTimeMS specifies the maximum amount of time to allow the query to run. -func (f *Find) MaxTimeMS(maxTimeMS int64) *Find { - if f == nil { - f = new(Find) - } - - f.maxTimeMS = &maxTimeMS - return f -} - -// Min sets an inclusive lower bound for a specific index. -func (f *Find) Min(min bsoncore.Document) *Find { - if f == nil { - f = new(Find) - } - - f.min = min - return f -} - -// NoCursorTimeout when true prevents cursor from timing out after an inactivity period. -func (f *Find) NoCursorTimeout(noCursorTimeout bool) *Find { - if f == nil { - f = new(Find) - } - - f.noCursorTimeout = &noCursorTimeout - return f -} - -// OplogReplay when true replays a replica set's oplog. -func (f *Find) OplogReplay(oplogReplay bool) *Find { - if f == nil { - f = new(Find) - } - - f.oplogReplay = &oplogReplay - return f -} - -// Project limits the fields returned for all documents. -func (f *Find) Projection(projection bsoncore.Document) *Find { - if f == nil { - f = new(Find) - } - - f.projection = projection - return f -} - -// ReturnKey when true returns index keys for all result documents. -func (f *Find) ReturnKey(returnKey bool) *Find { - if f == nil { - f = new(Find) - } - - f.returnKey = &returnKey - return f -} - -// ShowRecordID when true adds a $recordId field with the record identifier to returned documents. -func (f *Find) ShowRecordID(showRecordID bool) *Find { - if f == nil { - f = new(Find) - } - - f.showRecordID = &showRecordID - return f -} - -// SingleBatch specifies whether the results should be returned in a single batch. -func (f *Find) SingleBatch(singleBatch bool) *Find { - if f == nil { - f = new(Find) - } - - f.singleBatch = &singleBatch - return f -} - -// Skip specifies the number of documents to skip before returning. -func (f *Find) Skip(skip int64) *Find { - if f == nil { - f = new(Find) - } - - f.skip = &skip - return f -} - -// Snapshot prevents the cursor from returning a document more than once because of an intervening write operation. -func (f *Find) Snapshot(snapshot bool) *Find { - if f == nil { - f = new(Find) - } - - f.snapshot = &snapshot - return f -} - -// Sort specifies the order in which to return results. -func (f *Find) Sort(sort bsoncore.Document) *Find { - if f == nil { - f = new(Find) - } - - f.sort = sort - return f -} - -// Tailable keeps a cursor open and resumable after the last data has been retrieved. -func (f *Find) Tailable(tailable bool) *Find { - if f == nil { - f = new(Find) - } - - f.tailable = &tailable - return f -} - -// Session sets the session for this operation. -func (f *Find) Session(session *session.Client) *Find { - if f == nil { - f = new(Find) - } - - f.session = session - return f -} - -// ClusterClock sets the cluster clock for this operation. -func (f *Find) ClusterClock(clock *session.ClusterClock) *Find { - if f == nil { - f = new(Find) - } - - f.clock = clock - return f -} - -// Collection sets the collection that this command will run against. -func (f *Find) Collection(collection string) *Find { - if f == nil { - f = new(Find) - } - - f.collection = collection - return f -} - -// CommandMonitor sets the monitor to use for APM events. -func (f *Find) CommandMonitor(monitor *event.CommandMonitor) *Find { - if f == nil { - f = new(Find) - } - - f.monitor = monitor - return f -} - -// Database sets the database to run this operation against. -func (f *Find) Database(database string) *Find { - if f == nil { - f = new(Find) - } - - f.database = database - return f -} - -// Deployment sets the deployment to use for this operation. -func (f *Find) Deployment(deployment driver.Deployment) *Find { - if f == nil { - f = new(Find) - } - - f.deployment = deployment - return f -} - -// ReadConcern specifies the read concern for this operation. -func (f *Find) ReadConcern(readConcern *readconcern.ReadConcern) *Find { - if f == nil { - f = new(Find) - } - - f.readConcern = readConcern - return f -} - -// ReadPreference set the read prefernce used with this operation. -func (f *Find) ReadPreference(readPreference *readpref.ReadPref) *Find { - if f == nil { - f = new(Find) - } - - f.readPreference = readPreference - return f -} - -// ServerSelector sets the selector used to retrieve a server. -func (f *Find) ServerSelector(selector description.ServerSelector) *Find { - if f == nil { - f = new(Find) - } - - f.selector = selector - return f -} - -// Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based -// on how the operation is set. -func (f *Find) Retry(retry driver.RetryMode) *Find { - if f == nil { - f = new(Find) - } - - f.retry = &retry - return f -} |