friendlymongo

package module

Go to main page

Versions in this module

v0

v0.5.0

May 23, 2024

v0.4.0

Mar 31, 2024

v0.3.0

Mar 30, 2024

Changes in this version

+ func AddToSet(exp map[string]interface{}) bson.M

+ func ArrayToObject(exp interface{}) bson.M

+ func Each(values interface{}) bson.M

+ func First(exp interface{}) bson.M

+ func Map(input, as, k, v string) bson.M

+ func Push(exp interface{}) bson.M

v0.2.0

Mar 27, 2024

Changes in this version

+ func IncludeIndex(index string) unwindOptsFunc

+ func PreserveNullEmpty(preserve bool) unwindOptsFunc

type StageBuilder

+ func (pb *StageBuilder) Bucket(id string, groupBy string, boundaries []any, def any, output bson.M) *StageBuilder

+ func (pb *StageBuilder) Facet(id string, aggregations map[string]*StageBuilder) *StageBuilder

+ func (pb *StageBuilder) SortByCount(id string, expr interface{}) *StageBuilder

+ func (pb *StageBuilder) Unwind(id, fieldPath string, opts ...unwindOptsFunc) *StageBuilder

v0.1.0

Mar 17, 2024

Changes in this version

+ type BaseModel struct

+ CreatedAt time.Time

+ ID primitive.ObjectID

+ UpdatedAt time.Time

+ func NewBaseModel() *BaseModel

+ func (b *BaseModel) OnCreate()

+ func (b *BaseModel) OnReplace()

+ func (b *BaseModel) OnUpdate()

+ type BaseRepository struct

+ func NewBaseRepository[T Model](db *mongo.Database, collectionName string, t T) *BaseRepository[T]

+ func (r *BaseRepository[Model]) ReplaceOne(ctx context.Context, filter interface{}, replacement Model) error

+ func (r *BaseRepository[T]) Aggregate(ctx context.Context, pipeline mongo.Pipeline, result interface{}) error

+ func (r *BaseRepository[T]) Delete(ctx context.Context, filter interface{}) (int64, error)

+ func (r *BaseRepository[T]) Find(ctx context.Context, filter interface{}) ([]T, error)

+ func (r *BaseRepository[T]) FindOne(ctx context.Context, filter interface{}) (T, error)

+ func (r *BaseRepository[T]) InsertMany(ctx context.Context, documents []T) error

+ func (r *BaseRepository[T]) InsertOne(ctx context.Context, document T) error

+ func (r *BaseRepository[T]) UpdateOne(ctx context.Context, filters interface{}, update interface{}) (T, error)

+ type Model interface

+ OnCreate func()

+ OnReplace func()

+ OnUpdate func()

+ type MongoClient struct

+ func GetInstance() *MongoClient

+ func SetInstance(uri string) *MongoClient

+ func (c *MongoClient) Client() *mongo.Client

+ func (c *MongoClient) Connect() error

+ func (c *MongoClient) Database(name string) *mongo.Database

+ func (c *MongoClient) Disconnect() error

+ type MongoRepository interface

+ Aggregate func(ctx context.Context, pipeline mongo.Pipeline, result interface{}) error

+ Delete func(ctx context.Context, filter interface{}) (int64, error)

+ Find func(ctx context.Context, filter interface{}) ([]Model, error)

+ FindOne func(ctx context.Context, filter interface{}) (Model, error)

+ InsertMany func(ctx context.Context, documents []Model) error

+ InsertOne func(ctx context.Context, document Model) error

+ ReplaceOne func(ctx context.Context, filter interface{}, replacement T) error

+ UpdateOne func(ctx context.Context, filters interface{}, update interface{}) (Model, error)

+ type StageBuilder struct

+ func NewStageBuilder() *StageBuilder

+ func (pb *StageBuilder) AddStage(id string, stageType string, filters interface{}) *StageBuilder

+ func (pb *StageBuilder) Append(id string, filters interface{}) *StageBuilder

+ func (pb *StageBuilder) Build() mongo.Pipeline

+ func (pb *StageBuilder) Count(id string, filter string) *StageBuilder

+ func (pb *StageBuilder) Group(id string, filters interface{}) *StageBuilder

+ func (pb *StageBuilder) Limit(id string, filters interface{}) *StageBuilder

+ func (pb *StageBuilder) Lookup(id string, filters bson.M) *StageBuilder

+ func (pb *StageBuilder) Match(id string, filters interface{}) *StageBuilder

+ func (pb *StageBuilder) Project(id string, filters interface{}) *StageBuilder

+ func (pb *StageBuilder) Skip(id string, filters interface{}) *StageBuilder

+ func (pb *StageBuilder) Sort(id string, filters interface{}) *StageBuilder

+ func (pb *StageBuilder) Stages() []*stage

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL