Versions in this module Expand all Collapse all v1 v1.0.4 Jun 3, 2019 v1.0.3 Jun 2, 2019 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") + var ErrFilterType = errors.New("filter must be a string") + func AbortTransaction(ctx context.Context, cmd command.AbortTransaction, topo *topology.Topology, ...) (result.TransactionResult, 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 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, ns command.Namespace, server driver.Server, ...) (result.KillCursors, error) + func ListDatabases(ctx context.Context, cmd command.ListDatabases, topo *topology.Topology, ...) (result.ListDatabases, error) + func Read(ctx context.Context, cmd command.Read, topo *topology.Topology, ...) (bson.Raw, 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 BatchCursor struct + func Aggregate(ctx context.Context, cmd command.Aggregate, topo *topology.Topology, ...) (*BatchCursor, error) + func Find(ctx context.Context, cmd command.Find, topo *topology.Topology, ...) (*BatchCursor, error) + func ListIndexes(ctx context.Context, cmd command.ListIndexes, topo *topology.Topology, ...) (*BatchCursor, error) + func NewBatchCursor(result bsoncore.Document, clientSession *session.Client, ...) (*BatchCursor, error) + func NewEmptyBatchCursor() *BatchCursor + func NewLegacyBatchCursor(ns command.Namespace, cursorID int64, ds *bsoncore.DocumentSequence, ...) (*BatchCursor, error) + func ReadCursor(ctx context.Context, cmd command.Read, topo *topology.Topology, ...) (*BatchCursor, error) + func (bc *BatchCursor) Batch() *bsoncore.DocumentSequence + 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) PostBatchResumeToken() bsoncore.Document + func (bc *BatchCursor) Server() driver.Server + 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 ListCollectionsBatchCursor struct + func ListCollections(ctx context.Context, cmd command.ListCollections, topo *topology.Topology, ...) (*ListCollectionsBatchCursor, error) + func NewLegacyListCollectionsBatchCursor(bc *BatchCursor) (*ListCollectionsBatchCursor, error) + func NewListCollectionsBatchCursor(bc *BatchCursor) (*ListCollectionsBatchCursor, error) + func (lcbc *ListCollectionsBatchCursor) Batch() *bsoncore.DocumentSequence + 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) Server() driver.Server + 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
Go to main page