Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

operation

package

Go to main page

Versions in this module

v2

v2.1.0

Feb 26, 2025

v2.0.1

Feb 20, 2025

v2.0.0

Dec 10, 2024

Changes in this version

+ type AbortTransaction struct

+ func NewAbortTransaction() *AbortTransaction

+ func (at *AbortTransaction) Authenticator(authenticator driver.Authenticator) *AbortTransaction

+ func (at *AbortTransaction) ClusterClock(clock *session.ClusterClock) *AbortTransaction

+ func (at *AbortTransaction) Collection(collection string) *AbortTransaction

+ func (at *AbortTransaction) CommandMonitor(monitor *event.CommandMonitor) *AbortTransaction

+ func (at *AbortTransaction) Crypt(crypt driver.Crypt) *AbortTransaction

+ func (at *AbortTransaction) Database(database string) *AbortTransaction

+ func (at *AbortTransaction) Deployment(deployment driver.Deployment) *AbortTransaction

+ func (at *AbortTransaction) Execute(ctx context.Context) error

+ func (at *AbortTransaction) RecoveryToken(recoveryToken bsoncore.Document) *AbortTransaction

+ func (at *AbortTransaction) Retry(retry driver.RetryMode) *AbortTransaction

+ func (at *AbortTransaction) ServerAPI(serverAPI *driver.ServerAPIOptions) *AbortTransaction

+ func (at *AbortTransaction) ServerSelector(selector description.ServerSelector) *AbortTransaction

+ func (at *AbortTransaction) Session(session *session.Client) *AbortTransaction

+ func (at *AbortTransaction) WriteConcern(writeConcern *writeconcern.WriteConcern) *AbortTransaction

+ type Aggregate struct

+ func NewAggregate(pipeline bsoncore.Document) *Aggregate

+ func (a *Aggregate) AllowDiskUse(allowDiskUse bool) *Aggregate

+ func (a *Aggregate) Authenticator(authenticator driver.Authenticator) *Aggregate

+ func (a *Aggregate) BatchSize(batchSize int32) *Aggregate

+ func (a *Aggregate) BypassDocumentValidation(bypassDocumentValidation bool) *Aggregate

+ func (a *Aggregate) ClusterClock(clock *session.ClusterClock) *Aggregate

+ func (a *Aggregate) Collation(collation bsoncore.Document) *Aggregate

+ func (a *Aggregate) Collection(collection string) *Aggregate

+ func (a *Aggregate) CommandMonitor(monitor *event.CommandMonitor) *Aggregate

+ func (a *Aggregate) Comment(comment bsoncore.Value) *Aggregate

+ func (a *Aggregate) Crypt(crypt driver.Crypt) *Aggregate

+ func (a *Aggregate) CustomOptions(co map[string]bsoncore.Value) *Aggregate

+ func (a *Aggregate) Database(database string) *Aggregate

+ func (a *Aggregate) Deployment(deployment driver.Deployment) *Aggregate

+ func (a *Aggregate) Execute(ctx context.Context) error

+ func (a *Aggregate) HasOutputStage(hos bool) *Aggregate

+ func (a *Aggregate) Hint(hint bsoncore.Value) *Aggregate

+ func (a *Aggregate) Let(let bsoncore.Document) *Aggregate

+ func (a *Aggregate) OmitMaxTimeMS(omit bool) *Aggregate

+ func (a *Aggregate) Pipeline(pipeline bsoncore.Document) *Aggregate

+ func (a *Aggregate) ReadConcern(readConcern *readconcern.ReadConcern) *Aggregate

+ func (a *Aggregate) ReadPreference(readPreference *readpref.ReadPref) *Aggregate

+ func (a *Aggregate) Result(opts driver.CursorOptions) (*driver.BatchCursor, error)

+ func (a *Aggregate) ResultCursorResponse() driver.CursorResponse

+ func (a *Aggregate) Retry(retry driver.RetryMode) *Aggregate

+ func (a *Aggregate) ServerAPI(serverAPI *driver.ServerAPIOptions) *Aggregate

+ func (a *Aggregate) ServerSelector(selector description.ServerSelector) *Aggregate

+ func (a *Aggregate) Session(session *session.Client) *Aggregate

+ func (a *Aggregate) Timeout(timeout *time.Duration) *Aggregate

+ func (a *Aggregate) WriteConcern(writeConcern *writeconcern.WriteConcern) *Aggregate

+ type Command struct

+ func NewCommand(command bsoncore.Document) *Command

+ func NewCursorCommand(command bsoncore.Document, cursorOpts driver.CursorOptions) *Command

+ func (c *Command) Authenticator(authenticator driver.Authenticator) *Command

+ func (c *Command) ClusterClock(clock *session.ClusterClock) *Command

+ func (c *Command) CommandMonitor(monitor *event.CommandMonitor) *Command

+ func (c *Command) Crypt(crypt driver.Crypt) *Command

+ func (c *Command) Database(database string) *Command

+ func (c *Command) Deployment(deployment driver.Deployment) *Command

+ func (c *Command) Execute(ctx context.Context) error

+ func (c *Command) Logger(logger *logger.Logger) *Command

