mongo

package

Go to main page

Versions in this module

v2

v2.5.0

Jan 28, 2026

Changes in this version

+ func ErrorCodes(err error) []int

type Session

+ func (s *Session) SnapshotTime() bson.Timestamp

v2.4.2

Jan 21, 2026

v2.4.1

Dec 9, 2025

v2.4.0

Oct 28, 2025

Changes in this version

type Client

+ func (c *Client) AppendDriverInfo(info options.DriverInfo)

v2.3.1

Oct 9, 2025

v2.3.0

Aug 13, 2025

Changes in this version

type MarshalError

+ func (me MarshalError) Unwrap() error

type MongocryptError

+ func (m MongocryptError) Unwrap() error

v2.2.3

Aug 5, 2025

v2.2.2

Jun 5, 2025

Changes in this version

type GridFSFile

+ func (f *GridFSFile) UnmarshalBSON(data []byte) error

v2.2.1

May 6, 2025

v2.2.0

Apr 9, 2025

Changes in this version

+ type InvalidArgumentError struct

+ func (e InvalidArgumentError) Error() string

+ func (e InvalidArgumentError) Unwrap() error

v2.1.0

Feb 26, 2025

Changes in this version

type BulkWriteException

+ func (bwe BulkWriteException) ErrorCodes() []int

type Client

+ func (c *Client) BulkWrite(ctx context.Context, writes []ClientBulkWrite, ...) (*ClientBulkWriteResult, error)

+ type ClientBulkWrite struct

+ Collection string

+ Database string

+ Model ClientWriteModel

+ type ClientBulkWriteDeleteResult struct

+ DeletedCount int64

+ type ClientBulkWriteException struct

+ PartialResult *ClientBulkWriteResult

+ WriteConcernErrors []WriteConcernError

+ WriteError *WriteError

+ WriteErrors map[int]WriteError

+ func (bwe ClientBulkWriteException) Error() string

+ type ClientBulkWriteInsertResult struct

+ InsertedID interface{}

+ type ClientBulkWriteResult struct

+ Acknowledged bool

+ DeleteResults map[int]ClientBulkWriteDeleteResult

+ DeletedCount int64

+ HasVerboseResults bool

+ InsertResults map[int]ClientBulkWriteInsertResult

+ InsertedCount int64

+ MatchedCount int64

+ ModifiedCount int64

+ UpdateResults map[int]ClientBulkWriteUpdateResult

+ UpsertedCount int64

+ type ClientBulkWriteUpdateResult struct

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedID interface{}

+ type ClientDeleteManyModel struct

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ func NewClientDeleteManyModel() *ClientDeleteManyModel

+ func (dmm *ClientDeleteManyModel) SetCollation(collation *options.Collation) *ClientDeleteManyModel

+ func (dmm *ClientDeleteManyModel) SetFilter(filter interface{}) *ClientDeleteManyModel

+ func (dmm *ClientDeleteManyModel) SetHint(hint interface{}) *ClientDeleteManyModel

+ type ClientDeleteOneModel struct

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ func NewClientDeleteOneModel() *ClientDeleteOneModel

+ func (dom *ClientDeleteOneModel) SetCollation(collation *options.Collation) *ClientDeleteOneModel

+ func (dom *ClientDeleteOneModel) SetFilter(filter interface{}) *ClientDeleteOneModel

+ func (dom *ClientDeleteOneModel) SetHint(hint interface{}) *ClientDeleteOneModel

+ type ClientInsertOneModel struct

+ Document interface{}

+ func NewClientInsertOneModel() *ClientInsertOneModel

+ func (iom *ClientInsertOneModel) SetDocument(doc interface{}) *ClientInsertOneModel

+ type ClientReplaceOneModel struct

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ Replacement interface{}

+ Sort interface{}

+ Upsert *bool

+ func NewClientReplaceOneModel() *ClientReplaceOneModel

