mongo

Dec 10, 2019

Changes in this version

type ChangeStream

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

type Client

+ func (c *Client) NumberSessionsInProgress() int

+ type ClientEncryption struct

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

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

+ func (ce *ClientEncryption) CreateDataKey(ctx context.Context, kmsProvider string, opts ...*options.DataKeyOptions) (primitive.Binary, error)

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

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

type Cursor

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

+ type EncryptionKeyVaultError struct

+ Wrapped error

+ func (ekve EncryptionKeyVaultError) Error() string

+ type MongocryptError struct

+ Code int32

+ Message string

+ func (m MongocryptError) Error() string

+ type MongocryptdError struct

+ Wrapped error

+ func (e MongocryptdError) Error() string

+ type XSession interface

+ ClientSession func() *session.Client

+ ID func() bsonx.Doc

Aug 13, 2019

Changes in this version

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

type ChangeStream

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

type CommandError

+ func (e CommandError) IsMaxTimeMSExpiredError() bool

type Cursor

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

type Database

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

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

type Session

+ Client func() *Client

+ WithTransaction func(ctx context.Context, fn func(sessCtx SessionContext) (interface{}, error), ...) (interface{}, error)

type WriteConcernError

+ Name string

Mar 13, 2019

Changes in this version

+ type CommandError struct

+ Code int32

+ Labels []string

+ Message string

+ Name string

+ func (e CommandError) Error() string

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

Feb 1, 2019

Changes in this version

+ type ChangeStream struct

+ Current bson.Raw

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

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

+ func (cs *ChangeStream) Err() error

+ func (cs *ChangeStream) ID() int64

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

type Cursor

+ Current bson.Raw

type DeleteManyModel

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

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

type DeleteOneModel

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

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

type InsertOneModel

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

type ReplaceOneModel

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

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

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

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

type UpdateManyModel

+ func (umm *UpdateManyModel) SetArrayFilters(filters options.ArrayFilters) *UpdateManyModel

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

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

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

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

type UpdateOneModel

+ func (uom *UpdateOneModel) SetArrayFilters(filters options.ArrayFilters) *UpdateOneModel

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

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

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

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

+ type WriteException struct

+ WriteConcernError *WriteConcernError

+ WriteErrors WriteErrors

+ func (mwe WriteException) Error() string

Jan 8, 2019

Changes in this version

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

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

type UpdateResult

+ UpsertedCount int64

Dec 6, 2018

Changes in this version

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

type Client

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

type Database

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

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

+ type SingleResult struct

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

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

+ func (sr *SingleResult) Err() error

+ type StreamType uint8

+ const ClientStream

+ const CollectionStream

+ const DatabaseStream

Nov 15, 2018

Changes in this version

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

+ type Pipeline []bson.D

Oct 11, 2018

Changes in this version

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

type BulkWriteError

+ Request WriteModel

+ type BulkWriteException struct

+ WriteConcernError *WriteConcernError

+ WriteErrors []BulkWriteError

+ func (bwe BulkWriteException) Error() string

+ type BulkWriteResult struct

+ DeletedCount int64

+ InsertedCount int64

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedCount int64

+ UpsertedIDs map[int64]interface{}

type Client

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

+ func (c *Client) UseSessionWithOptions(ctx context.Context, opts []sessionopt.Session, fn func(SessionContext) error) error

type Collection

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

+ type DeleteManyModel struct

+ func NewDeleteManyModel() *DeleteManyModel

+ func (dmm *DeleteManyModel) Collation(collation *mongoopt.Collation) *DeleteManyModel

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

+ type DeleteOneModel struct

+ func NewDeleteOneModel() *DeleteOneModel

+ func (dom *DeleteOneModel) Collation(collation *mongoopt.Collation) *DeleteOneModel

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

+ type InsertOneModel struct

+ func NewInsertOneModel() *InsertOneModel

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

+ type ReplaceOneModel struct

+ func NewReplaceOneModel() *ReplaceOneModel

+ func (rom *ReplaceOneModel) Collation(collation *mongoopt.Collation) *ReplaceOneModel

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

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

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

type Session

+ AdvanceClusterTime func(*bson.Document) error

+ AdvanceOperationTime func(*bson.Timestamp) error

+ ClusterTime func() *bson.Document

+ OperationTime func() *bson.Timestamp

