mongo-driver: go.mongodb.org/mongo-driver/x/mongo/driver/operation Index | Files

package operation

import "go.mongodb.org/mongo-driver/x/mongo/driver/operation"

Index

Package Files

abort_transaction.go aggregate.go command.go commit_transaction.go count.go createIndexes.go delete.go distinct.go drop_collection.go drop_database.go drop_indexes.go end_sessions.go find.go find_and_modify.go insert.go ismaster.go listDatabases.go list_collections.go list_indexes.go operation.go update.go

type AbortTransaction Uses

type AbortTransaction struct {
    // contains filtered or unexported fields
}

AbortTransaction performs an abortTransaction operation.

func NewAbortTransaction Uses

func NewAbortTransaction() *AbortTransaction

NewAbortTransaction constructs and returns a new AbortTransaction.

func (*AbortTransaction) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*AbortTransaction) Collection Uses

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

Collection sets the collection that this command will run against.

func (*AbortTransaction) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*AbortTransaction) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*AbortTransaction) Database Uses

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

Database sets the database to run this operation against.

func (*AbortTransaction) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*AbortTransaction) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*AbortTransaction) RecoveryToken Uses

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

RecoveryToken sets the recovery token to use when committing or aborting a sharded transaction.

func (*AbortTransaction) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*AbortTransaction) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*AbortTransaction) Session Uses

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

Session sets the session for this operation.

func (*AbortTransaction) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type Aggregate Uses

type Aggregate struct {
    // contains filtered or unexported fields
}

Performs an aggregate operation

func NewAggregate Uses

func NewAggregate(pipeline bsoncore.Document) *Aggregate

NewAggregate constructs and returns a new Aggregate.

func (*Aggregate) AllowDiskUse Uses

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

AllowDiskUse enables writing to temporary files. When true, aggregation stages can write to the dbPath/_tmp directory.

func (*Aggregate) BatchSize Uses

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

BatchSize specifies the number of documents to return in every batch.

func (*Aggregate) BypassDocumentValidation Uses

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

BypassDocumentValidation allows the write to opt-out of document level validation. This only applies when the $out stage is specified.

func (*Aggregate) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*Aggregate) Collation Uses

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

Collation specifies a collation. This option is only valid for server versions 3.4 and above.

func (*Aggregate) Collection Uses

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

Collection sets the collection that this command will run against.

func (*Aggregate) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*Aggregate) Comment Uses

func (a *Aggregate) Comment(comment string) *Aggregate

Comment specifies an arbitrary string to help trace the operation through the database profiler, currentOp, and logs.

func (*Aggregate) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*Aggregate) Database Uses

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

Database sets the database to run this operation against.

func (*Aggregate) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*Aggregate) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*Aggregate) Hint Uses

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

Hint specifies the index to use.

func (*Aggregate) MaxTimeMS Uses

func (a *Aggregate) MaxTimeMS(maxTimeMS int64) *Aggregate

MaxTimeMS specifies the maximum amount of time to allow the query to run.

func (*Aggregate) Pipeline Uses

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

Pipeline determines how data is transformed for an aggregation.

func (*Aggregate) ReadConcern Uses

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

ReadConcern specifies the read concern for this operation.

func (*Aggregate) ReadPreference Uses

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

ReadPreference set the read prefernce used with this operation.

func (*Aggregate) Result Uses

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

Result returns the result of executing this operation.

func (*Aggregate) ResultCursorResponse Uses

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

func (*Aggregate) Retry Uses

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

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 (*Aggregate) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*Aggregate) Session Uses

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

Session sets the session for this operation.

func (*Aggregate) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type Command Uses

type Command struct {
    // contains filtered or unexported fields
}

Command is used to run a generic operation.

func NewCommand Uses

func NewCommand(command bsoncore.Document) *Command

NewCommand constructs and returns a new Command.

func (*Command) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*Command) Command Uses

func (c *Command) Command(command bsoncore.Document) *Command

Command sets the command to be run.

func (*Command) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*Command) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*Command) Database Uses

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

Database sets the database to run this operation against.