+ func (rom *ClientReplaceOneModel) SetCollation(collation *options.Collation) *ClientReplaceOneModel

+ func (rom *ClientReplaceOneModel) SetFilter(filter interface{}) *ClientReplaceOneModel

+ func (rom *ClientReplaceOneModel) SetHint(hint interface{}) *ClientReplaceOneModel

+ func (rom *ClientReplaceOneModel) SetReplacement(rep interface{}) *ClientReplaceOneModel

+ func (rom *ClientReplaceOneModel) SetSort(sort interface{}) *ClientReplaceOneModel

+ func (rom *ClientReplaceOneModel) SetUpsert(upsert bool) *ClientReplaceOneModel

+ type ClientUpdateManyModel struct

+ ArrayFilters []interface{}

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ Update interface{}

+ Upsert *bool

+ func NewClientUpdateManyModel() *ClientUpdateManyModel

+ func (umm *ClientUpdateManyModel) SetArrayFilters(filters []interface{}) *ClientUpdateManyModel

+ func (umm *ClientUpdateManyModel) SetCollation(collation *options.Collation) *ClientUpdateManyModel

+ func (umm *ClientUpdateManyModel) SetFilter(filter interface{}) *ClientUpdateManyModel

+ func (umm *ClientUpdateManyModel) SetHint(hint interface{}) *ClientUpdateManyModel

+ func (umm *ClientUpdateManyModel) SetUpdate(update interface{}) *ClientUpdateManyModel

+ func (umm *ClientUpdateManyModel) SetUpsert(upsert bool) *ClientUpdateManyModel

+ type ClientUpdateOneModel struct

+ ArrayFilters []interface{}

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ Sort interface{}

+ Update interface{}

+ Upsert *bool

+ func NewClientUpdateOneModel() *ClientUpdateOneModel

+ func (uom *ClientUpdateOneModel) SetArrayFilters(filters []interface{}) *ClientUpdateOneModel

+ func (uom *ClientUpdateOneModel) SetCollation(collation *options.Collation) *ClientUpdateOneModel

+ func (uom *ClientUpdateOneModel) SetFilter(filter interface{}) *ClientUpdateOneModel

+ func (uom *ClientUpdateOneModel) SetHint(hint interface{}) *ClientUpdateOneModel

+ func (uom *ClientUpdateOneModel) SetSort(sort interface{}) *ClientUpdateOneModel

+ func (uom *ClientUpdateOneModel) SetUpdate(update interface{}) *ClientUpdateOneModel

+ func (uom *ClientUpdateOneModel) SetUpsert(upsert bool) *ClientUpdateOneModel

+ type ClientWriteModel interface

type CommandError

+ func (e CommandError) ErrorCodes() []int

type ReplaceOneModel

+ Sort interface{}

+ func (rom *ReplaceOneModel) SetSort(sort interface{}) *ReplaceOneModel

type ServerError

+ ErrorCodes func() []int

type UpdateOneModel

+ Sort interface{}

+ func (uom *UpdateOneModel) SetSort(sort interface{}) *UpdateOneModel

type WriteError

+ func (we WriteError) ErrorCodes() []int

type WriteException

+ func (mwe WriteException) ErrorCodes() []int

v2.0.1

Feb 20, 2025

v2.0.0

Dec 10, 2024

Changes in this version

+ const DefaultGridFSChunkSize

+ var ErrClientDisconnected = errors.New("client is disconnected")

+ var ErrEmptySlice = errors.New("must provide at least one element in input slice")

+ var ErrFileNotFound = errors.New("file with given parameters not found")

+ var ErrInvalidIndexValue = errors.New("invalid index value")

+ var ErrMissingChunk = errors.New("EOF missing one or more chunks")

+ var ErrMissingGridFSChunkSize = errors.New("files collection document does not contain a 'chunkSize' field")

+ var ErrMissingResumeToken = errors.New("cannot provide resume functionality when the resume token is missing")