+ type SessionContext interface

+ type UpdateManyModel struct

+ func NewUpdateManyModel() *UpdateManyModel

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

+ func (umm *UpdateManyModel) Collation(collation *mongoopt.Collation) *UpdateManyModel

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

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

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

+ type UpdateOneModel struct

+ func NewUpdateOneModel() *UpdateOneModel

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

+ func (uom *UpdateOneModel) Collation(collation *mongoopt.Collation) *UpdateOneModel

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

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

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

+ type WriteModel interface

Sep 27, 2018

Changes in this version

+ type BSONAppender interface

+ AppendBSON func([]byte, interface{}) ([]byte, error)

+ type BSONAppenderFunc func([]byte, interface{}) ([]byte, error)

+ func (baf BSONAppenderFunc) AppendBSON(dst []byte, val interface{}) ([]byte, error)

type Collection

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

+ type MarshalError struct

+ Err error

+ Value interface{}

+ func (me MarshalError) Error() string

Sep 20, 2018

Changes in this version

type Client

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

Sep 6, 2018

Changes in this version

type Database

+ func (db *Database) ReadConcern() *readconcern.ReadConcern

+ func (db *Database) ReadPreference() *readpref.ReadPref

+ func (db *Database) WriteConcern() *writeconcern.WriteConcern

Aug 16, 2018

Changes in this version

type Session

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

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

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

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

+ func (s *Session) StartTransaction(opts ...transactionopt.Transaction) error

Aug 8, 2018

Changes in this version

type Collection

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

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

Jul 26, 2018

Changes in this version

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

type Client

+ func (c *Client) StartSession() (*Session, error)

+ func (c *Client) ValidSession(sess *session.Client) error

+ type Session struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Jul 10, 2018

Changes in this version

type Collection

+ func (coll *Collection) Clone(opts ...collectionopt.Option) (*Collection, error)

Jun 12, 2018

Changes in this version

+ type IndexOptionsBuilder struct

+ func NewIndexOptionsBuilder() *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Background(background bool) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Bits(bits int32) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) BucketSize(bucketSize int32) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Build() *bson.Document

+ func (iob *IndexOptionsBuilder) Collation(collation *bson.Document) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) DefaultLanguage(defaultLanguage string) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) ExpireAfterSeconds(expireAfterSeconds int32) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) LanguageOverride(languageOverride string) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Max(max float64) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Min(min float64) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Name(name string) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) PartialFilterExpression(partialFilterExpression *bson.Document) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Sparse(sparse bool) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) SphereVersion(sphereVersion int32) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) StorageEngine(storageEngine *bson.Document) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) TextVersion(textVersion int32) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Unique(unique bool) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Version(version int32) *IndexOptionsBuilder

+ func (iob *IndexOptionsBuilder) Weights(weights *bson.Document) *IndexOptionsBuilder

May 31, 2018

Changes in this version

type Database

+ func (db *Database) ListCollections(ctx context.Context, filter *bson.Document, ...) (command.Cursor, error)

May 17, 2018

Changes in this version

type ClientOptions

+ func (co *ClientOptions) MaxStaleness(d time.Duration) *ClientOptions

May 2, 2018

Changes in this version

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

+ type BulkWriteError struct

+ WriteConcernError *WriteConcernError

+ WriteErrors WriteErrors

+ func (bwe BulkWriteError) Error() string

type Collection

+ func (coll *Collection) Drop(ctx context.Context) error

+ func (coll *Collection) Name() string

type Database

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

+ type WriteConcernError struct

+ Code int

+ Details bson.Reader

+ Message string

+ func (wce WriteConcernError) Error() string

+ type WriteError struct

+ Code int

+ Index int

+ Message string

+ func (we WriteError) Error() string

+ type WriteErrors []WriteError

+ func (we WriteErrors) Error() string

Apr 18, 2018

Changes in this version

+ var ClientOpt = &ClientOptions

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

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

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

type Client

+ func Connect(ctx context.Context, uri string, opts *ClientOptions) (*Client, error)

+ func NewClientWithOptions(uri string, opts *ClientOptions) (*Client, error)

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

+ 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)

+ type ClientOptions struct

+ func (co *ClientOptions) AppName(s string) *ClientOptions

+ func (co *ClientOptions) AuthMechanism(s string) *ClientOptions

