driver

Sep 17, 2024

Changes in this version

+ type AuthConfig struct

+ ClusterClock *session.ClusterClock

+ Connection Connection

+ Description description.Server

+ HandshakeInfo HandshakeInformation

+ ServerAPI *ServerAPIOptions

+ type Authenticator interface

+ Auth func(context.Context, *AuthConfig) error

+ Reauth func(context.Context, *AuthConfig) error

type Connection

+ OIDCTokenGenID func() uint64

+ SetOIDCTokenGenID func(uint64)

+ type Cred struct

+ OIDCHumanCallback OIDCCallback

+ OIDCMachineCallback OIDCCallback

+ Password string

+ PasswordSet bool

+ Props map[string]string

+ Source string

+ Username string

+ type IDPInfo struct

+ ClientID string

+ Issuer string

+ RequestScopes []string

+ type OIDCArgs struct

+ IDPInfo *IDPInfo

+ RefreshToken *string

+ Version int

+ type OIDCCallback func(context.Context, *OIDCArgs) (*OIDCCredential, error)

+ type OIDCCredential struct

+ AccessToken string

+ ExpiresAt *time.Time

+ RefreshToken *string

type Operation

+ Authenticator Authenticator

Apr 12, 2024

Changes in this version

type Operation

+ OmitCSOTMaxTimeMS bool

Nov 7, 2023

retracted

Changes in this version

+ var ErrNoCursor = errors.New("database response does not contain a cursor")

type BatchCursor

+ func (bc *BatchCursor) SetComment(comment interface{})

+ func (bc *BatchCursor) SetMaxTime(dur time.Duration)

type CursorOptions

+ MarshalValueEncoderFn func(io.Writer) (*bson.Encoder, error)

type LegacyOperationKind

+ const LegacyHandshake

type Operation

+ Name string

Nov 8, 2023

Changes in this version

+ const LegacyNotPrimaryErrMsg

Jun 21, 2023

Changes in this version

type Crypt

+ EncryptExplicitExpression func(ctx context.Context, val bsoncore.Document, ...) (bsoncore.Document, error)

type Operation

+ Logger *logger.Logger

Jun 6, 2023

Changes in this version

type Connection

+ DriverConnectionID func() uint64

type ListCollectionsBatchCursor

+ func (lcbc *ListCollectionsBatchCursor) SetBatchSize(size int32)

Nov 2, 2022

retracted

Changes in this version

+ var ErrNegativeMaxTime = errors.New("a negative value was provided for MaxTime on an operation")

+ var NoWritesPerformed = "NoWritesPerformed"

type CryptOptions

+ HTTPClient *http.Client

+ type LabeledError interface

+ HasErrorLabel func(string) bool

type Operation

+ MaxTime *time.Duration

+ type RTTMonitor interface

+ EWMA func() time.Duration

+ Min func() time.Duration

+ P90 func() time.Duration

+ Stats func() string

type Server

+ RTTMonitor func() RTTMonitor

type SingleConnectionDeployment

+ func (ssd SingleConnectionDeployment) RTTMonitor() RTTMonitor

type WriteCommandError

+ func (wce WriteCommandError) HasErrorLabel(label string) bool

Jul 14, 2022

retracted

Changes in this version

+ var ErrDeadlineWouldBeExceeded = errors.New("operation not sent to server, as Timeout would be exceeded")

type Crypt

+ RewrapDataKey func(ctx context.Context, filter []byte, opts *options.RewrapManyDataKeyOptions) ([]bsoncore.Document, error)

type CryptOptions

+ BypassQueryAnalysis bool

+ MongoCrypt *mongocrypt.MongoCrypt

type CursorOptions

+ Comment bsoncore.Value

type Operation

+ Timeout *time.Duration

type Server

+ RTT90 func() time.Duration

type SingleConnectionDeployment

+ func (ssd SingleConnectionDeployment) RTT90() time.Duration

Apr 5, 2022

Changes in this version

type BatchCursor

+ func NewBatchCursorFromDocuments(documents []byte) *BatchCursor