+ func (c *Command) ReadPreference(readPreference *readpref.ReadPref) *Command

+ func (c *Command) Result() bsoncore.Document

+ func (c *Command) ResultCursor() (*driver.BatchCursor, error)

+ func (c *Command) ServerAPI(serverAPI *driver.ServerAPIOptions) *Command

+ func (c *Command) ServerSelector(selector description.ServerSelector) *Command

+ func (c *Command) Session(session *session.Client) *Command

+ func (c *Command) Timeout(timeout *time.Duration) *Command

+ type CommitTransaction struct

+ func NewCommitTransaction() *CommitTransaction

+ func (ct *CommitTransaction) Authenticator(authenticator driver.Authenticator) *CommitTransaction

+ func (ct *CommitTransaction) ClusterClock(clock *session.ClusterClock) *CommitTransaction

+ func (ct *CommitTransaction) CommandMonitor(monitor *event.CommandMonitor) *CommitTransaction

+ func (ct *CommitTransaction) Crypt(crypt driver.Crypt) *CommitTransaction

+ func (ct *CommitTransaction) Database(database string) *CommitTransaction

+ func (ct *CommitTransaction) Deployment(deployment driver.Deployment) *CommitTransaction

+ func (ct *CommitTransaction) Execute(ctx context.Context) error

+ func (ct *CommitTransaction) RecoveryToken(recoveryToken bsoncore.Document) *CommitTransaction

+ func (ct *CommitTransaction) Retry(retry driver.RetryMode) *CommitTransaction

+ func (ct *CommitTransaction) ServerAPI(serverAPI *driver.ServerAPIOptions) *CommitTransaction

+ func (ct *CommitTransaction) ServerSelector(selector description.ServerSelector) *CommitTransaction

+ func (ct *CommitTransaction) Session(session *session.Client) *CommitTransaction

+ func (ct *CommitTransaction) WriteConcern(writeConcern *writeconcern.WriteConcern) *CommitTransaction

+ type Count struct

+ func NewCount() *Count

+ func (c *Count) Authenticator(authenticator driver.Authenticator) *Count

+ func (c *Count) ClusterClock(clock *session.ClusterClock) *Count

+ func (c *Count) Collection(collection string) *Count

+ func (c *Count) CommandMonitor(monitor *event.CommandMonitor) *Count

+ func (c *Count) Comment(comment bsoncore.Value) *Count

+ func (c *Count) Crypt(crypt driver.Crypt) *Count

+ func (c *Count) Database(database string) *Count

+ func (c *Count) Deployment(deployment driver.Deployment) *Count

+ func (c *Count) Execute(ctx context.Context) error

+ func (c *Count) Query(query bsoncore.Document) *Count

+ func (c *Count) ReadConcern(readConcern *readconcern.ReadConcern) *Count

+ func (c *Count) ReadPreference(readPreference *readpref.ReadPref) *Count

+ func (c *Count) Result() CountResult

+ func (c *Count) Retry(retry driver.RetryMode) *Count

+ func (c *Count) ServerAPI(serverAPI *driver.ServerAPIOptions) *Count

+ func (c *Count) ServerSelector(selector description.ServerSelector) *Count

+ func (c *Count) Session(session *session.Client) *Count

+ func (c *Count) Timeout(timeout *time.Duration) *Count

+ type CountResult struct

+ N int64

+ type Create struct

+ func NewCreate(collectionName string) *Create

+ func (c *Create) Authenticator(authenticator driver.Authenticator) *Create

+ func (c *Create) Capped(capped bool) *Create

+ func (c *Create) ChangeStreamPreAndPostImages(csppi bsoncore.Document) *Create

+ func (c *Create) ClusterClock(clock *session.ClusterClock) *Create

+ func (c *Create) ClusteredIndex(ci bsoncore.Document) *Create

+ func (c *Create) Collation(collation bsoncore.Document) *Create

+ func (c *Create) CollectionName(collectionName string) *Create

+ func (c *Create) CommandMonitor(monitor *event.CommandMonitor) *Create

+ func (c *Create) Crypt(crypt driver.Crypt) *Create

+ func (c *Create) Database(database string) *Create

+ func (c *Create) Deployment(deployment driver.Deployment) *Create

+ func (c *Create) EncryptedFields(ef bsoncore.Document) *Create

+ func (c *Create) Execute(ctx context.Context) error

+ func (c *Create) ExpireAfterSeconds(eas int64) *Create

+ func (c *Create) IndexOptionDefaults(indexOptionDefaults bsoncore.Document) *Create

+ func (c *Create) Max(max int64) *Create

+ func (c *Create) Pipeline(pipeline bsoncore.Document) *Create

+ func (c *Create) ServerAPI(serverAPI *driver.ServerAPIOptions) *Create

+ func (c *Create) ServerSelector(selector description.ServerSelector) *Create

+ func (c *Create) Session(session *session.Client) *Create

+ func (c *Create) Size(size int64) *Create

+ func (c *Create) StorageEngine(storageEngine bsoncore.Document) *Create

+ func (c *Create) TimeSeries(timeSeries bsoncore.Document) *Create