+ func (co *ClientOptions) AuthMechanismProperties(m map[string]string) *ClientOptions

+ func (co *ClientOptions) AuthSource(s string) *ClientOptions

+ func (co *ClientOptions) ConnectTimeout(d time.Duration) *ClientOptions

+ func (co *ClientOptions) Dialer(d Dialer) *ClientOptions

+ func (co *ClientOptions) HeartbeatInterval(d time.Duration) *ClientOptions

+ func (co *ClientOptions) Hosts(s []string) *ClientOptions

+ func (co *ClientOptions) Journal(b bool) *ClientOptions

+ func (co *ClientOptions) LocalThreshold(d time.Duration) *ClientOptions

+ func (co *ClientOptions) MaxConnIdleTime(d time.Duration) *ClientOptions

+ func (co *ClientOptions) MaxConnsPerHost(u uint16) *ClientOptions

+ func (co *ClientOptions) MaxIdleConnsPerHost(u uint16) *ClientOptions

+ func (co *ClientOptions) Password(s string) *ClientOptions

+ func (co *ClientOptions) ReadConcernLevel(s string) *ClientOptions

+ func (co *ClientOptions) ReadPreference(s string) *ClientOptions

+ func (co *ClientOptions) ReadPreferenceTagSets(m []map[string]string) *ClientOptions

+ func (co *ClientOptions) ReplicaSet(s string) *ClientOptions

+ func (co *ClientOptions) SSL(b bool) *ClientOptions

+ func (co *ClientOptions) SSLCaFile(s string) *ClientOptions

+ func (co *ClientOptions) SSLClientCertificateKeyFile(s string) *ClientOptions

+ func (co *ClientOptions) SSLClientCertificateKeyPassword(s func() string) *ClientOptions

+ func (co *ClientOptions) SSLInsecure(b bool) *ClientOptions

+ func (co *ClientOptions) ServerSelectionTimeout(d time.Duration) *ClientOptions

+ func (co *ClientOptions) Single(b bool) *ClientOptions

+ func (co *ClientOptions) SocketTimeout(d time.Duration) *ClientOptions

+ func (co *ClientOptions) Username(s string) *ClientOptions

+ func (co *ClientOptions) WNumber(i int) *ClientOptions

+ func (co *ClientOptions) WString(s string) *ClientOptions

+ func (co *ClientOptions) WTimeout(d time.Duration) *ClientOptions

type Collection

+ func (coll *Collection) Indexes() IndexView

+ type DatabaseSpecification struct

+ Empty bool

+ Name string

+ SizeOnDisk int64

+ type Dialer interface

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

+ type IndexModel struct

+ Keys *bson.Document

+ Options *bson.Document

+ 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) (bson.Reader, error)

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

+ func (iv IndexView) List(ctx context.Context) (Cursor, error)

+ type ListDatabasesResult struct

+ Databases []DatabaseSpecification

+ TotalSize int64

Mar 6, 2018

Changes in this version

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

type Collection

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

type Cursor

+ Close func(context.Context) error

+ Decode func(interface{}) error

+ DecodeBytes func() (bson.Reader, error)

+ Err func() error

+ ID func() int64

+ Next func(context.Context) bool

+ type Options struct

+ var Opt Options

+ func (Options) AllowDiskUse(b bool) options.OptAllowDiskUse

+ func (Options) AllowPartialResults(b bool) options.OptAllowPartialResults

+ func (Options) ArrayFilters(filters ...interface{}) (options.OptArrayFilters, error)

+ func (Options) BatchSize(i int32) options.OptBatchSize

+ func (Options) BypassDocumentValidation(b bool) options.OptBypassDocumentValidation

+ func (Options) Collation(collation *options.Collation) options.OptCollation

+ func (Options) Comment(s string) options.OptComment

+ func (Options) CursorType(cursorType options.CursorType) options.OptCursorType

+ func (Options) FullDocument(fullDocument string) options.OptFullDocument

+ func (Options) Hint(hint interface{}) (options.OptHint, error)

+ func (Options) Limit(i int64) options.OptLimit

+ func (Options) Max(max interface{}) (options.OptMax, error)

+ func (Options) MaxAwaitTime(duration time.Duration) options.OptMaxAwaitTime

