mongodb

Documentation

Index

• func CalcMongoUri(params UriParams) string
• func TransformId(id string) (primitive.ObjectID, error)
• func TransformIds(ids []string) ([]primitive.ObjectID, error)
• type DB
  • func New(uri string, dbName string) (*DB, error)
  • func (m *DB) GetCollection(n string) *mongo.Collection
• type EntityCreator
• type EntityTransformer
• type Helper
  • func NewHelper[Entity any, Transform any](collection *mongo.Collection, creator EntityCreator[Entity]) Helper[Entity, Transform]
• type UriParams

Functions

func CalcMongoUri

func CalcMongoUri(params UriParams) string

func TransformId

func TransformId(id string) (primitive.ObjectID, error)

func TransformIds

func TransformIds(ids []string) ([]primitive.ObjectID, error)

Types

type DB

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

func New

func New(uri string, dbName string) (*DB, error)

func (*DB) GetCollection

func (m *DB) GetCollection(n string) *mongo.Collection

type EntityCreator

type EntityCreator[Entity any] func() *Entity

type EntityTransformer

type EntityTransformer[Entity any, Transform any] func(*Entity) Transform

type Helper

type Helper[Entity any, Transform any] interface {
	GetFilterCount(ctx context.Context, filter bson.M, options ...*options.CountOptions) (int64, error)
	GetListFilter(ctx context.Context, filter bson.M, options ...*options.FindOptions) ([]Entity, error)
	GetListFilterTransform(ctx context.Context, filter bson.M, transform EntityTransformer[Entity, Transform], options ...*options.FindOptions) ([]Transform, error)
	GetAggregateListFilter(ctx context.Context, pipeline mongo.Pipeline, options ...*options.AggregateOptions) ([]Entity, error)
	GetAggregateListFilterTransform(ctx context.Context, pipeline mongo.Pipeline, transform EntityTransformer[Entity, Transform], options ...*options.AggregateOptions) ([]Transform, error)
	GetFilter(ctx context.Context, filter bson.M, options ...*options.FindOneOptions) (*Entity, bool, error)
	UpdateOne(ctx context.Context, filter bson.M, setter bson.M, options ...*options.UpdateOptions) error
}

func NewHelper

func NewHelper[Entity any, Transform any](collection *mongo.Collection, creator EntityCreator[Entity]) Helper[Entity, Transform]

type UriParams

type UriParams struct {
	Host  string
	Port  string
	User  string
	Pass  string
	Db    string
	Query string
}