+ var ErrMultipleIndexDrop = errors.New("multiple indexes would be dropped")

+ var ErrNilCursor = errors.New("cursor is nil")

+ var ErrNilDocument = errors.New("document is nil")

+ var ErrNilValue = errors.New("value is nil")

+ var ErrNoDocuments = errors.New("mongo: no documents in result")

+ var ErrNonStringIndexName = errors.New("index name must be a string")

+ var ErrNotSlice = errors.New("must provide a non-empty slice")

+ var ErrStreamClosed = errors.New("stream is closed or aborted")

+ var ErrWrongClient = errors.New("session was not created by this client")

+ var ErrWrongSize = errors.New("chunk size does not match expected size")

+ func BatchCursorFromCursor(c *Cursor) *driver.BatchCursor

+ func IsDuplicateKeyError(err error) bool

+ func IsNetworkError(err error) bool

+ func IsTimeout(err error) bool

+ func NewSessionContext(parent context.Context, sess *Session) context.Context

+ func WithSession(ctx context.Context, sess *Session, fn func(context.Context) error) error

+ type BulkWriteError struct

+ Request WriteModel

+ func (bwe BulkWriteError) Error() string

+ type BulkWriteException struct

+ Labels []string

+ WriteConcernError *WriteConcernError

+ WriteErrors []BulkWriteError

+ func (bwe BulkWriteException) Error() string

+ func (bwe BulkWriteException) HasErrorCode(code int) bool

+ func (bwe BulkWriteException) HasErrorCodeWithMessage(code int, message string) bool

+ func (bwe BulkWriteException) HasErrorLabel(label string) bool

+ func (bwe BulkWriteException) HasErrorMessage(message string) bool

+ type BulkWriteResult struct

+ Acknowledged bool

+ DeletedCount int64

+ InsertedCount int64

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedCount int64

+ UpsertedIDs map[int64]interface{}

+ type ChangeStream struct

+ Current bson.Raw

+ func (cs *ChangeStream) Close(ctx context.Context) error

+ func (cs *ChangeStream) Decode(val interface{}) error

+ func (cs *ChangeStream) Err() error

+ func (cs *ChangeStream) ID() int64

+ func (cs *ChangeStream) Next(ctx context.Context) bool

+ func (cs *ChangeStream) RemainingBatchLength() int

+ func (cs *ChangeStream) ResumeToken() bson.Raw

+ func (cs *ChangeStream) SetBatchSize(size int32)

+ func (cs *ChangeStream) TryNext(ctx context.Context) bool

+ type Client struct

+ func Connect(opts ...*options.ClientOptions) (*Client, error)

+ func (c *Client) Database(name string, opts ...options.Lister[options.DatabaseOptions]) *Database

+ func (c *Client) Disconnect(ctx context.Context) error

+ func (c *Client) ListDatabaseNames(ctx context.Context, filter interface{}, ...) ([]string, error)

+ func (c *Client) ListDatabases(ctx context.Context, filter interface{}, ...) (ListDatabasesResult, error)

+ func (c *Client) NumberSessionsInProgress() int

+ func (c *Client) Ping(ctx context.Context, rp *readpref.ReadPref) error

+ func (c *Client) StartSession(opts ...options.Lister[options.SessionOptions]) (*Session, error)

+ func (c *Client) UseSession(ctx context.Context, fn func(context.Context) error) error

+ func (c *Client) UseSessionWithOptions(ctx context.Context, opts *options.SessionOptionsBuilder, ...) error

+ func (c *Client) Watch(ctx context.Context, pipeline interface{}, ...) (*ChangeStream, error)

+ type ClientEncryption struct

+ func NewClientEncryption(keyVaultClient *Client, ...) (*ClientEncryption, error)

+ func (ce *ClientEncryption) AddKeyAltName(ctx context.Context, id bson.Binary, keyAltName string) *SingleResult