func (*Command) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*Command) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*Command) ReadConcern Uses

func (c *Command) ReadConcern(readConcern *readconcern.ReadConcern) *Command

ReadConcern specifies the read concern for this operation.

func (*Command) ReadPreference Uses

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

ReadPreference set the read prefernce used with this operation.

func (*Command) Result Uses

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

Result returns the result of executing this operation.

func (*Command) ResultCursor Uses

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

ResultCursor parses the command response as a cursor and returns the resulting BatchCursor.

func (*Command) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*Command) Session Uses

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

Session sets the session for this operation.

type CommitTransaction Uses

type CommitTransaction struct {
    // contains filtered or unexported fields
}

CommitTransaction attempts to commit a transaction.

func NewCommitTransaction Uses

func NewCommitTransaction() *CommitTransaction

NewCommitTransaction constructs and returns a new CommitTransaction.

func (*CommitTransaction) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*CommitTransaction) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*CommitTransaction) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*CommitTransaction) Database Uses

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

Database sets the database to run this operation against.

func (*CommitTransaction) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*CommitTransaction) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*CommitTransaction) MaxTimeMS Uses

func (ct *CommitTransaction) MaxTimeMS(maxTimeMS int64) *CommitTransaction

MaxTimeMS specifies the maximum amount of time to allow the query to run.

func (*CommitTransaction) RecoveryToken Uses

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

RecoveryToken sets the recovery token to use when committing or aborting a sharded transaction.

func (*CommitTransaction) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*CommitTransaction) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*CommitTransaction) Session Uses

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

Session sets the session for this operation.

func (*CommitTransaction) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type Count Uses

type Count struct {
    // contains filtered or unexported fields
}

Performs a count operation

func NewCount Uses

func NewCount() *Count

NewCount constructs and returns a new Count.

func (*Count) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*Count) Collection Uses

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

Collection sets the collection that this command will run against.

func (*Count) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*Count) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*Count) Database Uses

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

Database sets the database to run this operation against.

func (*Count) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*Count) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*Count) MaxTimeMS Uses

func (c *Count) MaxTimeMS(maxTimeMS int64) *Count

MaxTimeMS specifies the maximum amount of time to allow the query to run.

func (*Count) Query Uses

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

Query determines what results are returned from find.

func (*Count) ReadConcern Uses

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

ReadConcern specifies the read concern for this operation.

func (*Count) ReadPreference Uses

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

ReadPreference set the read prefernce used with this operation.

func (*Count) Result Uses

func (c *Count) Result() CountResult

Result returns the result of executing this operation.

func (*Count) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*Count) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*Count) Session Uses

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

Session sets the session for this operation.

type CountResult Uses

type CountResult struct {
    // The number of documents found
    N int64
}

type CreateIndexes Uses

type CreateIndexes struct {
    // contains filtered or unexported fields
}

CreateIndexes performs a createIndexes operation.

func NewCreateIndexes Uses

func NewCreateIndexes(indexes bsoncore.Document) *CreateIndexes

NewCreateIndexes constructs and returns a new CreateIndexes.

func (*CreateIndexes) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*CreateIndexes) Collection Uses

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

Collection sets the collection that this command will run against.

func (*CreateIndexes) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*CreateIndexes) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*CreateIndexes) Database Uses

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

Database sets the database to run this operation against.

func (*CreateIndexes) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*CreateIndexes) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*CreateIndexes) Indexes Uses

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

An array containing index specification documents for the indexes being created.

func (*CreateIndexes) MaxTimeMS Uses

func (ci *CreateIndexes) MaxTimeMS(maxTimeMS int64) *CreateIndexes

MaxTimeMS specifies the maximum amount of time to allow the query to run.

func (*CreateIndexes) Result Uses

func (ci *CreateIndexes) Result() CreateIndexesResult

Result returns the result of executing this operation.

func (*CreateIndexes) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*CreateIndexes) Session Uses

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

Session sets the session for this operation.

type CreateIndexesResult Uses

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
}

type Delete Uses

type Delete struct {
    // contains filtered or unexported fields
}