+ func (c *Create) ValidationAction(validationAction string) *Create

+ func (c *Create) ValidationLevel(validationLevel string) *Create

+ func (c *Create) Validator(validator bsoncore.Document) *Create

+ func (c *Create) ViewOn(viewOn string) *Create

+ func (c *Create) WriteConcern(writeConcern *writeconcern.WriteConcern) *Create

+ type CreateIndexes struct

+ func NewCreateIndexes(indexes bsoncore.Document) *CreateIndexes

+ func (ci *CreateIndexes) Authenticator(authenticator driver.Authenticator) *CreateIndexes

+ func (ci *CreateIndexes) ClusterClock(clock *session.ClusterClock) *CreateIndexes

+ func (ci *CreateIndexes) Collection(collection string) *CreateIndexes

+ func (ci *CreateIndexes) CommandMonitor(monitor *event.CommandMonitor) *CreateIndexes

+ func (ci *CreateIndexes) CommitQuorum(commitQuorum bsoncore.Value) *CreateIndexes

+ func (ci *CreateIndexes) Crypt(crypt driver.Crypt) *CreateIndexes

+ func (ci *CreateIndexes) Database(database string) *CreateIndexes

+ func (ci *CreateIndexes) Deployment(deployment driver.Deployment) *CreateIndexes

+ func (ci *CreateIndexes) Execute(ctx context.Context) error

+ func (ci *CreateIndexes) Indexes(indexes bsoncore.Document) *CreateIndexes

+ func (ci *CreateIndexes) Result() CreateIndexesResult

+ func (ci *CreateIndexes) ServerAPI(serverAPI *driver.ServerAPIOptions) *CreateIndexes

+ func (ci *CreateIndexes) ServerSelector(selector description.ServerSelector) *CreateIndexes

+ func (ci *CreateIndexes) Session(session *session.Client) *CreateIndexes

+ func (ci *CreateIndexes) Timeout(timeout *time.Duration) *CreateIndexes

+ func (ci *CreateIndexes) WriteConcern(writeConcern *writeconcern.WriteConcern) *CreateIndexes

+ type CreateIndexesResult struct

+ CreatedCollectionAutomatically bool

+ IndexesAfter int32

+ IndexesBefore int32

+ type CreateSearchIndexResult struct

+ Name string

+ type CreateSearchIndexes struct

+ func NewCreateSearchIndexes(indexes bsoncore.Document) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Authenticator(authenticator driver.Authenticator) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) ClusterClock(clock *session.ClusterClock) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Collection(collection string) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) CommandMonitor(monitor *event.CommandMonitor) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Crypt(crypt driver.Crypt) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Database(database string) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Deployment(deployment driver.Deployment) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Execute(ctx context.Context) error

+ func (csi *CreateSearchIndexes) Indexes(indexes bsoncore.Document) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Result() CreateSearchIndexesResult

+ func (csi *CreateSearchIndexes) ServerAPI(serverAPI *driver.ServerAPIOptions) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) ServerSelector(selector description.ServerSelector) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Session(session *session.Client) *CreateSearchIndexes

+ func (csi *CreateSearchIndexes) Timeout(timeout *time.Duration) *CreateSearchIndexes

+ type CreateSearchIndexesResult struct

+ IndexesCreated []CreateSearchIndexResult

+ type Delete struct

+ func NewDelete(deletes ...bsoncore.Document) *Delete

+ func (d *Delete) Authenticator(authenticator driver.Authenticator) *Delete

+ func (d *Delete) ClusterClock(clock *session.ClusterClock) *Delete

+ func (d *Delete) Collection(collection string) *Delete

+ func (d *Delete) CommandMonitor(monitor *event.CommandMonitor) *Delete

+ func (d *Delete) Comment(comment bsoncore.Value) *Delete

+ func (d *Delete) Crypt(crypt driver.Crypt) *Delete

+ func (d *Delete) Database(database string) *Delete

+ func (d *Delete) Deletes(deletes ...bsoncore.Document) *Delete

+ func (d *Delete) Deployment(deployment driver.Deployment) *Delete

+ func (d *Delete) Execute(ctx context.Context) error

+ func (d *Delete) Hint(hint bool) *Delete

+ func (d *Delete) Let(let bsoncore.Document) *Delete

+ func (d *Delete) Logger(logger *logger.Logger) *Delete

+ func (d *Delete) Ordered(ordered bool) *Delete

+ func (d *Delete) Result() DeleteResult

+ func (d *Delete) Retry(retry driver.RetryMode) *Delete

+ func (d *Delete) ServerAPI(serverAPI *driver.ServerAPIOptions) *Delete

+ func (d *Delete) ServerSelector(selector description.ServerSelector) *Delete

+ func (d *Delete) Session(session *session.Client) *Delete

+ func (d *Delete) Timeout(timeout *time.Duration) *Delete

+ func (d *Delete) WriteConcern(writeConcern *writeconcern.WriteConcern) *Delete

+ type DeleteResult struct

+ N int64

+ type Distinct struct

+ func NewDistinct(key string, query bsoncore.Document) *Distinct

+ func (d *Distinct) Authenticator(authenticator driver.Authenticator) *Distinct