type Error

+ Raw bsoncore.Document

+ type RetryablePoolError interface

+ Retryable func() bool

type WriteCommandError

+ Raw bsoncore.Document

type WriteConcernError

+ Raw bsoncore.Document

type WriteError

+ Raw bsoncore.Document

Nov 23, 2021

Changes in this version

type Connection

+ ServerConnectionID func() *int32

type CryptOptions

+ TLSConfig map[string]*tls.Config

type Error

+ func (e Error) NotPrimary() bool

type HandshakeInformation

+ ServerConnectionID *int32

type Operation

+ IsOutputAggregate bool

type Server

+ MinRTT func() time.Duration

type SingleConnectionDeployment

+ func (ssd SingleConnectionDeployment) MinRTT() time.Duration

type WriteConcernError

+ func (wce WriteConcernError) NotPrimary() bool

Jul 20, 2021

retracted

Changes in this version

type WriteError

+ Details bsoncore.Document

Jul 12, 2021

retracted

Changes in this version

+ const TestServerAPIVersion

+ func ExtractErrorFromServerResponse(doc bsoncore.Document) error

type BatchCursor

+ func (bc *BatchCursor) SetBatchSize(size int32)

type CursorOptions

+ ServerAPI *ServerAPIOptions

type CursorResponse

+ Connection PinnedConnection

+ ErrorProcessor ErrorProcessor

type Operation

+ ServerAPI *ServerAPIOptions

+ type PinnedConnection interface

+ PinToCursor func() error

+ PinToTransaction func() error

+ UnpinFromCursor func() error

+ UnpinFromTransaction func() error

+ type ResponseInfo struct

+ Connection Connection

+ ConnectionDescription description.Server

+ CurrentIndex int

+ Server Server

+ ServerResponse bsoncore.Document

+ type ServerAPIOptions struct

+ DeprecationErrors *bool

+ ServerAPIVersion string

+ Strict *bool

+ func NewServerAPIOptions(serverAPIVersion string) *ServerAPIOptions

+ func (s *ServerAPIOptions) SetDeprecationErrors(deprecationErrors bool) *ServerAPIOptions

+ func (s *ServerAPIOptions) SetStrict(strict bool) *ServerAPIOptions

Mar 9, 2021 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ type HandshakeInformation struct

+ Description description.Server

+ SaslSupportedMechs []string

+ SpeculativeAuthenticate bsoncore.Document

type Handshaker

+ GetHandshakeInformation func(context.Context, address.Address, Connection) (HandshakeInformation, error)

+ type ProcessErrorResult int

+ const ConnectionPoolCleared

+ const NoChange

+ const ServerMarkedUnknown

+ func (p ProcessErrorResult) ServerChanged() bool

Dec 16, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Mar 9, 2021 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Feb 2, 2021 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jan 19, 2021 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Dec 1, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Nov 3, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Oct 7, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Sep 1, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jul 30, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ var RetryableWriteError = "RetryableWriteError"

type Connection

+ Stale func() bool

type Error

+ TopologyVersion *description.TopologyVersion

+ func (e Error) RetryableRead() bool

+ func (e Error) RetryableWrite(wireVersion *description.VersionRange) bool

+ func (e Error) Unwrap() error

type Operation

+ func (op Operation) ExecuteExhaust(ctx context.Context, conn StreamerConnection, scratch []byte) error

type QueryFailureError

+ Wrapped error

+ func (e QueryFailureError) Unwrap() error

+ type StreamerConnection interface

+ CurrentlyStreaming func() bool

+ SetStreaming func(bool)

+ SupportsStreaming func() bool

type WriteCommandError

+ Labels []string

type WriteConcernError

+ Labels []string

+ TopologyVersion *description.TopologyVersion

Jul 13, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jun 9, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Apr 10, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Aug 10, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Aug 4, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jul 8, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jun 3, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

May 5, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Apr 7, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Mar 3, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Feb 5, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ func CompressPayload(in []byte, opts CompressionOpts) ([]byte, error)