Delete performs a delete operation

func NewDelete Uses

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

NewDelete constructs and returns a new Delete.

func (*Delete) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*Delete) Collection Uses

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

Collection sets the collection that this command will run against.

func (*Delete) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*Delete) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*Delete) Database Uses

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

Database sets the database to run this operation against.

func (*Delete) Deletes Uses

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

Deletes adds documents to this operation that will be used to determine what documents to delete when this operation is executed. These documents should have the form {q: <query>, limit: <integer limit>, collation: <document>}. The collation field is optional. If limit is 0, there will be no limit on the number of documents deleted.

func (*Delete) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*Delete) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*Delete) Ordered Uses

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

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 (*Delete) Result Uses

func (d *Delete) Result() DeleteResult

Result returns the result of executing this operation.

func (*Delete) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*Delete) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*Delete) Session Uses

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

Session sets the session for this operation.

func (*Delete) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type DeleteResult Uses

type DeleteResult struct {
    // Number of documents successfully deleted.
    N int32
}

type Distinct Uses

type Distinct struct {
    // contains filtered or unexported fields
}

Distinct performs a distinct operation.

func NewDistinct Uses

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

NewDistinct constructs and returns a new Distinct.

func (*Distinct) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*Distinct) Collation Uses

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

Collation specifies a collation to be used.

func (*Distinct) Collection Uses

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

Collection sets the collection that this command will run against.

func (*Distinct) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*Distinct) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*Distinct) Database Uses

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

Database sets the database to run this operation against.

func (*Distinct) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*Distinct) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*Distinct) Key Uses

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

Key specifies which field to return distinct values for.

func (*Distinct) MaxTimeMS Uses

func (d *Distinct) MaxTimeMS(maxTimeMS int64) *Distinct

MaxTimeMS specifies the maximum amount of time to allow the query to run.

func (*Distinct) Query Uses

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

Query specifies which documents to return distinct values from.

func (*Distinct) ReadConcern Uses

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

ReadConcern specifies the read concern for this operation.

func (*Distinct) ReadPreference Uses

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

ReadPreference set the read prefernce used with this operation.

func (*Distinct) Result Uses

func (d *Distinct) Result() DistinctResult

Result returns the result of executing this operation.

func (*Distinct) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*Distinct) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*Distinct) Session Uses

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

Session sets the session for this operation.

type DistinctResult Uses

type DistinctResult struct {
    // The distinct values for the field.
    Values bsoncore.Value
}

type DropCollection Uses

type DropCollection struct {
    // contains filtered or unexported fields
}

DropCollection performs a drop operation.

func NewDropCollection Uses

func NewDropCollection() *DropCollection

NewDropCollection constructs and returns a new DropCollection.

func (*DropCollection) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*DropCollection) Collection Uses

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

Collection sets the collection that this command will run against.

func (*DropCollection) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*DropCollection) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*DropCollection) Database Uses

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

Database sets the database to run this operation against.

func (*DropCollection) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*DropCollection) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*DropCollection) Result Uses

func (dc *DropCollection) Result() DropCollectionResult

Result returns the result of executing this operation.

func (*DropCollection) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*DropCollection) Session Uses

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

Session sets the session for this operation.

func (*DropCollection) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type DropCollectionResult Uses

type DropCollectionResult struct {
    // The number of indexes in the dropped collection.
    NIndexesWas int32
    // The namespace of the dropped collection.
    Ns  string
}

type DropDatabase Uses

type DropDatabase struct {
    // contains filtered or unexported fields
}

DropDatabase performs a dropDatabase operation

func NewDropDatabase Uses

func NewDropDatabase() *DropDatabase

NewDropDatabase constructs and returns a new DropDatabase.

func (*DropDatabase) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*DropDatabase) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*DropDatabase) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*DropDatabase) Database Uses

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

Database sets the database to run this operation against.

func (*DropDatabase) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*DropDatabase) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*DropDatabase) Result Uses

func (dd *DropDatabase) Result() DropDatabaseResult

Result returns the result of executing this operation.