+ func (Options) MaxScan(i int64) options.OptMaxScan

+ func (Options) MaxTime(duration time.Duration) options.OptMaxTime

+ func (Options) Min(min interface{}) (options.OptMin, error)

+ func (Options) NoCursorTimeout(b bool) options.OptNoCursorTimeout

+ func (Options) OplogReplay(b bool) options.OptOplogReplay

+ func (Options) Ordered(b bool) options.OptOrdered

+ func (Options) Projection(projection interface{}) (options.OptProjection, error)

+ func (Options) ReadConcern(readConcern *readconcern.ReadConcern) (options.OptReadConcern, error)

+ func (Options) ResumeAfter(token *bson.Document) options.OptResumeAfter

+ func (Options) ReturnDocument(returnDocument options.ReturnDocument) options.OptReturnDocument

+ func (Options) ReturnKey(b bool) options.OptReturnKey

+ func (Options) ShowRecordID(b bool) options.OptShowRecordID

+ func (Options) Skip(i int64) options.OptSkip

+ func (Options) Snapshot(b bool) options.OptSnapshot

+ func (Options) Sort(sort interface{}) (options.OptSort, error)

+ func (Options) Upsert(b bool) options.OptUpsert

+ func (Options) WriteConcern(writeConcern *writeconcern.WriteConcern) (options.OptWriteConcern, error)

Feb 13, 2018

Changes in this version

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

+ func AllowDiskUse(b bool) options.OptAllowDiskUse

+ func AllowPartialResults(b bool) options.OptAllowPartialResults

+ func ArrayFilters(filters ...interface{}) (options.OptArrayFilters, error)

+ func BatchSize(i int32) options.OptBatchSize

+ func BypassDocumentValidation(b bool) options.OptBypassDocumentValidation

+ func Collation(collation *options.CollationOptions) options.OptCollation

+ func Comment(s string) options.OptComment

+ func CursorType(cursorType options.CursorType) options.OptCursorType

+ func Hint(hint interface{}) (options.OptHint, error)

+ func Limit(i int64) options.OptLimit

+ func Max(max interface{}) (options.OptMax, error)

+ func MaxAwaitTime(duration time.Duration) options.OptMaxAwaitTime

+ func MaxScan(i int64) options.OptMaxScan

+ func MaxTime(duration time.Duration) options.OptMaxTime

+ func Min(min interface{}) (options.OptMin, error)

+ func NoCursorTimeout(b bool) options.OptNoCursorTimeout

+ func OplogReplay(b bool) options.OptOplogReplay

+ func Ordered(b bool) options.OptOrdered

+ func Projection(projection interface{}) (options.OptProjection, error)

+ func ReturnDocument(returnDocument options.ReturnDocument) options.OptReturnDocument

+ func ReturnKey(b bool) options.OptReturnKey

+ func ShowRecordID(b bool) options.OptShowRecordID

+ func Skip(i int64) options.OptSkip

+ func Snapshot(b bool) options.OptSnapshot

+ func Sort(sort interface{}) (options.OptSort, error)

+ func TransformDocument(document interface{}) (*bson.Document, error)

+ func Upsert(b bool) options.OptUpsert

+ type Client struct

+ func NewClient(uri string) (*Client, error)

+ func NewClientFromConnString(cs connstring.ConnString) (*Client, error)

+ func (client *Client) ConnectionString() string

+ func (client *Client) Database(name string) *Database

+ type Collection struct

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

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

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

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

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

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

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

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

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

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

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

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

+ func (coll *Collection) ReplaceOne(ctx context.Context, filter interface{}, replacement 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)

+ type Cursor ops.Cursor

+ type Database struct

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

+ func (db *Database) Collection(name string) *Collection

+ func (db *Database) Name() string

+ func (db *Database) RunCommand(ctx context.Context, command interface{}) (bson.Reader, error)

+ type DeleteResult struct

+ DeletedCount int64

+ type DocumentResult struct

+ func (dr *DocumentResult) Decode(v interface{}) error

+ type InsertManyResult struct

+ InsertedIDs []interface{}

+ type InsertOneResult struct

+ InsertedID interface{}

+ type UpdateResult struct

+ MatchedCount int64

+ ModifiedCount int64

+ UpsertedID interface{}

+ func (result *UpdateResult) UnmarshalBSON(b []byte) error