+ func (d *Distinct) ClusterClock(clock *session.ClusterClock) *Distinct

+ func (d *Distinct) Collation(collation bsoncore.Document) *Distinct

+ func (d *Distinct) Collection(collection string) *Distinct

+ func (d *Distinct) CommandMonitor(monitor *event.CommandMonitor) *Distinct

+ func (d *Distinct) Comment(comment bsoncore.Value) *Distinct

+ func (d *Distinct) Crypt(crypt driver.Crypt) *Distinct

+ func (d *Distinct) Database(database string) *Distinct

+ func (d *Distinct) Deployment(deployment driver.Deployment) *Distinct

+ func (d *Distinct) Execute(ctx context.Context) error

+ func (d *Distinct) Hint(hint bsoncore.Value) *Distinct

+ func (d *Distinct) Key(key string) *Distinct

+ func (d *Distinct) Query(query bsoncore.Document) *Distinct

+ func (d *Distinct) ReadConcern(readConcern *readconcern.ReadConcern) *Distinct

+ func (d *Distinct) ReadPreference(readPreference *readpref.ReadPref) *Distinct

+ func (d *Distinct) Result() DistinctResult

+ func (d *Distinct) Retry(retry driver.RetryMode) *Distinct

+ func (d *Distinct) ServerAPI(serverAPI *driver.ServerAPIOptions) *Distinct

+ func (d *Distinct) ServerSelector(selector description.ServerSelector) *Distinct

+ func (d *Distinct) Session(session *session.Client) *Distinct

+ func (d *Distinct) Timeout(timeout *time.Duration) *Distinct

+ type DistinctResult struct

+ Values bsoncore.Value

+ type DropCollection struct

+ func NewDropCollection() *DropCollection

+ func (dc *DropCollection) Authenticator(authenticator driver.Authenticator) *DropCollection

+ func (dc *DropCollection) ClusterClock(clock *session.ClusterClock) *DropCollection

+ func (dc *DropCollection) Collection(collection string) *DropCollection

+ func (dc *DropCollection) CommandMonitor(monitor *event.CommandMonitor) *DropCollection

+ func (dc *DropCollection) Crypt(crypt driver.Crypt) *DropCollection

+ func (dc *DropCollection) Database(database string) *DropCollection

+ func (dc *DropCollection) Deployment(deployment driver.Deployment) *DropCollection

+ func (dc *DropCollection) Execute(ctx context.Context) error

+ func (dc *DropCollection) Result() DropCollectionResult

+ func (dc *DropCollection) ServerAPI(serverAPI *driver.ServerAPIOptions) *DropCollection

+ func (dc *DropCollection) ServerSelector(selector description.ServerSelector) *DropCollection

+ func (dc *DropCollection) Session(session *session.Client) *DropCollection

+ func (dc *DropCollection) Timeout(timeout *time.Duration) *DropCollection

+ func (dc *DropCollection) WriteConcern(writeConcern *writeconcern.WriteConcern) *DropCollection

+ type DropCollectionResult struct

+ NIndexesWas int32

+ Ns string

+ type DropDatabase struct

+ func NewDropDatabase() *DropDatabase

+ func (dd *DropDatabase) Authenticator(authenticator driver.Authenticator) *DropDatabase

+ func (dd *DropDatabase) ClusterClock(clock *session.ClusterClock) *DropDatabase

+ func (dd *DropDatabase) CommandMonitor(monitor *event.CommandMonitor) *DropDatabase

+ func (dd *DropDatabase) Crypt(crypt driver.Crypt) *DropDatabase

+ func (dd *DropDatabase) Database(database string) *DropDatabase

+ func (dd *DropDatabase) Deployment(deployment driver.Deployment) *DropDatabase

+ func (dd *DropDatabase) Execute(ctx context.Context) error

+ func (dd *DropDatabase) ServerAPI(serverAPI *driver.ServerAPIOptions) *DropDatabase

+ func (dd *DropDatabase) ServerSelector(selector description.ServerSelector) *DropDatabase

+ func (dd *DropDatabase) Session(session *session.Client) *DropDatabase

+ func (dd *DropDatabase) WriteConcern(writeConcern *writeconcern.WriteConcern) *DropDatabase

+ type DropIndexes struct

+ func NewDropIndexes(index any) *DropIndexes

+ func (di *DropIndexes) Authenticator(authenticator driver.Authenticator) *DropIndexes

+ func (di *DropIndexes) ClusterClock(clock *session.ClusterClock) *DropIndexes

+ func (di *DropIndexes) Collection(collection string) *DropIndexes

+ func (di *DropIndexes) CommandMonitor(monitor *event.CommandMonitor) *DropIndexes

+ func (di *DropIndexes) Crypt(crypt driver.Crypt) *DropIndexes

+ func (di *DropIndexes) Database(database string) *DropIndexes

+ func (di *DropIndexes) Deployment(deployment driver.Deployment) *DropIndexes

+ func (di *DropIndexes) Execute(ctx context.Context) error

+ func (di *DropIndexes) Index(index any) *DropIndexes

+ func (di *DropIndexes) Result() DropIndexesResult