Jan 8, 2020 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

type Error

+ Wrapped error

Dec 10, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ func CompressPlayoad(in []byte, opts CompressionOpts) ([]byte, error)

+ func DecompressPayload(in []byte, opts CompressionOpts) ([]byte, error)

+ type CollectionInfoFn func(ctx context.Context, db string, filter bsoncore.Document) (bsoncore.Document, error)

+ type CompressionOpts struct

+ Compressor wiremessage.CompressorID

+ UncompressedSize int32

+ ZlibLevel int

+ ZstdLevel int

+ type Connector interface

+ Connect func() error

+ type Crypt struct

+ BypassAutoEncryption bool

+ func NewCrypt(opts *CryptOptions) (*Crypt, error)

+ func (c *Crypt) Close()

+ func (c *Crypt) CreateDataKey(ctx context.Context, kmsProvider string, opts *options.DataKeyOptions) (bsoncore.Document, error)

+ func (c *Crypt) Decrypt(ctx context.Context, cmdResponse bsoncore.Document) (bsoncore.Document, error)

+ func (c *Crypt) DecryptExplicit(ctx context.Context, subtype byte, data []byte) (bsoncore.Value, error)

+ func (c *Crypt) Encrypt(ctx context.Context, db string, cmd bsoncore.Document) (bsoncore.Document, error)

+ func (c *Crypt) EncryptExplicit(ctx context.Context, val bsoncore.Value, ...) (byte, []byte, error)

+ type CryptOptions struct

+ BypassAutoEncryption bool

+ CollInfoFn CollectionInfoFn

+ KeyFn KeyRetrieverFn

+ KmsProviders map[string]map[string]interface{}

+ MarkFn MarkCommandFn

+ SchemaMap map[string]bsoncore.Document

type CursorOptions

+ Crypt *Crypt

+ type Disconnector interface

+ Disconnect func(context.Context) error

+ type KeyRetrieverFn func(ctx context.Context, filter bsoncore.Document) ([]bsoncore.Document, error)

+ type MarkCommandFn func(ctx context.Context, db string, cmd bsoncore.Document) (bsoncore.Document, error)

type Operation

+ Crypt *Crypt

+ type Subscriber interface

+ Subscribe func() (*Subscription, error)

+ Unsubscribe func(*Subscription) error

+ type Subscription struct

+ ID uint64

+ Updates <-chan description.Topology

Dec 17, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Nov 5, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Oct 7, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

type Handshaker

+ FinishHandshake func(context.Context, Connection) error

+ GetDescription func(context.Context, address.Address, Connection) (description.Server, error)

Sep 5, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Aug 13, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ var ErrCursorNotFound = errors.New("cursor not found")

+ var ErrDocumentTooLarge = errors.New("an inserted document is too large")

+ var ErrMultiDocCommandResponse = errors.New("command returned multiple documents")

+ var ErrNoDocCommandResponse = errors.New("command returned no documents")

+ var ErrNonPrimaryReadPref = errors.New("read preference in a transaction must be primary")

+ var ErrReplyDocumentMismatch = errors.New("number of documents returned does not match numberReturned field")

+ var ErrUnacknowledgedWrite = errors.New("unacknowledged write")

+ var ErrUnsupportedStorageEngine = errors.New(...)

+ var NetworkError = "NetworkError"

+ var TransientTransactionError = "TransientTransactionError"

+ var UnknownTransactionCommitResult = "UnknownTransactionCommitResult"

type BatchCursor

+ func (bc *BatchCursor) KillCursor(ctx context.Context) error

+ func (bc *BatchCursor) PostBatchResumeToken() bsoncore.Document

+ type Batches struct

+ Current []bsoncore.Document

+ Documents []bsoncore.Document

+ Identifier string

+ Ordered *bool

+ func (b *Batches) AdvanceBatch(maxCount, targetBatchSize int) error

+ func (b *Batches) ClearBatch()

+ func (b *Batches) Valid() bool

+ type Compressor interface

+ CompressWireMessage func(src, dst []byte) ([]byte, error)

