typed_mongo

Documentation

Index

• func Aggregate[D any, U any](ctx context.Context, c TypedCollection[D], pipeline model.AggregatePipeline, ...) ([]*U, error)
• type BulkWriteOperation
  • func (b *BulkWriteOperation) Execute(ctx context.Context) (*mongo.BulkWriteResult, error)
  • func (b *BulkWriteOperation) UpdateOne(update *model.TypedUpdateOneModel) *BulkWriteOperation
• type TypedCollection
  • func NewTypedCollection[D any](db *mongo.Database, name string, opts ...*options.CollectionOptions) TypedCollection[D]

Functions

func Aggregate

func Aggregate[D any, U any](ctx context.Context, c TypedCollection[D], pipeline model.AggregatePipeline, opts ...*options.AggregateOptions) ([]*U, error)

Types

type BulkWriteOperation

type BulkWriteOperation struct {
	// contains filtered or unexported fields
}

func (*BulkWriteOperation) Execute

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

func (*BulkWriteOperation) UpdateOne

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

type TypedCollection

type TypedCollection[D any] interface {
	FindOne(ctx context.Context, filter model.Filter, opts ...*options.FindOneOptions) (*D, error)
	Find(ctx context.Context, filter model.Filter, opts ...*options.FindOptions) ([]*D, error)
	FindByDocIds(ctx context.Context, ids []primitive.ObjectID, opts ...*options.FindOptions) ([]*D, error)
	CountDocuments(ctx context.Context, filter model.Filter, opts ...*options.CountOptions) (int64, error)
	InsertOne(ctx context.Context, doc D) (primitive.ObjectID, error)
	InsertMany(ctx context.Context, docs []*D) ([]primitive.ObjectID, error)
	FindOneAndUpdate(ctx context.Context, m *model.FindOneAndUpdate, opts ...*options.FindOneAndUpdateOptions) (*D, error)
	UpdateOne(ctx context.Context, m *model.UpdateOne, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)
	UpdateMany(ctx context.Context, m *model.UpdateMany, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)
	UpdateById(ctx context.Context, m *model.UpdateById, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)
	DeleteOne(ctx context.Context, filter model.Filter, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
	DeleteMany(ctx context.Context, filter model.Filter, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
	InitializeBulkWriteOp(opts ...*options.BulkWriteOptions) *BulkWriteOperation
	// contains filtered or unexported methods
}

func NewTypedCollection

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