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

mongodb

package

Go to main page

Versions in this module

v1

v1.1.72

Jun 5, 2024

v1.1.71

Jun 4, 2024

v1.1.70

May 28, 2024

Changes in this version

+ func NewMongoDBConn(ctx context.Context, cfg *common_utils.BaseConfig) (*mongo.Client, error)

+ type MongoDB interface

+ Aggregate func(ctx context.Context, collection string, pipeline any, ...) (*mongo.Cursor, error)

+ Client func() *mongo.Client

+ Collection func(name string, opts ...*options.CollectionOptions) *mongo.Collection

+ CountDocuments func(ctx context.Context, collection string, filter any, ...) (int64, error)

+ CreateCollection func(ctx context.Context, name string, opts ...*options.CreateCollectionOptions) error

+ DeleteMany func(ctx context.Context, collection string, filter any, ...) (*mongo.DeleteResult, error)

+ DeleteOne func(ctx context.Context, collection string, filter any, ...) (*mongo.DeleteResult, error)

+ Distinct func(ctx context.Context, collection string, fieldName string, filter any, ...) ([]any, error)

+ DropCollection func(ctx context.Context, name string) error

+ EstimatedDocumentCount func(ctx context.Context, collection string, ...) (int64, error)

+ Find func(ctx context.Context, collection string, filter any, ...) (*mongo.Cursor, error)

+ FindOne func(ctx context.Context, collection string, filter any, ...) *mongo.SingleResult

+ FindOneAndDelete func(ctx context.Context, collection string, filter any, ...) *mongo.SingleResult

+ FindOneAndReplace func(ctx context.Context, collection string, filter any, replacement any, ...) *mongo.SingleResult

+ FindOneAndUpdate func(ctx context.Context, collection string, filter any, update any, ...) *mongo.SingleResult

+ Indexes func(collection string) mongo.IndexView

+ InsertMany func(ctx context.Context, collection string, documents []any) (*mongo.InsertManyResult, error)

+ InsertOne func(ctx context.Context, collection string, document any) (*mongo.InsertOneResult, error)

+ StartSession func() (mongo.Session, error)

+ UpdateMany func(ctx context.Context, collection string, filter any, update any, ...) (*mongo.UpdateResult, error)

+ UpdateOne func(ctx context.Context, collection string, filter any, update any, ...) (*mongo.UpdateResult, error)

+ UseSession func(ctx context.Context, fn func(mongo.SessionContext) error) error

+ Watch func(ctx context.Context, collection string, pipeline any, ...) (*mongo.ChangeStream, error)

+ func NewMongoDBClient(client *mongo.Client, cfg *common_utils.BaseConfig) MongoDB

+ type MongoDBClient struct

+ func (m *MongoDBClient) Aggregate(ctx context.Context, collection string, pipeline any, ...) (*mongo.Cursor, error)

+ func (m *MongoDBClient) Client() *mongo.Client

+ func (m *MongoDBClient) Collection(name string, opts ...*options.CollectionOptions) *mongo.Collection

+ func (m *MongoDBClient) CountDocuments(ctx context.Context, collection string, filter any, ...) (int64, error)

+ func (m *MongoDBClient) CreateCollection(ctx context.Context, name string, opts ...*options.CreateCollectionOptions) error

+ func (m *MongoDBClient) DeleteMany(ctx context.Context, collection string, filter any, ...) (*mongo.DeleteResult, error)

+ func (m *MongoDBClient) DeleteOne(ctx context.Context, collection string, filter any, ...) (*mongo.DeleteResult, error)

+ func (m *MongoDBClient) Distinct(ctx context.Context, collection string, fieldName string, filter any, ...) ([]any, error)

+ func (m *MongoDBClient) DropCollection(ctx context.Context, name string) error

+ func (m *MongoDBClient) EstimatedDocumentCount(ctx context.Context, collection string, ...) (int64, error)

+ func (m *MongoDBClient) Find(ctx context.Context, collection string, filter any, ...) (*mongo.Cursor, error)

+ func (m *MongoDBClient) FindOne(ctx context.Context, collection string, filter any, ...) *mongo.SingleResult

+ func (m *MongoDBClient) FindOneAndDelete(ctx context.Context, collection string, filter any, ...) *mongo.SingleResult

+ func (m *MongoDBClient) FindOneAndReplace(ctx context.Context, collection string, filter any, replacement any, ...) *mongo.SingleResult

+ func (m *MongoDBClient) FindOneAndUpdate(ctx context.Context, collection string, filter any, update any, ...) *mongo.SingleResult

+ func (m *MongoDBClient) Indexes(collection string) mongo.IndexView

+ func (m *MongoDBClient) InsertMany(ctx context.Context, collection string, documents []any) (*mongo.InsertManyResult, error)

+ func (m *MongoDBClient) InsertOne(ctx context.Context, collection string, document any) (*mongo.InsertOneResult, error)

+ func (m *MongoDBClient) StartSession() (mongo.Session, error)

+ func (m *MongoDBClient) UpdateMany(ctx context.Context, collection string, filter any, update any, ...) (*mongo.UpdateResult, error)

+ func (m *MongoDBClient) UpdateOne(ctx context.Context, collection string, filter any, update any, ...) (*mongo.UpdateResult, error)

+ func (m *MongoDBClient) UseSession(ctx context.Context, fn func(mongo.SessionContext) error) error

+ func (m *MongoDBClient) Watch(ctx context.Context, collection string, pipeline any, ...) (*mongo.ChangeStream, error)