+ func (ce *ClientEncryption) Close(ctx context.Context) error

+ func (ce *ClientEncryption) CreateDataKey(ctx context.Context, kmsProvider string, ...) (bson.Binary, error)

+ func (ce *ClientEncryption) CreateEncryptedCollection(ctx context.Context, db *Database, coll string, ...) (*Collection, bson.M, error)

+ func (ce *ClientEncryption) Decrypt(ctx context.Context, val bson.Binary) (bson.RawValue, error)

+ func (ce *ClientEncryption) DeleteKey(ctx context.Context, id bson.Binary) (*DeleteResult, error)

+ func (ce *ClientEncryption) Encrypt(ctx context.Context, val bson.RawValue, ...) (bson.Binary, error)

+ func (ce *ClientEncryption) EncryptExpression(ctx context.Context, expr interface{}, result interface{}, ...) error

+ func (ce *ClientEncryption) GetKey(ctx context.Context, id bson.Binary) *SingleResult

+ func (ce *ClientEncryption) GetKeyByAltName(ctx context.Context, keyAltName string) *SingleResult

+ func (ce *ClientEncryption) GetKeys(ctx context.Context) (*Cursor, error)

+ func (ce *ClientEncryption) RemoveKeyAltName(ctx context.Context, id bson.Binary, keyAltName string) *SingleResult

+ func (ce *ClientEncryption) RewrapManyDataKey(ctx context.Context, filter interface{}, ...) (*RewrapManyDataKeyResult, error)

+ type Collection struct

+ func (coll *Collection) Aggregate(ctx context.Context, pipeline interface{}, ...) (*Cursor, error)

+ func (coll *Collection) BulkWrite(ctx context.Context, models []WriteModel, ...) (*BulkWriteResult, error)

+ func (coll *Collection) Clone(opts ...options.Lister[options.CollectionOptions]) *Collection

+ func (coll *Collection) CountDocuments(ctx context.Context, filter interface{}, ...) (int64, error)

+ func (coll *Collection) Database() *Database

+ func (coll *Collection) DeleteMany(ctx context.Context, filter interface{}, ...) (*DeleteResult, error)

+ func (coll *Collection) DeleteOne(ctx context.Context, filter interface{}, ...) (*DeleteResult, error)

+ func (coll *Collection) Distinct(ctx context.Context, fieldName string, filter interface{}, ...) *DistinctResult

+ func (coll *Collection) Drop(ctx context.Context, opts ...options.Lister[options.DropCollectionOptions]) error

+ func (coll *Collection) EstimatedDocumentCount(ctx context.Context, ...) (int64, error)

+ func (coll *Collection) Find(ctx context.Context, filter interface{}, ...) (*Cursor, error)

+ func (coll *Collection) FindOne(ctx context.Context, filter interface{}, ...) *SingleResult

+ func (coll *Collection) FindOneAndDelete(ctx context.Context, filter interface{}, ...) *SingleResult

+ func (coll *Collection) FindOneAndReplace(ctx context.Context, filter interface{}, replacement interface{}, ...) *SingleResult

+ func (coll *Collection) FindOneAndUpdate(ctx context.Context, filter interface{}, update interface{}, ...) *SingleResult

+ func (coll *Collection) Indexes() IndexView

+ func (coll *Collection) InsertMany(ctx context.Context, documents interface{}, ...) (*InsertManyResult, error)

+ func (coll *Collection) InsertOne(ctx context.Context, document interface{}, ...) (*InsertOneResult, error)

+ func (coll *Collection) Name() string

+ func (coll *Collection) ReplaceOne(ctx context.Context, filter interface{}, replacement interface{}, ...) (*UpdateResult, error)

+ func (coll *Collection) SearchIndexes() SearchIndexView

+ func (coll *Collection) UpdateByID(ctx context.Context, id interface{}, update interface{}, ...) (*UpdateResult, error)