+ type Connection interface

+ Address func() address.Address

+ Close func() error

+ Description func() description.Server

+ ID func() string

+ ReadWireMessage func(ctx context.Context, dst []byte) ([]byte, error)

+ WriteWireMessage func(context.Context, []byte) error

+ type CursorOptions struct

+ BatchSize int32

+ CommandMonitor *event.CommandMonitor

+ Limit int32

+ MaxTimeMS int64

+ type CursorResponse struct

+ Collection string

+ Database string

+ Desc description.Server

+ FirstBatch *bsoncore.DocumentSequence

+ ID int64

+ Server Server

+ func NewCursorResponse(response bsoncore.Document, server Server, desc description.Server) (CursorResponse, error)

+ type Deployment interface

+ Kind func() description.TopologyKind

+ SelectServer func(context.Context, description.ServerSelector) (Server, error)

+ SupportsRetryWrites func() bool

+ type Error struct

+ Code int32

+ Labels []string

+ Message string

+ Name string

+ func (e Error) Error() string

+ func (e Error) HasErrorLabel(label string) bool

+ func (e Error) NamespaceNotFound() bool

+ func (e Error) NetworkError() bool

+ func (e Error) NodeIsRecovering() bool

+ func (e Error) NodeIsShuttingDown() bool

+ func (e Error) NotMaster() bool

+ func (e Error) Retryable() bool

+ func (e Error) UnsupportedStorageEngine() bool

+ type ErrorProcessor interface

+ ProcessError func(error)

+ type Expirable interface

+ Alive func() bool

+ Expire func() error

+ type Handshaker interface

+ Handshake func(context.Context, address.Address, Connection) (description.Server, error)

+ type HandshakerFunc func(context.Context, address.Address, Connection) (description.Server, error)

+ func (hf HandshakerFunc) Handshake(ctx context.Context, addr address.Address, conn Connection) (description.Server, error)

+ type InvalidOperationError struct

+ MissingField string

+ func (err InvalidOperationError) Error() string

+ type LegacyOperationKind uint

+ const LegacyFind

+ const LegacyGetMore

+ const LegacyKillCursors

+ const LegacyListCollections

+ const LegacyListIndexes

+ const LegacyNone

+ type LocalAddresser interface

+ LocalAddress func() address.Address

+ type Operation struct

+ Batches *Batches

+ Client *session.Client

+ Clock *session.ClusterClock

+ CommandFn func(dst []byte, desc description.SelectedServer) ([]byte, error)

+ CommandMonitor *event.CommandMonitor

+ Database string

+ Deployment Deployment

+ Legacy LegacyOperationKind

+ MinimumReadConcernWireVersion int32

+ MinimumWriteConcernWireVersion int32

+ ProcessResponseFn func(response bsoncore.Document, srvr Server, desc description.Server) error

+ ReadConcern *readconcern.ReadConcern

+ ReadPreference *readpref.ReadPref

+ RetryMode *RetryMode

+ Selector description.ServerSelector

+ Type Type

+ WriteConcern *writeconcern.WriteConcern

+ func (op Operation) Execute(ctx context.Context, scratch []byte) error

+ func (op Operation) Validate() error

+ type QueryFailureError struct

+ Message string

+ Response bsoncore.Document

+ func (e QueryFailureError) Error() string

+ type ResponseError struct

+ Message string

+ Wrapped error

+ func NewCommandResponseError(msg string, err error) ResponseError

+ func (e ResponseError) Error() string

+ type RetryMode uint

+ const RetryContext

+ const RetryNone

+ const RetryOnce

+ const RetryOncePerCommand

+ func (rm RetryMode) Enabled() bool

+ type Server interface

+ Connection func(context.Context) (Connection, error)

+ type SingleConnectionDeployment struct

+ C Connection

+ func (ssd SingleConnectionDeployment) Connection(context.Context) (Connection, error)

+ func (ssd SingleConnectionDeployment) Kind() description.TopologyKind

+ func (ssd SingleConnectionDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error)