func (*DropDatabase) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*DropDatabase) Session Uses

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

Session sets the session for this operation.

func (*DropDatabase) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type DropDatabaseResult Uses

type DropDatabaseResult struct {
    // The dropped database.
    Dropped string
}

type DropIndexes Uses

type DropIndexes struct {
    // contains filtered or unexported fields
}

DropIndexes performs an dropIndexes operation.

func NewDropIndexes Uses

func NewDropIndexes(index string) *DropIndexes

NewDropIndexes constructs and returns a new DropIndexes.

func (*DropIndexes) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*DropIndexes) Collection Uses

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

Collection sets the collection that this command will run against.

func (*DropIndexes) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*DropIndexes) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*DropIndexes) Database Uses

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

Database sets the database to run this operation against.

func (*DropIndexes) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*DropIndexes) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*DropIndexes) Index Uses

func (di *DropIndexes) Index(index string) *DropIndexes

Index specifies the name of the index to drop. If '*' is specified, all indexes will be dropped.

func (*DropIndexes) MaxTimeMS Uses

func (di *DropIndexes) MaxTimeMS(maxTimeMS int64) *DropIndexes

MaxTimeMS specifies the maximum amount of time to allow the query to run.

func (*DropIndexes) Result Uses

func (di *DropIndexes) Result() DropIndexesResult

Result returns the result of executing this operation.

func (*DropIndexes) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*DropIndexes) Session Uses

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

Session sets the session for this operation.

func (*DropIndexes) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type DropIndexesResult Uses

type DropIndexesResult struct {
    // Number of indexes that existed before the drop was executed.
    NIndexesWas int32
}

type EndSessions Uses

type EndSessions struct {
    // contains filtered or unexported fields
}

EndSessions performs an endSessions operation.

func NewEndSessions Uses

func NewEndSessions(sessionIDs bsoncore.Document) *EndSessions

NewEndSessions constructs and returns a new EndSessions.

func (*EndSessions) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*EndSessions) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*EndSessions) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*EndSessions) Database Uses

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

Database sets the database to run this operation against.

func (*EndSessions) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*EndSessions) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*EndSessions) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*EndSessions) Session Uses

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

Session sets the session for this operation.

func (*EndSessions) SessionIDs Uses

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

sessionIDs specify the sessions to be expired.

type Find Uses

type Find struct {
    // contains filtered or unexported fields
}

Find performs a find operation.

func NewFind Uses

func NewFind(filter bsoncore.Document) *Find

NewFind constructs and returns a new Find.

func (*Find) AllowPartialResults Uses

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

AllowPartialResults when true allows partial results to be returned if some shards are down.

func (*Find) AwaitData Uses

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

AwaitData when true makes a cursor block before returning when no data is available.

func (*Find) BatchSize Uses

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

BatchSize specifies the number of documents to return in every batch.

func (*Find) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*Find) Collation Uses

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

Collation specifies a collation to be used.

func (*Find) Collection Uses

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

Collection sets the collection that this command will run against.

func (*Find) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*Find) Comment Uses

func (f *Find) Comment(comment string) *Find

Comment sets a string to help trace an operation.

func (*Find) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*Find) Database Uses

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

Database sets the database to run this operation against.

func (*Find) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*Find) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*Find) Filter Uses

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

Filter determines what results are returned from find.

func (*Find) Hint Uses

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

Hint specifies the index to use.

func (*Find) Limit Uses

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

Limit sets a limit on the number of documents to return.

func (*Find) Max Uses

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

Max sets an exclusive upper bound for a specific index.

func (*Find) MaxTimeMS Uses

func (f *Find) MaxTimeMS(maxTimeMS int64) *Find

MaxTimeMS specifies the maximum amount of time to allow the query to run.

func (*Find) Min Uses

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

Min sets an inclusive lower bound for a specific index.

func (*Find) NoCursorTimeout Uses

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

NoCursorTimeout when true prevents cursor from timing out after an inactivity period.

func (*Find) OplogReplay Uses

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

OplogReplay when true replays a replica set's oplog.

func (*Find) Projection Uses

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

