Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mon

package

Go to main page

Versions in this module

v1

v1.0.2

Sep 6, 2023

v1.0.1

Jul 17, 2023

v1.0.0

Jan 11, 2023

Changes in this version

+ var ErrNotFound = mongo.ErrNoDocuments

+ func FormatAddr(hosts []string) string

+ func Inject(key string, client *mongo.Client)

+ func SetSlowThreshold(threshold time.Duration)

+ type BulkInserter struct

+ func NewBulkInserter(coll Collection, interval ...time.Duration) (*BulkInserter, error)

+ func (bi *BulkInserter) Flush()

+ func (bi *BulkInserter) Insert(doc interface{})

+ func (bi *BulkInserter) SetResultHandler(handler ResultHandler)

+ type ClosableClient struct

+ func (cs *ClosableClient) Close() error

+ type Collection interface

+ Aggregate func(ctx context.Context, pipeline interface{}, opts ...*mopt.AggregateOptions) (*mongo.Cursor, error)

+ BulkWrite func(ctx context.Context, models []mongo.WriteModel, opts ...*mopt.BulkWriteOptions) (*mongo.BulkWriteResult, error)

+ Clone func(opts ...*mopt.CollectionOptions) (*mongo.Collection, error)

+ CountDocuments func(ctx context.Context, filter interface{}, opts ...*mopt.CountOptions) (int64, error)

+ Database func() *mongo.Database

+ DeleteMany func(ctx context.Context, filter interface{}, opts ...*mopt.DeleteOptions) (*mongo.DeleteResult, error)

+ DeleteOne func(ctx context.Context, filter interface{}, opts ...*mopt.DeleteOptions) (*mongo.DeleteResult, error)

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

+ Drop func(ctx context.Context) error

+ EstimatedDocumentCount func(ctx context.Context, opts ...*mopt.EstimatedDocumentCountOptions) (int64, error)

+ Find func(ctx context.Context, filter interface{}, opts ...*mopt.FindOptions) (*mongo.Cursor, error)

+ FindOne func(ctx context.Context, filter interface{}, opts ...*mopt.FindOneOptions) (*mongo.SingleResult, error)

+ FindOneAndDelete func(ctx context.Context, filter interface{}, opts ...*mopt.FindOneAndDeleteOptions) (*mongo.SingleResult, error)

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

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

+ Indexes func() mongo.IndexView

+ InsertMany func(ctx context.Context, documents []interface{}, opts ...*mopt.InsertManyOptions) (*mongo.InsertManyResult, error)

+ InsertOne func(ctx context.Context, document interface{}, opts ...*mopt.InsertOneOptions) (*mongo.InsertOneResult, error)

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

+ UpdateByID func(ctx context.Context, id, update interface{}, opts ...*mopt.UpdateOptions) (*mongo.UpdateResult, error)

+ UpdateMany func(ctx context.Context, filter, update interface{}, opts ...*mopt.UpdateOptions) (*mongo.UpdateResult, error)

+ UpdateOne func(ctx context.Context, filter, update interface{}, opts ...*mopt.UpdateOptions) (*mongo.UpdateResult, error)

+ Watch func(ctx context.Context, pipeline interface{}, opts ...*mopt.ChangeStreamOptions) (*mongo.ChangeStream, error)

+ type Model struct

+ func MustNewModel(uri, db, collection string, opts ...Option) *Model

+ func NewModel(uri, db, collection string, opts ...Option) (*Model, error)

+ func (m *Model) Aggregate(ctx context.Context, v, pipeline interface{}, opts ...*mopt.AggregateOptions) error

+ func (m *Model) DeleteMany(ctx context.Context, filter interface{}, opts ...*mopt.DeleteOptions) (int64, error)

+ func (m *Model) DeleteOne(ctx context.Context, filter interface{}, opts ...*mopt.DeleteOptions) (int64, error)

+ func (m *Model) Find(ctx context.Context, v, filter interface{}, opts ...*mopt.FindOptions) error

+ func (m *Model) FindOne(ctx context.Context, v, filter interface{}, opts ...*mopt.FindOneOptions) error

+ func (m *Model) FindOneAndDelete(ctx context.Context, v, filter interface{}, ...) error

+ func (m *Model) FindOneAndReplace(ctx context.Context, v, filter, replacement interface{}, ...) error

+ func (m *Model) FindOneAndUpdate(ctx context.Context, v, filter, update interface{}, ...) error

+ func (m *Model) StartSession(opts ...*mopt.SessionOptions) (sess mongo.Session, err error)

+ type Option func(opts *options)

+ func WithTimeout(timeout time.Duration) Option

+ type ResultHandler func(*mongo.InsertManyResult, error)