mongo

Jul 19, 2023

Changes in this version

type BaseMongoRepository

+ CollectionStats func(ctx context.Context, coll *mongo.Collection) (*CollectionStats, error)

+ type CollectionStats struct

+ AvgObjSize int

+ Size int64

+ StorageSize int64

+ TotalIndexSize int64

type Db

+ func (db *Db) CollectionStats(ctx context.Context, coll *mongo.Collection) (*CollectionStats, error)

Nov 10, 2021

Changes in this version

+ type BaseMongoRepository interface

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

+ Database func() *mongo.Database

+ Delete func(ctx context.Context, coll *mongo.Collection, filter interface{}) error

+ DeleteByID func(ctx context.Context, coll *mongo.Collection, id string) error

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

+ GetCollection func(name string) *mongo.Collection

+ GetOne func(ctx context.Context, coll *mongo.Collection, filter interface{}, ...) error

+ GetOneByID func(ctx context.Context, coll *mongo.Collection, id string, document interface{}) error

+ InsertOne func(ctx context.Context, coll *mongo.Collection, document interface{}) (string, error)

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

+ UpdateOne func(ctx context.Context, coll *mongo.Collection, filter interface{}, ...) error

+ type DBResult map[string]interface

+ type Db struct

+ Timeout time.Duration

+ func NewMongoDB(ctx context.Context, lgr logger.Logger, connectString string) (*Db, error)

+ func (db *Db) Aggregate(ctx context.Context, coll *mongo.Collection, pipe interface{}) ([]DBResult, error)

+ func (db *Db) Count(ctx context.Context, coll *mongo.Collection, filter interface{}) (int64, error)

+ func (db *Db) Database() *mongo.Database

+ func (db *Db) Delete(ctx context.Context, coll *mongo.Collection, filter interface{}) error

+ func (db *Db) DeleteByID(ctx context.Context, coll *mongo.Collection, id string) error

+ func (db *Db) Disconnect(ctx context.Context) error

+ func (db *Db) Find(ctx context.Context, coll *mongo.Collection, filter interface{}, ...) error

+ func (db *Db) GetCollection(name string) *mongo.Collection

+ func (db *Db) GetOne(ctx context.Context, coll *mongo.Collection, filter interface{}, ...) error

+ func (db *Db) GetOneByID(ctx context.Context, coll *mongo.Collection, id string, document interface{}) error

+ func (db *Db) InsertOne(ctx context.Context, coll *mongo.Collection, document interface{}) (string, error)

+ func (db *Db) Ping(ctx context.Context) error

+ func (db *Db) ReplaceOne(ctx context.Context, coll *mongo.Collection, filter interface{}, ...) error

+ func (db *Db) UpdateOne(ctx context.Context, coll *mongo.Collection, filter interface{}, ...) error