+ func (ssd SingleConnectionDeployment) SupportsRetryWrites() bool

+ type SingleServerDeployment struct

+ func (SingleServerDeployment) Kind() description.TopologyKind

+ func (SingleServerDeployment) SupportsRetryWrites() bool

+ func (ssd SingleServerDeployment) SelectServer(context.Context, description.ServerSelector) (Server, error)

+ type Type uint

+ type WriteCommandError struct

+ WriteConcernError *WriteConcernError

+ WriteErrors WriteErrors

+ func (wce WriteCommandError) Error() string

+ func (wce WriteCommandError) Retryable() bool

+ func (wce WriteCommandError) UnsupportedStorageEngine() bool

+ type WriteConcernError struct

+ Code int64

+ Details bsoncore.Document

+ Message string

+ Name string

+ func (wce WriteConcernError) Error() string

+ func (wce WriteConcernError) NodeIsRecovering() bool

+ func (wce WriteConcernError) NodeIsShuttingDown() bool

+ func (wce WriteConcernError) NotMaster() bool

+ func (wce WriteConcernError) Retryable() bool

+ type WriteError struct

+ Code int64

+ Index int64

+ Message string

+ func (we WriteError) Error() string

+ type WriteErrors []WriteError

+ func (we WriteErrors) Error() string

Jul 9, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Jun 6, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

May 16, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Apr 18, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Mar 13, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

type BatchCursor

+ func (bc *BatchCursor) Server() *topology.Server

type ListCollectionsBatchCursor

+ func (lcbc *ListCollectionsBatchCursor) Server() *topology.Server

Mar 7, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Feb 22, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Feb 1, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ type BatchCursor struct

+ func NewBatchCursor(result bsoncore.Document, clientSession *session.Client, ...) (*BatchCursor, error)

+ func NewEmptyBatchCursor() *BatchCursor

+ func NewLegacyBatchCursor(ns command.Namespace, cursorID int64, batch []bson.Raw, limit int32, ...) (*BatchCursor, error)

+ func (bc *BatchCursor) Batch(dst []byte) []byte

+ func (bc *BatchCursor) Close(ctx context.Context) error

+ func (bc *BatchCursor) Err() error

+ func (bc *BatchCursor) ID() int64

+ func (bc *BatchCursor) Next(ctx context.Context) bool

+ func (bc *BatchCursor) RequiredBytes() int

+ type ListCollectionsBatchCursor struct

+ func NewLegacyListCollectionsBatchCursor(bc *BatchCursor) (*ListCollectionsBatchCursor, error)

+ func NewListCollectionsBatchCursor(bc *BatchCursor) (*ListCollectionsBatchCursor, error)

+ func (lcbc *ListCollectionsBatchCursor) Batch(dst []byte) []byte

+ func (lcbc *ListCollectionsBatchCursor) Close(ctx context.Context) error

+ func (lcbc *ListCollectionsBatchCursor) Err() error

+ func (lcbc *ListCollectionsBatchCursor) ID() int64

+ func (lcbc *ListCollectionsBatchCursor) Next(ctx context.Context) bool

+ func (lcbc *ListCollectionsBatchCursor) RequiredBytes() int

Jan 8, 2019 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ var ErrFilterType = errors.New("filter must be a string")

Dec 6, 2018 GO-2021-0112

  GO-2021-0112: Improper input validation in go.mongodb.org/mongo-driver

Changes in this version

+ var ErrArrayFilters = errors.New("array filters cannot be set for server versions < 3.6")

+ var ErrCollation = errors.New("collation cannot be set for server versions < 3.4")

+ func AbortTransaction(ctx context.Context, cmd command.AbortTransaction, topo *topology.Topology, ...) (result.TransactionResult, error)

+ func Aggregate(ctx context.Context, cmd command.Aggregate, topo *topology.Topology, ...) (command.Cursor, error)

+ func BulkWrite(ctx context.Context, ns command.Namespace, models []WriteModel, ...) (result.BulkWrite, error)