+ func (di *DropIndexes) ServerAPI(serverAPI *driver.ServerAPIOptions) *DropIndexes

+ func (di *DropIndexes) ServerSelector(selector description.ServerSelector) *DropIndexes

+ func (di *DropIndexes) Session(session *session.Client) *DropIndexes

+ func (di *DropIndexes) Timeout(timeout *time.Duration) *DropIndexes

+ func (di *DropIndexes) WriteConcern(writeConcern *writeconcern.WriteConcern) *DropIndexes

+ type DropIndexesResult struct

+ NIndexesWas int32

+ type DropSearchIndex struct

+ func NewDropSearchIndex(index string) *DropSearchIndex

+ func (dsi *DropSearchIndex) Authenticator(authenticator driver.Authenticator) *DropSearchIndex

+ func (dsi *DropSearchIndex) ClusterClock(clock *session.ClusterClock) *DropSearchIndex

+ func (dsi *DropSearchIndex) Collection(collection string) *DropSearchIndex

+ func (dsi *DropSearchIndex) CommandMonitor(monitor *event.CommandMonitor) *DropSearchIndex

+ func (dsi *DropSearchIndex) Crypt(crypt driver.Crypt) *DropSearchIndex

+ func (dsi *DropSearchIndex) Database(database string) *DropSearchIndex

+ func (dsi *DropSearchIndex) Deployment(deployment driver.Deployment) *DropSearchIndex

+ func (dsi *DropSearchIndex) Execute(ctx context.Context) error

+ func (dsi *DropSearchIndex) Index(index string) *DropSearchIndex

+ func (dsi *DropSearchIndex) Result() DropSearchIndexResult

+ func (dsi *DropSearchIndex) ServerAPI(serverAPI *driver.ServerAPIOptions) *DropSearchIndex

+ func (dsi *DropSearchIndex) ServerSelector(selector description.ServerSelector) *DropSearchIndex

+ func (dsi *DropSearchIndex) Session(session *session.Client) *DropSearchIndex

+ func (dsi *DropSearchIndex) Timeout(timeout *time.Duration) *DropSearchIndex

+ type DropSearchIndexResult struct

+ Ok int32

+ type EndSessions struct

+ func NewEndSessions(sessionIDs bsoncore.Document) *EndSessions

+ func (es *EndSessions) Authenticator(authenticator driver.Authenticator) *EndSessions

+ func (es *EndSessions) ClusterClock(clock *session.ClusterClock) *EndSessions

+ func (es *EndSessions) CommandMonitor(monitor *event.CommandMonitor) *EndSessions

+ func (es *EndSessions) Crypt(crypt driver.Crypt) *EndSessions

+ func (es *EndSessions) Database(database string) *EndSessions

+ func (es *EndSessions) Deployment(deployment driver.Deployment) *EndSessions

+ func (es *EndSessions) Execute(ctx context.Context) error

+ func (es *EndSessions) ServerAPI(serverAPI *driver.ServerAPIOptions) *EndSessions

+ func (es *EndSessions) ServerSelector(selector description.ServerSelector) *EndSessions

+ func (es *EndSessions) Session(session *session.Client) *EndSessions

+ func (es *EndSessions) SessionIDs(sessionIDs bsoncore.Document) *EndSessions

+ type Find struct

+ func NewFind(filter bsoncore.Document) *Find

+ func (f *Find) AllowDiskUse(allowDiskUse bool) *Find

+ func (f *Find) AllowPartialResults(allowPartialResults bool) *Find

+ func (f *Find) Authenticator(authenticator driver.Authenticator) *Find

+ func (f *Find) AwaitData(awaitData bool) *Find

+ func (f *Find) BatchSize(batchSize int32) *Find

+ func (f *Find) ClusterClock(clock *session.ClusterClock) *Find

+ func (f *Find) Collation(collation bsoncore.Document) *Find

+ func (f *Find) Collection(collection string) *Find

+ func (f *Find) CommandMonitor(monitor *event.CommandMonitor) *Find

+ func (f *Find) Comment(comment bsoncore.Value) *Find

+ func (f *Find) Crypt(crypt driver.Crypt) *Find

+ func (f *Find) Database(database string) *Find

+ func (f *Find) Deployment(deployment driver.Deployment) *Find

+ func (f *Find) Execute(ctx context.Context) error

+ func (f *Find) Filter(filter bsoncore.Document) *Find

+ func (f *Find) Hint(hint bsoncore.Value) *Find

+ func (f *Find) Let(let bsoncore.Document) *Find

+ func (f *Find) Limit(limit int64) *Find

+ func (f *Find) Logger(logger *logger.Logger) *Find

+ func (f *Find) Max(max bsoncore.Document) *Find

+ func (f *Find) Min(min bsoncore.Document) *Find

+ func (f *Find) NoCursorTimeout(noCursorTimeout bool) *Find

+ func (f *Find) OmitMaxTimeMS(omit bool) *Find

+ func (f *Find) OplogReplay(oplogReplay bool) *Find

+ func (f *Find) Projection(projection bsoncore.Document) *Find

+ func (f *Find) ReadConcern(readConcern *readconcern.ReadConcern) *Find

