mongo

Oct 20, 2023

Changes in this version

+ var ErrClientDisconnected = rawmongo.ErrClientDisconnected

+ var ErrEmptyIndex = collection.ErrEmptyIndex

+ var ErrNoDocuments = rawmongo.ErrNoDocuments

+ func FromAddr(host string, port int) *builder.ClientBuilder

+ func FromAddrs(addrs ...*model.Addr) *builder.ClientBuilder

+ func FromUri(uri string) *builder.ClientBuilder

May 23, 2022

Changes in this version

type TypedCollection

+ DeleteMany func(ctx context.Context, filter model.Filter, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ DeleteOne func(ctx context.Context, filter model.Filter, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ UpdateOne func(ctx context.Context, m *model.UpdateOne, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

May 20, 2022

Changes in this version

+ type BulkWriteOperation struct

+ func (b *BulkWriteOperation) Execute(ctx context.Context) (*mongo.BulkWriteResult, error)

+ func (b *BulkWriteOperation) UpdateOne(update *model.TypedUpdateOneModel) *BulkWriteOperation

type TypedCollection

+ InitializeBulkWriteOp func() *BulkWriteOperation

May 19, 2022

Changes in this version

type TypedCollection

+ CountDocuments func(ctx context.Context, filter model.Filter, opts ...*options.CountOptions) (int64, error)

May 19, 2022

Changes in this version

+ func Aggregate(ctx context.Context, c typedCollectionImpl[D], ...) ([]*U, error)

May 19, 2022

Changes in this version

+ type TypedCollection interface

+ Find func(ctx context.Context, filter model.Filter, opts ...*options.FindOptions) ([]*D, error)

+ FindByDocIds func(ctx context.Context, ids []primitive.ObjectID, opts ...*options.FindOptions) ([]*D, error)

+ FindOne func(ctx context.Context, filter model.Filter, opts ...*options.FindOneOptions) (*D, error)

+ FindOneAndUpdate func(ctx context.Context, m *model.FindOneAndUpdate, ...) (*D, error)

+ InsertMany func(ctx context.Context, docs []*D) ([]primitive.ObjectID, error)

+ InsertOne func(ctx context.Context, doc D) (primitive.ObjectID, error)

+ UpdateById func(ctx context.Context, m *model.UpdateById, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ UpdateMany func(ctx context.Context, m *model.UpdateMany, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ func NewTypedCollection(db *mongo.Database, name string, opts ...*options.CollectionOptions) TypedCollection[D]

May 18, 2022

Changes in this version

+ func Find(ctx context.Context, c *mongo.Collection, filter model.Filter, ...) ([]*T, error)

+ func FindByDocIds(ctx context.Context, c *mongo.Collection, ids []primitive.ObjectID, ...) ([]*T, error)

+ func FindOne(ctx context.Context, c *mongo.Collection, filter model.Filter, ...) (*T, error)

+ func FindOneAndUpdate(ctx context.Context, c *mongo.Collection, m *model.FindOneAndUpdate, ...) (*T, error)

+ func InsertMany(ctx context.Context, c *mongo.Collection, docs []*T) ([]primitive.ObjectID, error)

+ func InsertOne(ctx context.Context, c *mongo.Collection, doc T) (primitive.ObjectID, error)

+ func UpdateById(ctx context.Context, c *mongo.Collection, m *model.UpdateById, ...) (*mongo.UpdateResult, error)

+ func UpdateMany(ctx context.Context, c *mongo.Collection, m *model.UpdateMany, ...) (*mongo.UpdateResult, error)