+ func (coll *Collection) UpdateMany(ctx context.Context, filter interface{}, update interface{}, ...) (*UpdateResult, error)

+ func (coll *Collection) UpdateOne(ctx context.Context, filter interface{}, update interface{}, ...) (*UpdateResult, error)

+ func (coll *Collection) Watch(ctx context.Context, pipeline interface{}, ...) (*ChangeStream, error)

+ type CollectionSpecification struct

+ IDIndex IndexSpecification

+ Name string

+ Options bson.Raw

+ ReadOnly bool

+ Type string

+ UUID *bson.Binary

+ type CommandError struct

+ Code int32

+ Labels []string

+ Message string

+ Name string

+ Raw bson.Raw

+ Wrapped error

+ func (e CommandError) Error() string

+ func (e CommandError) HasErrorCode(code int) bool

+ func (e CommandError) HasErrorCodeWithMessage(code int, message string) bool

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

+ func (e CommandError) HasErrorMessage(message string) bool

+ func (e CommandError) IsMaxTimeMSExpiredError() bool

+ func (e CommandError) Unwrap() error

+ type Cursor struct

+ Current bson.Raw

+ func NewCursorFromDocuments(documents []interface{}, preloadedErr error, registry *bson.Registry) (*Cursor, error)

+ func (c *Cursor) All(ctx context.Context, results interface{}) error

+ func (c *Cursor) Close(ctx context.Context) error

+ func (c *Cursor) Decode(val interface{}) error

+ func (c *Cursor) Err() error

+ func (c *Cursor) ID() int64

+ func (c *Cursor) Next(ctx context.Context) bool

+ func (c *Cursor) RemainingBatchLength() int

+ func (c *Cursor) SetBatchSize(batchSize int32)

+ func (c *Cursor) SetComment(comment interface{})

+ func (c *Cursor) SetMaxAwaitTime(dur time.Duration)

+ func (c *Cursor) TryNext(ctx context.Context) bool

+ type Database struct

+ func (db *Database) Aggregate(ctx context.Context, pipeline interface{}, ...) (*Cursor, error)

+ func (db *Database) Client() *Client

+ func (db *Database) Collection(name string, opts ...options.Lister[options.CollectionOptions]) *Collection

+ func (db *Database) CreateCollection(ctx context.Context, name string, ...) error

+ func (db *Database) CreateView(ctx context.Context, viewName, viewOn string, pipeline interface{}, ...) error

+ func (db *Database) Drop(ctx context.Context) error

+ func (db *Database) GridFSBucket(opts ...options.Lister[options.BucketOptions]) *GridFSBucket

+ func (db *Database) ListCollectionNames(ctx context.Context, filter interface{}, ...) ([]string, error)

+ func (db *Database) ListCollectionSpecifications(ctx context.Context, filter interface{}, ...) ([]CollectionSpecification, error)

+ func (db *Database) ListCollections(ctx context.Context, filter interface{}, ...) (*Cursor, error)

+ func (db *Database) Name() string

+ func (db *Database) RunCommand(ctx context.Context, runCommand interface{}, ...) *SingleResult

+ func (db *Database) RunCommandCursor(ctx context.Context, runCommand interface{}, ...) (*Cursor, error)

+ func (db *Database) Watch(ctx context.Context, pipeline interface{}, ...) (*ChangeStream, error)

+ type DatabaseSpecification struct

+ Empty bool

+ Name string

+ SizeOnDisk int64

+ type DeleteManyModel struct

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ func NewDeleteManyModel() *DeleteManyModel

+ func (dmm *DeleteManyModel) SetCollation(collation *options.Collation) *DeleteManyModel

+ func (dmm *DeleteManyModel) SetFilter(filter interface{}) *DeleteManyModel

+ func (dmm *DeleteManyModel) SetHint(hint interface{}) *DeleteManyModel

+ type DeleteOneModel struct

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ func NewDeleteOneModel() *DeleteOneModel