Project limits the fields returned for all documents.

func (*Find) ReadConcern Uses

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

ReadConcern specifies the read concern for this operation.

func (*Find) ReadPreference Uses

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

ReadPreference set the read prefernce used with this operation.

func (*Find) Result Uses

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

Result returns the result of executing this operation.

func (*Find) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*Find) ReturnKey Uses

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

ReturnKey when true returns index keys for all result documents.

func (*Find) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*Find) Session Uses

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

Session sets the session for this operation.

func (*Find) ShowRecordID Uses

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

ShowRecordID when true adds a $recordId field with the record identifier to returned documents.

func (*Find) SingleBatch Uses

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

SingleBatch specifies whether the results should be returned in a single batch.

func (*Find) Skip Uses

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

Skip specifies the number of documents to skip before returning.

func (*Find) Snapshot Uses

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

Snapshot prevents the cursor from returning a document more than once because of an intervening write operation.

func (*Find) Sort Uses

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

Sort specifies the order in which to return results.

func (*Find) Tailable Uses

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

Tailable keeps a cursor open and resumable after the last data has been retrieved.

type FindAndModify Uses

type FindAndModify struct {
    // contains filtered or unexported fields
}

FindAndModify performs a findAndModify operation.

func NewFindAndModify Uses

func NewFindAndModify(query bsoncore.Document) *FindAndModify

NewFindAndModify constructs and returns a new FindAndModify.

func (*FindAndModify) ArrayFilters Uses

func (fam *FindAndModify) ArrayFilters(arrayFilters bsoncore.Document) *FindAndModify

ArrayFilters specifies an array of filter documents that determines which array elements to modify for an update operation on an array field.

func (*FindAndModify) BypassDocumentValidation Uses

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

BypassDocumentValidation specifies if document validation can be skipped when executing the operation.

func (*FindAndModify) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*FindAndModify) Collation Uses

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

Collation specifies a collation to be used.

func (*FindAndModify) Collection Uses

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

Collection sets the collection that this command will run against.

func (*FindAndModify) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*FindAndModify) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*FindAndModify) Database Uses

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

Database sets the database to run this operation against.

func (*FindAndModify) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*FindAndModify) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*FindAndModify) Fields Uses

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

Fields specifies a subset of fields to return.

func (*FindAndModify) MaxTimeMS Uses

func (fam *FindAndModify) MaxTimeMS(maxTimeMS int64) *FindAndModify

MaxTimeMS specifies the maximum amount of time to allow the operation to run.

func (*FindAndModify) NewDocument Uses

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

NewDocument specifies whether to return the modified document or the original. Defaults to false (return original).

func (*FindAndModify) Query Uses

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

Query specifies the selection criteria for the modification.

func (*FindAndModify) Remove Uses

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

Remove specifies that the matched document should be removed. Defaults to false.

func (*FindAndModify) Result Uses

func (fam *FindAndModify) Result() FindAndModifyResult

Result returns the result of executing this operation.

func (*FindAndModify) Retry Uses

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

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 (*FindAndModify) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*FindAndModify) Session Uses

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

Session sets the session for this operation.

func (*FindAndModify) Sort Uses

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

Sort determines which document the operation modifies if the query matches multiple documents.The first document matched by the sort order will be modified.

func (*FindAndModify) Update Uses

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

Update specifies the update document to perform on the matched document.

func (*FindAndModify) Upsert Uses

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

Upsert specifies whether or not to create a new document if no documents match the query when doing an update. Defaults to false.

func (*FindAndModify) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type FindAndModifyResult Uses

type FindAndModifyResult struct {
    // Either the old or modified document, depending on the value of the new parameter.
    Value bsoncore.Document
    // Contains information about updates and upserts.
    LastErrorObject LastErrorObject
}

type Insert Uses

type Insert struct {
    // contains filtered or unexported fields
}

Insert performs an insert operation.

func NewInsert Uses

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

NewInsert constructs and returns a new Insert.

func (*Insert) BypassDocumentValidation Uses

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

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 (*Insert) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*Insert) Collection Uses

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