+ func (f *Find) ReadPreference(readPreference *readpref.ReadPref) *Find

+ func (f *Find) Result(opts driver.CursorOptions) (*driver.BatchCursor, error)

+ func (f *Find) Retry(retry driver.RetryMode) *Find

+ func (f *Find) ReturnKey(returnKey bool) *Find

+ func (f *Find) ServerAPI(serverAPI *driver.ServerAPIOptions) *Find

+ func (f *Find) ServerSelector(selector description.ServerSelector) *Find

+ func (f *Find) Session(session *session.Client) *Find

+ func (f *Find) ShowRecordID(showRecordID bool) *Find

+ func (f *Find) SingleBatch(singleBatch bool) *Find

+ func (f *Find) Skip(skip int64) *Find

+ func (f *Find) Snapshot(snapshot bool) *Find

+ func (f *Find) Sort(sort bsoncore.Document) *Find

+ func (f *Find) Tailable(tailable bool) *Find

+ func (f *Find) Timeout(timeout *time.Duration) *Find

+ type FindAndModify struct

+ func NewFindAndModify(query bsoncore.Document) *FindAndModify

+ func (fam *FindAndModify) ArrayFilters(arrayFilters bsoncore.Array) *FindAndModify

+ func (fam *FindAndModify) Authenticator(authenticator driver.Authenticator) *FindAndModify

+ func (fam *FindAndModify) BypassDocumentValidation(bypassDocumentValidation bool) *FindAndModify

+ func (fam *FindAndModify) ClusterClock(clock *session.ClusterClock) *FindAndModify

+ func (fam *FindAndModify) Collation(collation bsoncore.Document) *FindAndModify

+ func (fam *FindAndModify) Collection(collection string) *FindAndModify

+ func (fam *FindAndModify) CommandMonitor(monitor *event.CommandMonitor) *FindAndModify

+ func (fam *FindAndModify) Comment(comment bsoncore.Value) *FindAndModify

+ func (fam *FindAndModify) Crypt(crypt driver.Crypt) *FindAndModify

+ func (fam *FindAndModify) Database(database string) *FindAndModify

+ func (fam *FindAndModify) Deployment(deployment driver.Deployment) *FindAndModify

+ func (fam *FindAndModify) Execute(ctx context.Context) error

+ func (fam *FindAndModify) Fields(fields bsoncore.Document) *FindAndModify

+ func (fam *FindAndModify) Hint(hint bsoncore.Value) *FindAndModify

+ func (fam *FindAndModify) Let(let bsoncore.Document) *FindAndModify

+ func (fam *FindAndModify) NewDocument(newDocument bool) *FindAndModify

+ func (fam *FindAndModify) Query(query bsoncore.Document) *FindAndModify

+ func (fam *FindAndModify) Remove(remove bool) *FindAndModify

+ func (fam *FindAndModify) Result() FindAndModifyResult

+ func (fam *FindAndModify) Retry(retry driver.RetryMode) *FindAndModify

+ func (fam *FindAndModify) ServerAPI(serverAPI *driver.ServerAPIOptions) *FindAndModify

+ func (fam *FindAndModify) ServerSelector(selector description.ServerSelector) *FindAndModify

+ func (fam *FindAndModify) Session(session *session.Client) *FindAndModify

+ func (fam *FindAndModify) Sort(sort bsoncore.Document) *FindAndModify

+ func (fam *FindAndModify) Timeout(timeout *time.Duration) *FindAndModify

+ func (fam *FindAndModify) Update(update bsoncore.Value) *FindAndModify

+ func (fam *FindAndModify) Upsert(upsert bool) *FindAndModify

+ func (fam *FindAndModify) WriteConcern(writeConcern *writeconcern.WriteConcern) *FindAndModify

+ type FindAndModifyResult struct

+ LastErrorObject LastErrorObject

+ Value bsoncore.Document

+ type Hello struct

+ func NewHello() *Hello

+ func (h *Hello) AppName(appname string) *Hello

+ func (h *Hello) Authenticator(authenticator driver.Authenticator) *Hello

+ func (h *Hello) ClusterClock(clock *session.ClusterClock) *Hello

+ func (h *Hello) Compressors(compressors []string) *Hello

+ func (h *Hello) Deployment(d driver.Deployment) *Hello

+ func (h *Hello) Execute(ctx context.Context) error

+ func (h *Hello) FinishHandshake(context.Context, *mnet.Connection) error

+ func (h *Hello) GetHandshakeInformation(ctx context.Context, _ address.Address, conn *mnet.Connection) (driver.HandshakeInformation, error)

+ func (h *Hello) LoadBalanced(lb bool) *Hello

+ func (h *Hello) MaxAwaitTimeMS(awaitTime int64) *Hello

+ func (h *Hello) OmitMaxTimeMS(val bool) *Hello

+ func (h *Hello) OuterLibraryName(name string) *Hello

+ func (h *Hello) OuterLibraryPlatform(platform string) *Hello

+ func (h *Hello) OuterLibraryVersion(version string) *Hello

+ func (h *Hello) Result(addr address.Address) description.Server