+ func (dom *DeleteOneModel) SetCollation(collation *options.Collation) *DeleteOneModel

+ func (dom *DeleteOneModel) SetFilter(filter interface{}) *DeleteOneModel

+ func (dom *DeleteOneModel) SetHint(hint interface{}) *DeleteOneModel

+ type DeleteResult struct

+ Acknowledged bool

+ DeletedCount int64

+ type Dialer interface

+ DialContext func(ctx context.Context, network, address string) (net.Conn, error)

+ type DistinctResult struct

+ func (dr *DistinctResult) Decode(v any) error

+ func (dr *DistinctResult) Err() error

+ func (dr *DistinctResult) Raw() (bson.RawArray, error)

+ type EncryptionKeyVaultError struct

+ Wrapped error

+ func (ekve EncryptionKeyVaultError) Error() string

+ func (ekve EncryptionKeyVaultError) Unwrap() error

+ type ErrMapForOrderedArgument struct

+ ParamName string

+ func (e ErrMapForOrderedArgument) Error() string

+ type GridFSBucket struct

+ func (b *GridFSBucket) Delete(ctx context.Context, fileID interface{}) error

+ func (b *GridFSBucket) DownloadToStream(ctx context.Context, fileID interface{}, stream io.Writer) (int64, error)

+ func (b *GridFSBucket) DownloadToStreamByName(ctx context.Context, filename string, stream io.Writer, ...) (int64, error)

+ func (b *GridFSBucket) Drop(ctx context.Context) error

+ func (b *GridFSBucket) Find(ctx context.Context, filter interface{}, ...) (*Cursor, error)

+ func (b *GridFSBucket) GetChunksCollection() *Collection

+ func (b *GridFSBucket) GetFilesCollection() *Collection

+ func (b *GridFSBucket) OpenDownloadStream(ctx context.Context, fileID interface{}) (*GridFSDownloadStream, error)

+ func (b *GridFSBucket) OpenDownloadStreamByName(ctx context.Context, filename string, ...) (*GridFSDownloadStream, error)

+ func (b *GridFSBucket) OpenUploadStream(ctx context.Context, filename string, ...) (*GridFSUploadStream, error)

+ func (b *GridFSBucket) OpenUploadStreamWithID(ctx context.Context, fileID interface{}, filename string, ...) (*GridFSUploadStream, error)

+ func (b *GridFSBucket) Rename(ctx context.Context, fileID interface{}, newFilename string) error

+ func (b *GridFSBucket) UploadFromStream(ctx context.Context, filename string, source io.Reader, ...) (bson.ObjectID, error)

+ func (b *GridFSBucket) UploadFromStreamWithID(ctx context.Context, fileID interface{}, filename string, source io.Reader, ...) error

+ type GridFSDownloadStream struct

+ func (ds *GridFSDownloadStream) Close() error

+ func (ds *GridFSDownloadStream) GetFile() *GridFSFile

+ func (ds *GridFSDownloadStream) Read(p []byte) (int, error)

+ func (ds *GridFSDownloadStream) Skip(skip int64) (int64, error)

+ type GridFSFile struct

+ ChunkSize int32

+ ID interface{}

+ Length int64

+ Metadata bson.Raw

+ Name string

+ UploadDate time.Time

+ type GridFSUploadStream struct

+ FileID interface{}

+ func (us *GridFSUploadStream) Abort() error

+ func (us *GridFSUploadStream) Close() error

+ func (us *GridFSUploadStream) Write(p []byte) (int, error)

+ type IndexModel struct

+ Keys interface{}

+ Options *options.IndexOptionsBuilder

+ type IndexSpecification struct

+ Clustered *bool

+ ExpireAfterSeconds *int32

+ KeysDocument bson.Raw

+ Name string

+ Namespace string

+ Sparse *bool

+ Unique *bool

+ Version int32

+ type IndexView struct