Collection sets the collection that this command will run against.

func (*Insert) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*Insert) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*Insert) Database Uses

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

Database sets the database to run this operation against.

func (*Insert) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*Insert) Documents Uses

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

Documents adds documents to this operation that will be inserted when this operation is executed.

func (*Insert) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*Insert) Ordered Uses

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

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 (*Insert) Result Uses

func (i *Insert) Result() InsertResult

Result returns the result of executing this operation.

func (*Insert) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*Insert) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*Insert) Session Uses

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

Session sets the session for this operation.

func (*Insert) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type InsertResult Uses

type InsertResult struct {
    // Number of documents successfully inserted.
    N int32
}

type IsMaster Uses

type IsMaster struct {
    // contains filtered or unexported fields
}

IsMaster is used to run the isMaster handshake operation.

func NewIsMaster Uses

func NewIsMaster() *IsMaster

NewIsMaster constructs an IsMaster.

func (*IsMaster) AppName Uses

func (im *IsMaster) AppName(appname string) *IsMaster

AppName sets the application name in the client metadata sent in this operation.

func (*IsMaster) ClusterClock Uses

func (im *IsMaster) ClusterClock(clock *session.ClusterClock) *IsMaster

ClusterClock sets the cluster clock for this operation.

func (*IsMaster) Compressors Uses

func (im *IsMaster) Compressors(compressors []string) *IsMaster

Compressors sets the compressors that can be used.

func (*IsMaster) Deployment Uses

func (im *IsMaster) Deployment(d driver.Deployment) *IsMaster

Deployment sets the Deployment for this operation.

func (*IsMaster) Execute Uses

func (im *IsMaster) Execute(ctx context.Context) error

Execute runs this operation.

func (*IsMaster) FinishHandshake Uses

func (im *IsMaster) FinishHandshake(context.Context, driver.Connection) error

FinishHandshake implements the Handshaker interface. This is a no-op function because a non-authenticated connection does not do anything besides the initial isMaster for a handshake.

func (*IsMaster) GetDescription Uses

func (im *IsMaster) GetDescription(ctx context.Context, _ address.Address, c driver.Connection) (description.Server, error)

GetDescription retrieves the server description for the given connection. This function implements the Handshaker interface.

func (*IsMaster) Result Uses

func (im *IsMaster) Result(addr address.Address) description.Server

Result returns the result of executing this operation.

func (*IsMaster) SASLSupportedMechs Uses

func (im *IsMaster) SASLSupportedMechs(username string) *IsMaster

SASLSupportedMechs retrieves the supported SASL mechanism for the given user when this operation is run.

type LastErrorObject Uses

type LastErrorObject struct {
    // True if an update modified an existing document
    UpdatedExisting bool
    // Object ID of the upserted document.
    Upserted interface{}
}

type ListCollections Uses

type ListCollections struct {
    // contains filtered or unexported fields
}

ListCollections performs a listCollections operation.

func NewListCollections Uses

func NewListCollections(filter bsoncore.Document) *ListCollections

NewListCollections constructs and returns a new ListCollections.

func (*ListCollections) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*ListCollections) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*ListCollections) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*ListCollections) Database Uses

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

Database sets the database to run this operation against.

func (*ListCollections) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*ListCollections) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*ListCollections) Filter Uses

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

Filter determines what results are returned from listCollections.

func (*ListCollections) NameOnly Uses

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

NameOnly specifies whether to only return collection names.

func (*ListCollections) ReadPreference Uses

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

ReadPreference set the read prefernce used with this operation.

func (*ListCollections) Result Uses

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

Result returns the result of executing this operation.

func (*ListCollections) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*ListCollections) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*ListCollections) Session Uses

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

Session sets the session for this operation.

type ListDatabases Uses

type ListDatabases struct {
    // contains filtered or unexported fields
}

ListDatabases performs a listDatabases operation.

func NewListDatabases Uses

func NewListDatabases(filter bsoncore.Document) *ListDatabases

NewListDatabases constructs and returns a new ListDatabases.