+ func CommitTransaction(ctx context.Context, cmd command.CommitTransaction, topo *topology.Topology, ...) (result.TransactionResult, error)

+ func Count(ctx context.Context, cmd command.Count, topo *topology.Topology, ...) (int64, error)

+ func CountDocuments(ctx context.Context, cmd command.CountDocuments, topo *topology.Topology, ...) (int64, error)

+ func CreateIndexes(ctx context.Context, cmd command.CreateIndexes, topo *topology.Topology, ...) (result.CreateIndexes, error)

+ func Delete(ctx context.Context, cmd command.Delete, topo *topology.Topology, ...) (result.Delete, error)

+ func Distinct(ctx context.Context, cmd command.Distinct, topo *topology.Topology, ...) (result.Distinct, error)

+ func DropCollection(ctx context.Context, cmd command.DropCollection, topo *topology.Topology, ...) (bson.Raw, error)

+ func DropDatabase(ctx context.Context, cmd command.DropDatabase, topo *topology.Topology, ...) (bson.Raw, error)

+ func DropIndexes(ctx context.Context, cmd command.DropIndexes, topo *topology.Topology, ...) (bson.Raw, error)

+ func EndSessions(ctx context.Context, cmd command.EndSessions, topo *topology.Topology, ...) ([]result.EndSessions, []error)

+ func Find(ctx context.Context, cmd command.Find, topo *topology.Topology, ...) (command.Cursor, error)

+ func FindOneAndDelete(ctx context.Context, cmd command.FindOneAndDelete, topo *topology.Topology, ...) (result.FindAndModify, error)

+ func FindOneAndReplace(ctx context.Context, cmd command.FindOneAndReplace, topo *topology.Topology, ...) (result.FindAndModify, error)

+ func FindOneAndUpdate(ctx context.Context, cmd command.FindOneAndUpdate, topo *topology.Topology, ...) (result.FindAndModify, error)

+ func Insert(ctx context.Context, cmd command.Insert, topo *topology.Topology, ...) (result.Insert, error)

+ func KillCursors(ctx context.Context, cmd command.KillCursors, topo *topology.Topology, ...) (result.KillCursors, error)

+ func ListCollections(ctx context.Context, cmd command.ListCollections, topo *topology.Topology, ...) (command.Cursor, error)

+ func ListDatabases(ctx context.Context, cmd command.ListDatabases, topo *topology.Topology, ...) (result.ListDatabases, error)

+ func ListIndexes(ctx context.Context, cmd command.ListIndexes, topo *topology.Topology, ...) (command.Cursor, error)

+ func Read(ctx context.Context, cmd command.Read, topo *topology.Topology, ...) (bson.Raw, error)

+ func ReadCursor(ctx context.Context, cmd command.Read, topo *topology.Topology, ...) (command.Cursor, error)

+ func Update(ctx context.Context, cmd command.Update, topo *topology.Topology, ...) (result.Update, error)

+ func Write(ctx context.Context, cmd command.Write, topo *topology.Topology, ...) (bson.Raw, error)

+ type BulkWriteError struct

+ Model WriteModel

+ type BulkWriteException struct

+ WriteConcernError *result.WriteConcernError

+ WriteErrors []BulkWriteError

+ func (BulkWriteException) Error() string

+ type DeleteManyModel struct

+ Collation *options.Collation

+ Filter interface{}

+ type DeleteOneModel struct

+ Collation *options.Collation

+ Filter interface{}

+ type InsertOneModel struct

+ Document interface{}

+ type ReplaceOneModel struct

+ Filter interface{}

+ Replacement interface{}

+ type UpdateManyModel struct

+ ArrayFilters options.ArrayFilters

+ ArrayFiltersSet bool

+ Filter interface{}

+ Update interface{}

+ type UpdateModel struct

+ Collation *options.Collation

+ Upsert bool

+ UpsertSet bool

+ type UpdateOneModel struct

+ ArrayFilters options.ArrayFilters

+ ArrayFiltersSet bool

+ Filter interface{}

+ Update interface{}

+ type WriteModel interface