+ func (iv IndexView) CreateMany(ctx context.Context, models []IndexModel, ...) ([]string, error)

+ func (iv IndexView) CreateOne(ctx context.Context, model IndexModel, ...) (string, error)

+ func (iv IndexView) DropAll(ctx context.Context, opts ...options.Lister[options.DropIndexesOptions]) error

+ func (iv IndexView) DropOne(ctx context.Context, name string, ...) error

+ func (iv IndexView) DropWithKey(ctx context.Context, keySpecDocument interface{}, ...) error

+ func (iv IndexView) List(ctx context.Context, opts ...options.Lister[options.ListIndexesOptions]) (*Cursor, error)

+ func (iv IndexView) ListSpecifications(ctx context.Context, opts ...options.Lister[options.ListIndexesOptions]) ([]IndexSpecification, error)

+ type InsertManyResult struct

+ Acknowledged bool

+ InsertedIDs []interface{}

+ type InsertOneModel struct

+ Document interface{}

+ func NewInsertOneModel() *InsertOneModel

+ func (iom *InsertOneModel) SetDocument(doc interface{}) *InsertOneModel

+ type InsertOneResult struct

+ Acknowledged bool

+ InsertedID interface{}

+ type LabeledError interface

+ HasErrorLabel func(string) bool

+ type ListDatabasesResult struct

+ Databases []DatabaseSpecification

+ TotalSize int64

+ type MarshalError struct

+ Err error

+ Value interface{}

+ func (me MarshalError) Error() string

+ type MongocryptError struct

+ Code int32

+ Message string

+ func (m MongocryptError) Error() string

+ type MongocryptdError struct

+ Wrapped error

+ func (e MongocryptdError) Error() string

+ func (e MongocryptdError) Unwrap() error

+ type Pipeline []bson.D

+ type ReplaceOneModel struct

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ Replacement interface{}

+ Upsert *bool

+ func NewReplaceOneModel() *ReplaceOneModel

+ func (rom *ReplaceOneModel) SetCollation(collation *options.Collation) *ReplaceOneModel

+ func (rom *ReplaceOneModel) SetFilter(filter interface{}) *ReplaceOneModel

+ func (rom *ReplaceOneModel) SetHint(hint interface{}) *ReplaceOneModel

+ func (rom *ReplaceOneModel) SetReplacement(rep interface{}) *ReplaceOneModel

+ func (rom *ReplaceOneModel) SetUpsert(upsert bool) *ReplaceOneModel

+ type RewrapManyDataKeyResult struct

+ type SearchIndexModel struct

+ Definition interface{}

+ Options *options.SearchIndexesOptionsBuilder

+ type SearchIndexView struct

+ func (siv SearchIndexView) CreateMany(ctx context.Context, models []SearchIndexModel, ...) ([]string, error)

+ func (siv SearchIndexView) CreateOne(ctx context.Context, model SearchIndexModel, ...) (string, error)

+ func (siv SearchIndexView) DropOne(ctx context.Context, name string, ...) error

+ func (siv SearchIndexView) List(ctx context.Context, ...) (*Cursor, error)

+ func (siv SearchIndexView) UpdateOne(ctx context.Context, name string, definition interface{}, ...) error

+ type ServerError interface

+ HasErrorCode func(int) bool

+ HasErrorCodeWithMessage func(int, string) bool

+ HasErrorMessage func(string) bool

+ type Session struct

+ func SessionFromContext(ctx context.Context) *Session

+ func (s *Session) AbortTransaction(ctx context.Context) error

+ func (s *Session) AdvanceClusterTime(d bson.Raw) error

+ func (s *Session) AdvanceOperationTime(ts *bson.Timestamp) error

+ func (s *Session) Client() *Client

+ func (s *Session) ClientSession() *session.Client

+ func (s *Session) ClusterTime() bson.Raw

+ func (s *Session) CommitTransaction(ctx context.Context) error