func (*ListDatabases) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*ListDatabases) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*ListDatabases) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*ListDatabases) Database Uses

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

Database sets the database to run this operation against.

func (*ListDatabases) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*ListDatabases) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*ListDatabases) Filter Uses

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

Filter determines what results are returned from listDatabases.

func (*ListDatabases) NameOnly Uses

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

NameOnly specifies whether to only return database names.

func (*ListDatabases) ReadPreference Uses

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

ReadPreference set the read prefernce used with this operation.

func (*ListDatabases) Result Uses

func (ld *ListDatabases) Result() ListDatabasesResult

Result returns the result of executing this operation.

func (*ListDatabases) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*ListDatabases) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*ListDatabases) Session Uses

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

Session sets the session for this operation.

type ListDatabasesResult Uses

type ListDatabasesResult struct {
    // An array of documents, one document for each database
    Databases []databaseRecord
    // The sum of the size of all the database files on disk in bytes.
    TotalSize int64
}

type ListIndexes Uses

type ListIndexes struct {
    // contains filtered or unexported fields
}

ListIndexes performs a listIndexes operation.

func NewListIndexes Uses

func NewListIndexes() *ListIndexes

NewListIndexes constructs and returns a new ListIndexes.

func (*ListIndexes) BatchSize Uses

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

BatchSize specifies the number of documents to return in every batch.

func (*ListIndexes) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*ListIndexes) Collection Uses

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

Collection sets the collection that this command will run against.

func (*ListIndexes) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*ListIndexes) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*ListIndexes) Database Uses

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

Database sets the database to run this operation against.

func (*ListIndexes) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*ListIndexes) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*ListIndexes) MaxTimeMS Uses

func (li *ListIndexes) MaxTimeMS(maxTimeMS int64) *ListIndexes

MaxTimeMS specifies the maximum amount of time to allow the query to run.

func (*ListIndexes) Result Uses

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

Result returns the result of executing this operation.

func (*ListIndexes) Retry Uses

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

Retry enables retryable mode for this operation. Retries are handled automatically in driver.Operation.Execute based on how the operation is set.

func (*ListIndexes) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*ListIndexes) Session Uses

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

Session sets the session for this operation.

type Update Uses

type Update struct {
    // contains filtered or unexported fields
}

Update performs an update operation.

func NewUpdate Uses

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

NewUpdate constructs and returns a new Update.

func (*Update) BypassDocumentValidation Uses

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

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 (*Update) ClusterClock Uses

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

ClusterClock sets the cluster clock for this operation.

func (*Update) Collection Uses

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

Collection sets the collection that this command will run against.

func (*Update) CommandMonitor Uses

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

CommandMonitor sets the monitor to use for APM events.

func (*Update) Crypt Uses

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

Crypt sets the Crypt object to use for automatic encryption and decryption.

func (*Update) Database Uses

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

Database sets the database to run this operation against.

func (*Update) Deployment Uses

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

Deployment sets the deployment to use for this operation.

func (*Update) Execute Uses

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

Execute runs this operations and returns an error if the operaiton did not execute successfully.

func (*Update) Ordered Uses

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

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 (*Update) Result Uses

func (u *Update) Result() UpdateResult

Result returns the result of executing this operation.

func (*Update) Retry Uses

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

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 (*Update) ServerSelector Uses

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

ServerSelector sets the selector used to retrieve a server.

func (*Update) Session Uses

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

Session sets the session for this operation.

func (*Update) Updates Uses

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

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 (*Update) WriteConcern Uses

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

WriteConcern sets the write concern for this operation.

type UpdateResult Uses

type UpdateResult struct {
    // Number of documents matched.
    N   int32
    // Number of documents modified.
    NModified int32
    // Information about upserted documents.
    Upserted []Upsert
}

UpdateResult contains information for the result of an Update operation.

type Upsert Uses

type Upsert struct {
    Index int64
    ID    interface{} `bson:"_id"`
}

Upsert contains the information for an upsert in an Update operation.

Package operation imports 19 packages (graph) and is imported by 5 packages. Updated 2019-10-03. Refresh now. Tools for package owners.