+ func (h *Hello) SASLSupportedMechs(username string) *Hello

+ func (h *Hello) ServerAPI(serverAPI *driver.ServerAPIOptions) *Hello

+ func (h *Hello) SpeculativeAuthenticate(doc bsoncore.Document) *Hello

+ func (h *Hello) StreamResponse(ctx context.Context, conn *mnet.Connection) error

+ func (h *Hello) TopologyVersion(tv *description.TopologyVersion) *Hello

+ type Insert struct

+ func NewInsert(documents ...bsoncore.Document) *Insert

+ func (i *Insert) Authenticator(authenticator driver.Authenticator) *Insert

+ func (i *Insert) BypassDocumentValidation(bypassDocumentValidation bool) *Insert

+ func (i *Insert) ClusterClock(clock *session.ClusterClock) *Insert

+ func (i *Insert) Collection(collection string) *Insert

+ func (i *Insert) CommandMonitor(monitor *event.CommandMonitor) *Insert

+ func (i *Insert) Comment(comment bsoncore.Value) *Insert

+ func (i *Insert) Crypt(crypt driver.Crypt) *Insert

+ func (i *Insert) Database(database string) *Insert

+ func (i *Insert) Deployment(deployment driver.Deployment) *Insert

+ func (i *Insert) Documents(documents ...bsoncore.Document) *Insert

+ func (i *Insert) Execute(ctx context.Context) error

+ func (i *Insert) Logger(logger *logger.Logger) *Insert

+ func (i *Insert) Ordered(ordered bool) *Insert

+ func (i *Insert) Result() InsertResult

+ func (i *Insert) Retry(retry driver.RetryMode) *Insert

+ func (i *Insert) ServerAPI(serverAPI *driver.ServerAPIOptions) *Insert

+ func (i *Insert) ServerSelector(selector description.ServerSelector) *Insert

+ func (i *Insert) Session(session *session.Client) *Insert

+ func (i *Insert) Timeout(timeout *time.Duration) *Insert

+ func (i *Insert) WriteConcern(writeConcern *writeconcern.WriteConcern) *Insert

+ type InsertResult struct

+ N int64

+ type LastErrorObject struct

+ UpdatedExisting bool

+ Upserted interface{}

+ type ListCollections struct

+ func NewListCollections(filter bsoncore.Document) *ListCollections

+ func (lc *ListCollections) Authenticator(authenticator driver.Authenticator) *ListCollections

+ func (lc *ListCollections) AuthorizedCollections(authorizedCollections bool) *ListCollections

+ func (lc *ListCollections) BatchSize(batchSize int32) *ListCollections

+ func (lc *ListCollections) ClusterClock(clock *session.ClusterClock) *ListCollections

+ func (lc *ListCollections) CommandMonitor(monitor *event.CommandMonitor) *ListCollections

+ func (lc *ListCollections) Crypt(crypt driver.Crypt) *ListCollections

+ func (lc *ListCollections) Database(database string) *ListCollections

+ func (lc *ListCollections) Deployment(deployment driver.Deployment) *ListCollections

+ func (lc *ListCollections) Execute(ctx context.Context) error

+ func (lc *ListCollections) Filter(filter bsoncore.Document) *ListCollections

+ func (lc *ListCollections) NameOnly(nameOnly bool) *ListCollections

+ func (lc *ListCollections) ReadPreference(readPreference *readpref.ReadPref) *ListCollections

+ func (lc *ListCollections) Result(opts driver.CursorOptions) (*driver.BatchCursor, error)

+ func (lc *ListCollections) Retry(retry driver.RetryMode) *ListCollections

+ func (lc *ListCollections) ServerAPI(serverAPI *driver.ServerAPIOptions) *ListCollections

+ func (lc *ListCollections) ServerSelector(selector description.ServerSelector) *ListCollections

+ func (lc *ListCollections) Session(session *session.Client) *ListCollections

+ func (lc *ListCollections) Timeout(timeout *time.Duration) *ListCollections

+ type ListDatabases struct

+ func NewListDatabases(filter bsoncore.Document) *ListDatabases

+ func (ld *ListDatabases) Authenticator(authenticator driver.Authenticator) *ListDatabases

+ func (ld *ListDatabases) AuthorizedDatabases(authorizedDatabases bool) *ListDatabases

+ func (ld *ListDatabases) ClusterClock(clock *session.ClusterClock) *ListDatabases

+ func (ld *ListDatabases) CommandMonitor(monitor *event.CommandMonitor) *ListDatabases

+ func (ld *ListDatabases) Crypt(crypt driver.Crypt) *ListDatabases

+ func (ld *ListDatabases) Database(database string) *ListDatabases

+ func (ld *ListDatabases) Deployment(deployment driver.Deployment) *ListDatabases

+ func (ld *ListDatabases) Execute(ctx context.Context) error

+ func (ld *ListDatabases) Filter(filter bsoncore.Document) *ListDatabases

+ func (ld *ListDatabases) NameOnly(nameOnly bool) *ListDatabases

+ func (ld *ListDatabases) ReadPreference(readPreference *readpref.ReadPref) *ListDatabases

+ func (ld *ListDatabases) Result() ListDatabasesResult