+ func (s *Session) EndSession(ctx context.Context)

+ func (s *Session) ID() bson.Raw

+ func (s *Session) OperationTime() *bson.Timestamp

+ func (s *Session) StartTransaction(opts ...options.Lister[options.TransactionOptions]) error

+ func (s *Session) WithTransaction(ctx context.Context, fn func(ctx context.Context) (interface{}, error), ...) (interface{}, error)

+ type SingleResult struct

+ Acknowledged bool

+ func NewSingleResultFromDocument(document interface{}, err error, registry *bson.Registry) *SingleResult

+ func (sr *SingleResult) Decode(v interface{}) error

+ func (sr *SingleResult) Err() error

+ func (sr *SingleResult) Raw() (bson.Raw, error)

+ type StreamType uint8

+ const ClientStream

+ const CollectionStream

+ const DatabaseStream

+ type UpdateManyModel struct

+ ArrayFilters []interface{}

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ Update interface{}

+ Upsert *bool

+ func NewUpdateManyModel() *UpdateManyModel

+ func (umm *UpdateManyModel) SetArrayFilters(filters []interface{}) *UpdateManyModel

+ func (umm *UpdateManyModel) SetCollation(collation *options.Collation) *UpdateManyModel

+ func (umm *UpdateManyModel) SetFilter(filter interface{}) *UpdateManyModel

+ func (umm *UpdateManyModel) SetHint(hint interface{}) *UpdateManyModel

+ func (umm *UpdateManyModel) SetUpdate(update interface{}) *UpdateManyModel

+ func (umm *UpdateManyModel) SetUpsert(upsert bool) *UpdateManyModel

+ type UpdateOneModel struct

+ ArrayFilters []interface{}

+ Collation *options.Collation

+ Filter interface{}

+ Hint interface{}

+ Update interface{}

+ Upsert *bool

+ func NewUpdateOneModel() *UpdateOneModel

+ func (uom *UpdateOneModel) SetArrayFilters(filters []interface{}) *UpdateOneModel

+ func (uom *UpdateOneModel) SetCollation(collation *options.Collation) *UpdateOneModel

+ func (uom *UpdateOneModel) SetFilter(filter interface{}) *UpdateOneModel

+ func (uom *UpdateOneModel) SetHint(hint interface{}) *UpdateOneModel

+ func (uom *UpdateOneModel) SetUpdate(update interface{}) *UpdateOneModel

+ func (uom *UpdateOneModel) SetUpsert(upsert bool) *UpdateOneModel

+ type UpdateResult struct

+ Acknowledged bool

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedCount int64

+ UpsertedID interface{}

+ type WriteConcernError struct

+ Code int

+ Details bson.Raw

+ Message string

+ Name string

+ Raw bson.Raw

+ func (wce WriteConcernError) Error() string

+ func (wce WriteConcernError) IsMaxTimeMSExpiredError() bool

+ type WriteError struct

+ Code int

+ Details bson.Raw

+ Index int

+ Message string

+ Raw bson.Raw

+ func (we WriteError) Error() string

+ func (we WriteError) HasErrorCode(code int) bool

+ func (we WriteError) HasErrorCodeWithMessage(code int, message string) bool

+ func (we WriteError) HasErrorLabel(string) bool

+ func (we WriteError) HasErrorMessage(message string) bool

+ type WriteErrors []WriteError

+ func (we WriteErrors) Error() string

+ type WriteException struct

+ Labels []string

+ Raw bson.Raw

+ WriteConcernError *WriteConcernError

+ WriteErrors WriteErrors

+ func (mwe WriteException) Error() string

+ func (mwe WriteException) HasErrorCode(code int) bool

+ func (mwe WriteException) HasErrorCodeWithMessage(code int, message string) bool

+ func (mwe WriteException) HasErrorLabel(label string) bool

+ func (mwe WriteException) HasErrorMessage(message string) bool

+ type WriteModel interface

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL