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 + type Aggregate struct + func NewAggregate(pipeline bsoncore.Document) *Aggregate + func (a *Aggregate) AllowDiskUse(allowDiskUse bool) *Aggregate + func (a *Aggregate) BatchSize(batchSize int32) *Aggregate + func (a *Aggregate) BypassDocumentValidation(bypassDocumentValidation bool) *Aggregate + func (a *Aggregate) ClusterClock(clock *session.ClusterClock) *Aggregate + func (a *Aggregate) Collation(collation bsoncore.Document) *Aggregate + func (a *Aggregate) Collection(collection string) *Aggregate + func (a *Aggregate) CommandMonitor(monitor *event.CommandMonitor) *Aggregate + func (a *Aggregate) Comment(comment string) *Aggregate + func (a *Aggregate) Database(database string) *Aggregate + func (a *Aggregate) Deployment(deployment driver.Deployment) *Aggregate + func (a *Aggregate) Execute(ctx context.Context) error + func (a *Aggregate) Hint(hint bsoncore.Value) *Aggregate + func (a *Aggregate) MaxTimeMS(maxTimeMS int64) *Aggregate + func (a *Aggregate) Pipeline(pipeline bsoncore.Document) *Aggregate + func (a *Aggregate) ReadConcern(readConcern *readconcern.ReadConcern) *Aggregate + func (a *Aggregate) ReadPreference(readPreference *readpref.ReadPref) *Aggregate + func (a *Aggregate) Result(opts driver.CursorOptions) (*driver.BatchCursor, error) + func (a *Aggregate) ServerSelector(selector description.ServerSelector) *Aggregate + func (a *Aggregate) Session(session *session.Client) *Aggregate + func (a *Aggregate) WriteConcern(writeConcern *writeconcern.WriteConcern) *Aggregate + type Command struct + func NewCommand(command bsoncore.Document) *Command + func (c *Command) ClusterClock(clock *session.ClusterClock) *Command + func (c *Command) Command(command bsoncore.Document) *Command + func (c *Command) CommandMonitor(monitor *event.CommandMonitor) *Command + func (c *Command) Database(database string) *Command + func (c *Command) Deployment(deployment driver.Deployment) *Command + func (c *Command) Execute(ctx context.Context) error + func (c *Command) ReadConcern(readConcern *readconcern.ReadConcern) *Command + func (c *Command) ReadPreference(readPreference *readpref.ReadPref) *Command + func (c *Command) Result() bsoncore.Document + func (c *Command) ResultCursor(opts driver.CursorOptions) (*driver.BatchCursor, error) + func (c *Command) ServerSelector(selector description.ServerSelector) *Command + func (c *Command) Session(session *session.Client) *Command + type CreateIndexes struct + func NewCreateIndexes(indexes bsoncore.Document) *CreateIndexes + func (ci *CreateIndexes) ClusterClock(clock *session.ClusterClock) *CreateIndexes + func (ci *CreateIndexes) Collection(collection string) *CreateIndexes + func (ci *CreateIndexes) CommandMonitor(monitor *event.CommandMonitor) *CreateIndexes + func (ci *CreateIndexes) Database(database string) *CreateIndexes + func (ci *CreateIndexes) Deployment(deployment driver.Deployment) *CreateIndexes + func (ci *CreateIndexes) Execute(ctx context.Context) error + func (ci *CreateIndexes) Indexes(indexes bsoncore.Document) *CreateIndexes + func (ci *CreateIndexes) MaxTimeMS(maxTimeMS int64) *CreateIndexes + func (ci *CreateIndexes) Result() CreateIndexesResult + func (ci *CreateIndexes) ServerSelector(selector description.ServerSelector) *CreateIndexes + func (ci *CreateIndexes) Session(session *session.Client) *CreateIndexes + type CreateIndexesResult struct + CreatedCollectionAutomatically bool + IndexesAfter int32 + IndexesBefore int32 + type Delete struct + func NewDelete(deletes ...bsoncore.Document) *Delete + func (d *Delete) ClusterClock(clock *session.ClusterClock) *Delete + func (d *Delete) Collection(collection string) *Delete + func (d *Delete) CommandMonitor(monitor *event.CommandMonitor) *Delete + func (d *Delete) Database(database string) *Delete + func (d *Delete) Deletes(deletes ...bsoncore.Document) *Delete + func (d *Delete) Deployment(deployment driver.Deployment) *Delete + func (d *Delete) Execute(ctx context.Context) error + func (d *Delete) Ordered(ordered bool) *Delete + func (d *Delete) Result() DeleteResult + func (d *Delete) Retry(retry driver.RetryMode) *Delete + func (d *Delete) ServerSelector(selector description.ServerSelector) *Delete + func (d *Delete) Session(session *session.Client) *Delete + func (d *Delete) WriteConcern(writeConcern *writeconcern.WriteConcern) *Delete + type DeleteResult struct + N int32 + type Distinct struct + func NewDistinct(key string, query bsoncore.Document) *Distinct + func (d *Distinct) ClusterClock(clock *session.ClusterClock) *Distinct + func (d *Distinct) Collation(collation bsoncore.Document) *Distinct + func (d *Distinct) Collection(collection string) *Distinct + func (d *Distinct) CommandMonitor(monitor *event.CommandMonitor) *Distinct + func (d *Distinct) Database(database string) *Distinct + func (d *Distinct) Deployment(deployment driver.Deployment) *Distinct + func (d *Distinct) Execute(ctx context.Context) error + func (d *Distinct) Key(key string) *Distinct + func (d *Distinct) MaxTimeMS(maxTimeMS int64) *Distinct + func (d *Distinct) Query(query bsoncore.Document) *Distinct + func (d *Distinct) ReadConcern(readConcern *readconcern.ReadConcern) *Distinct + func (d *Distinct) ReadPreference(readPreference *readpref.ReadPref) *Distinct + func (d *Distinct) Result() DistinctResult + func (d *Distinct) ServerSelector(selector description.ServerSelector) *Distinct + func (d *Distinct) Session(session *session.Client) *Distinct + type DistinctResult struct + Values bsoncore.Value + type DropCollection struct + func NewDropCollection() *DropCollection + func (dc *DropCollection) ClusterClock(clock *session.ClusterClock) *DropCollection + func (dc *DropCollection) Collection(collection string) *DropCollection + func (dc *DropCollection) CommandMonitor(monitor *event.CommandMonitor) *DropCollection + func (dc *DropCollection) Database(database string) *DropCollection + func (dc *DropCollection) Deployment(deployment driver.Deployment) *DropCollection + func (dc *DropCollection) Execute(ctx context.Context) error + func (dc *DropCollection) Result() DropCollectionResult + func (dc *DropCollection) ServerSelector(selector description.ServerSelector) *DropCollection + func (dc *DropCollection) Session(session *session.Client) *DropCollection + func (dc *DropCollection) WriteConcern(writeConcern *writeconcern.WriteConcern) *DropCollection + type DropCollectionResult struct + NIndexesWas int32 + Ns string + type Find struct + func NewFind(filter bsoncore.Document) *Find + func (f *Find) AllowPartialResults(allowPartialResults bool) *Find + func (f *Find) AwaitData(awaitData bool) *Find + func (f *Find) BatchSize(batchSize int32) *Find + func (f *Find) ClusterClock(clock *session.ClusterClock) *Find + func (f *Find) Collation(collation bsoncore.Document) *Find + func (f *Find) Collection(collection string) *Find + func (f *Find) CommandMonitor(monitor *event.CommandMonitor) *Find + func (f *Find) Comment(comment string) *Find + func (f *Find) Database(database string) *Find + func (f *Find) Deployment(deployment driver.Deployment) *Find + func (f *Find) Execute(ctx context.Context) error + func (f *Find) Filter(filter bsoncore.Document) *Find + func (f *Find) Hint(hint bsoncore.Value) *Find + func (f *Find) Limit(limit int64) *Find + func (f *Find) Max(max bsoncore.Document) *Find + func (f *Find) MaxTimeMS(maxTimeMS int64) *Find + func (f *Find) Min(min bsoncore.Document) *Find + func (f *Find) NoCursorTimeout(noCursorTimeout bool) *Find + func (f *Find) OplogReplay(oplogReplay bool) *Find + func (f *Find) Projection(projection bsoncore.Document) *Find + func (f *Find) ReadConcern(readConcern *readconcern.ReadConcern) *Find + func (f *Find) ReadPreference(readPreference *readpref.ReadPref) *Find + func (f *Find) Result(opts driver.CursorOptions) (*driver.BatchCursor, error) + func (f *Find) ReturnKey(returnKey bool) *Find + func (f *Find) ServerSelector(selector description.ServerSelector) *Find + func (f *Find) Session(session *session.Client) *Find + func (f *Find) ShowRecordID(showRecordID bool) *Find + func (f *Find) SingleBatch(singleBatch bool) *Find + func (f *Find) Skip(skip int64) *Find + func (f *Find) Snapshot(snapshot bool) *Find + func (f *Find) Sort(sort bsoncore.Document) *Find + func (f *Find) Tailable(tailable bool) *Find + type FindAndModify struct + func NewFindAndModify(query bsoncore.Document) *FindAndModify + func (fam *FindAndModify) ArrayFilters(arrayFilters bsoncore.Document) *FindAndModify + func (fam *FindAndModify) BypassDocumentValidation(bypassDocumentValidation bool) *FindAndModify + func (fam *FindAndModify) ClusterClock(clock *session.ClusterClock) *FindAndModify + func (fam *FindAndModify) Collation(collation bsoncore.Document) *FindAndModify + func (fam *FindAndModify) Collection(collection string) *FindAndModify + func (fam *FindAndModify) CommandMonitor(monitor *event.CommandMonitor) *FindAndModify + func (fam *FindAndModify) Database(database string) *FindAndModify + func (fam *FindAndModify) Deployment(deployment driver.Deployment) *FindAndModify + func (fam *FindAndModify) Execute(ctx context.Context) error + func (fam *FindAndModify) Fields(fields bsoncore.Document) *FindAndModify + func (fam *FindAndModify) MaxTimeMS(maxTimeMS int64) *FindAndModify + func (fam *FindAndModify) NewDocument(newDocument bool) *FindAndModify + func (fam *FindAndModify) Query(query bsoncore.Document) *FindAndModify + func (fam *FindAndModify) Remove(remove bool) *FindAndModify + func (fam *FindAndModify) Result() FindAndModifyResult + func (fam *FindAndModify) Retry(retry driver.RetryMode) *FindAndModify + func (fam *FindAndModify) ServerSelector(selector description.ServerSelector) *FindAndModify + func (fam *FindAndModify) Session(session *session.Client) *FindAndModify + func (fam *FindAndModify) Sort(sort bsoncore.Document) *FindAndModify + func (fam *FindAndModify) Update(update bsoncore.Document) *FindAndModify + func (fam *FindAndModify) Upsert(upsert bool) *FindAndModify + func (fam *FindAndModify) WriteConcern(writeConcern *writeconcern.WriteConcern) *FindAndModify + type FindAndModifyResult struct + LastErrorObject LastErrorObject + Value bsoncore.Document + type Insert struct + func NewInsert(documents ...bsoncore.Document) *Insert + func (i *Insert) BypassDocumentValidation(bypassDocumentValidation bool) *Insert + func (i *Insert) ClusterClock(clock *session.ClusterClock) *Insert + func (i *Insert) Collection(collection string) *Insert + func (i *Insert) CommandMonitor(monitor *event.CommandMonitor) *Insert + func (i *Insert) Database(database string) *Insert + func (i *Insert) Deployment(deployment driver.Deployment) *Insert + func (i *Insert) Documents(documents ...bsoncore.Document) *Insert + func (i *Insert) Execute(ctx context.Context) error + func (i *Insert) Ordered(ordered bool) *Insert + func (i *Insert) Result() InsertResult + func (i *Insert) Retry(retry driver.RetryMode) *Insert + func (i *Insert) ServerSelector(selector description.ServerSelector) *Insert + func (i *Insert) Session(session *session.Client) *Insert + func (i *Insert) WriteConcern(writeConcern *writeconcern.WriteConcern) *Insert + type InsertResult struct + N int32 + type IsMaster struct + func NewIsMaster() *IsMaster + func (im *IsMaster) AppName(appname string) *IsMaster + func (im *IsMaster) ClusterClock(clock *session.ClusterClock) *IsMaster + func (im *IsMaster) Compressors(compressors []string) *IsMaster + func (im *IsMaster) Deployment(d driver.Deployment) *IsMaster + func (im *IsMaster) Execute(ctx context.Context) error + func (im *IsMaster) Handshake(ctx context.Context, _ address.Address, c driver.Connection) (description.Server, error) + func (im *IsMaster) Result(addr address.Address) description.Server + func (im *IsMaster) SASLSupportedMechs(username string) *IsMaster + type LastErrorObject struct + UpdatedExisting bool + Upserted interface{} + type ListCollections struct + func NewListCollections(filter bsoncore.Document) *ListCollections + func (lc *ListCollections) ClusterClock(clock *session.ClusterClock) *ListCollections + func (lc *ListCollections) CommandMonitor(monitor *event.CommandMonitor) *ListCollections + func (lc *ListCollections) Database(database string) *ListCollections + func (lc *ListCollections) Deployment(deployment driver.Deployment) *ListCollections + func (lc *ListCollections) Execute(ctx context.Context) error + func (lc *ListCollections) Filter(filter bsoncore.Document) *ListCollections + func (lc *ListCollections) NameOnly(nameOnly bool) *ListCollections + func (lc *ListCollections) ReadPreference(readPreference *readpref.ReadPref) *ListCollections + func (lc *ListCollections) Result(opts driver.CursorOptions) (*driver.ListCollectionsBatchCursor, error) + func (lc *ListCollections) ServerSelector(selector description.ServerSelector) *ListCollections + func (lc *ListCollections) Session(session *session.Client) *ListCollections + type ListDatabases struct + func NewListDatabases(filter bsoncore.Document) *ListDatabases + func (ld *ListDatabases) ClusterClock(clock *session.ClusterClock) *ListDatabases + func (ld *ListDatabases) CommandMonitor(monitor *event.CommandMonitor) *ListDatabases + func (ld *ListDatabases) Database(database string) *ListDatabases + func (ld *ListDatabases) Deployment(deployment driver.Deployment) *ListDatabases + func (ld *ListDatabases) Execute(ctx context.Context) error + func (ld *ListDatabases) Filter(filter bsoncore.Document) *ListDatabases + func (ld *ListDatabases) NameOnly(nameOnly bool) *ListDatabases + func (ld *ListDatabases) ReadPreference(readPreference *readpref.ReadPref) *ListDatabases + func (ld *ListDatabases) Result() ListDatabasesResult + func (ld *ListDatabases) ServerSelector(selector description.ServerSelector) *ListDatabases + func (ld *ListDatabases) Session(session *session.Client) *ListDatabases + type ListDatabasesResult struct + Databases []databaseRecord + TotalSize int64 + type ListIndexes struct + func NewListIndexes() *ListIndexes + func (li *ListIndexes) BatchSize(batchSize int32) *ListIndexes + func (li *ListIndexes) ClusterClock(clock *session.ClusterClock) *ListIndexes + func (li *ListIndexes) Collection(collection string) *ListIndexes + func (li *ListIndexes) CommandMonitor(monitor *event.CommandMonitor) *ListIndexes + func (li *ListIndexes) Database(database string) *ListIndexes + func (li *ListIndexes) Deployment(deployment driver.Deployment) *ListIndexes + func (li *ListIndexes) Execute(ctx context.Context) error + func (li *ListIndexes) MaxTimeMS(maxTimeMS int64) *ListIndexes + func (li *ListIndexes) Result(opts driver.CursorOptions) (*driver.BatchCursor, error) + func (li *ListIndexes) ServerSelector(selector description.ServerSelector) *ListIndexes + func (li *ListIndexes) Session(session *session.Client) *ListIndexes + type Update struct + func NewUpdate(updates ...bsoncore.Document) *Update + func (u *Update) BypassDocumentValidation(bypassDocumentValidation bool) *Update + func (u *Update) ClusterClock(clock *session.ClusterClock) *Update + func (u *Update) Collection(collection string) *Update + func (u *Update) CommandMonitor(monitor *event.CommandMonitor) *Update + func (u *Update) Database(database string) *Update + func (u *Update) Deployment(deployment driver.Deployment) *Update + func (u *Update) Execute(ctx context.Context) error + func (u *Update) Ordered(ordered bool) *Update + func (u *Update) Result() UpdateResult + func (u *Update) Retry(retry driver.RetryMode) *Update + func (u *Update) ServerSelector(selector description.ServerSelector) *Update + func (u *Update) Session(session *session.Client) *Update + func (u *Update) Updates(updates ...bsoncore.Document) *Update + func (u *Update) WriteConcern(writeConcern *writeconcern.WriteConcern) *Update + type UpdateResult struct + N int32 + NModified int32 + Upserted []Upsert + type Upsert struct + ID interface{} + Index int64
Go to main page