+ func (ld *ListDatabases) Retry(retry driver.RetryMode) *ListDatabases

+ func (ld *ListDatabases) ServerAPI(serverAPI *driver.ServerAPIOptions) *ListDatabases

+ func (ld *ListDatabases) ServerSelector(selector description.ServerSelector) *ListDatabases

+ func (ld *ListDatabases) Session(session *session.Client) *ListDatabases

+ func (ld *ListDatabases) Timeout(timeout *time.Duration) *ListDatabases

+ type ListDatabasesResult struct

+ Databases []databaseRecord

+ TotalSize int64

+ type ListIndexes struct

+ func NewListIndexes() *ListIndexes

+ func (li *ListIndexes) Authenticator(authenticator driver.Authenticator) *ListIndexes

+ func (li *ListIndexes) BatchSize(batchSize int32) *ListIndexes

+ func (li *ListIndexes) ClusterClock(clock *session.ClusterClock) *ListIndexes

+ func (li *ListIndexes) Collection(collection string) *ListIndexes

+ func (li *ListIndexes) CommandMonitor(monitor *event.CommandMonitor) *ListIndexes

+ func (li *ListIndexes) Crypt(crypt driver.Crypt) *ListIndexes

+ func (li *ListIndexes) Database(database string) *ListIndexes

+ func (li *ListIndexes) Deployment(deployment driver.Deployment) *ListIndexes

+ func (li *ListIndexes) Execute(ctx context.Context) error

+ func (li *ListIndexes) Result(opts driver.CursorOptions) (*driver.BatchCursor, error)

+ func (li *ListIndexes) Retry(retry driver.RetryMode) *ListIndexes

+ func (li *ListIndexes) ServerAPI(serverAPI *driver.ServerAPIOptions) *ListIndexes

+ func (li *ListIndexes) ServerSelector(selector description.ServerSelector) *ListIndexes

+ func (li *ListIndexes) Session(session *session.Client) *ListIndexes

+ func (li *ListIndexes) Timeout(timeout *time.Duration) *ListIndexes

+ type Update struct

+ func NewUpdate(updates ...bsoncore.Document) *Update

+ func (u *Update) ArrayFilters(arrayFilters bool) *Update

+ func (u *Update) Authenticator(authenticator driver.Authenticator) *Update

+ func (u *Update) BypassDocumentValidation(bypassDocumentValidation bool) *Update

+ func (u *Update) ClusterClock(clock *session.ClusterClock) *Update

+ func (u *Update) Collection(collection string) *Update

+ func (u *Update) CommandMonitor(monitor *event.CommandMonitor) *Update

+ func (u *Update) Comment(comment bsoncore.Value) *Update

+ func (u *Update) Crypt(crypt driver.Crypt) *Update

+ func (u *Update) Database(database string) *Update

+ func (u *Update) Deployment(deployment driver.Deployment) *Update

+ func (u *Update) Execute(ctx context.Context) error

+ func (u *Update) Hint(hint bool) *Update

+ func (u *Update) Let(let bsoncore.Document) *Update

+ func (u *Update) Logger(logger *logger.Logger) *Update

+ func (u *Update) Ordered(ordered bool) *Update

+ func (u *Update) Result() UpdateResult

+ func (u *Update) Retry(retry driver.RetryMode) *Update

+ func (u *Update) ServerAPI(serverAPI *driver.ServerAPIOptions) *Update

+ func (u *Update) ServerSelector(selector description.ServerSelector) *Update

+ func (u *Update) Session(session *session.Client) *Update

+ func (u *Update) Timeout(timeout *time.Duration) *Update

+ func (u *Update) Updates(updates ...bsoncore.Document) *Update

+ func (u *Update) WriteConcern(writeConcern *writeconcern.WriteConcern) *Update

+ type UpdateResult struct

+ N int64

+ NModified int64

+ Upserted []Upsert

+ type UpdateSearchIndex struct

+ func NewUpdateSearchIndex(index string, definition bsoncore.Document) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Authenticator(authenticator driver.Authenticator) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) ClusterClock(clock *session.ClusterClock) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Collection(collection string) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) CommandMonitor(monitor *event.CommandMonitor) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Crypt(crypt driver.Crypt) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Database(database string) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Definition(definition bsoncore.Document) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Deployment(deployment driver.Deployment) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Execute(ctx context.Context) error

+ func (usi *UpdateSearchIndex) Index(name string) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Result() UpdateSearchIndexResult

+ func (usi *UpdateSearchIndex) ServerAPI(serverAPI *driver.ServerAPIOptions) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) ServerSelector(selector description.ServerSelector) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Session(session *session.Client) *UpdateSearchIndex

+ func (usi *UpdateSearchIndex) Timeout(timeout *time.Duration) *UpdateSearchIndex

+ type UpdateSearchIndexResult struct

+ Ok int32

+ type Upsert struct

+ ID interface{}

+ Index int64

v2.0.0-beta2

Sep 18, 2024

v2.0.0-beta1

Jul 26, 2024

v2.0.0-alpha2

Jul 26, 2024

Other modules containing this package

go.mongodb.org/mongo-driver