modm

package module

Go to main page

Versions in this module

v0

v0.0.6

Jun 16, 2024

Changes in this version

type DefaultField

+ func (df *DefaultField) SetID(id primitive.ObjectID)

type Document

+ SetID func(id primitive.ObjectID)

v0.0.5

May 17, 2024

Changes in this version

type DefaultField

+ func (df *DefaultField) IndexModels() []mongo.IndexModel

type Indexes

+ IndexModels func() []mongo.IndexModel

v0.0.4

Jan 11, 2024

Changes in this version

+ func IsDocumentExists(err error) (bool, error)

v0.0.3

Dec 12, 2023

Changes in this version

type DefaultField

+ ID primitive.ObjectID

+ func (df *DefaultField) DefaultID()

v0.0.2

Dec 11, 2023

v0.0.1

Nov 12, 2023

Changes in this version

+ func DeepCopy[T comparable](src T) T

+ func GetPointer[T any](value T) *T

+ func IndexesToModel(uniques []string, indexes []string) []mongo.IndexModel

+ func SplitSortField(field string) (key string, sort int32)

+ func StructToBSOND(v interface{}) (doc bson.D, err error)

+ type DefaultField struct

+ CreatedAt time.Time

+ Id primitive.ObjectID

+ UpdatedAt time.Time

+ func (df *DefaultField) AfterFind(ctx context.Context)

+ func (df *DefaultField) AfterInsert(ctx context.Context)

+ func (df *DefaultField) AfterUpdate(ctx context.Context)

+ func (df *DefaultField) BeforeInsert(ctx context.Context)

+ func (df *DefaultField) BeforeUpdate(ctx context.Context)

+ func (df *DefaultField) DefaultCreatedAt()

+ func (df *DefaultField) DefaultId()

+ func (df *DefaultField) DefaultUpdatedAt()

+ func (df *DefaultField) Indexes() []string

+ func (df *DefaultField) Uniques() []string

+ type DoTransactionFunc func(ctx context.Context, ...) (interface{}, error)

+ func DoTransaction(client *mongo.Client) DoTransactionFunc

+ type Document interface

+ AfterFind func(ctx context.Context)

+ AfterInsert func(ctx context.Context)

+ AfterUpdate func(ctx context.Context)

+ BeforeInsert func(ctx context.Context)

+ BeforeUpdate func(ctx context.Context)

+ type IRepo interface

+ Aggregate func(ctx context.Context, pipeline interface{}, res interface{}, ...) error

+ Clone func(opts ...*options.CollectionOptions) (*mongo.Collection, error)

+ Collection func() *mongo.Collection

+ Count func(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

+ CountDocuments func(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

+ DeleteMany func(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (deletedCount int64, err error)

+ DeleteOne func(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (deletedCount int64, err error)

+ Distinct func(ctx context.Context, fieldName string, filter interface{}, ...) ([]interface{}, error)

+ EnsureIndexes func(ctx context.Context, uniques []string, indexes []string) error

+ EnsureIndexesByModel func(ctx context.Context, model Indexes) error

+ EstimatedCount func(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)

+ EstimatedDocumentCount func(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)

+ Find func(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (docs []T, err error)

+ FindOne func(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) (doc T, err error)

+ FindOneAndDelete func(ctx context.Context, filter interface{}, ...) (doc T, err error)

+ FindOneAndUpdate func(ctx context.Context, filter interface{}, updateOrDoc interface{}, ...) (T, error)

+ Get func(ctx context.Context, id interface{}, opts ...*options.FindOneOptions) (T, error)

+ InsertMany func(ctx context.Context, docs []T, opts ...*options.InsertManyOptions) error

+ InsertOne func(ctx context.Context, doc T, opts ...*options.InsertOneOptions) (T, error)

+ Name func() string

+ UpdateByID func(ctx context.Context, id interface{}, updateOrDoc interface{}, ...) (modifiedCount int64, err error)

+ UpdateMany func(ctx context.Context, filter interface{}, updateOrDoc interface{}, ...) (modifiedCount int64, err error)

+ UpdateOne func(ctx context.Context, filter interface{}, updateOrDoc interface{}, ...) (modifiedCount int64, err error)

+ type Indexes interface

+ Indexes func() []string

+ Uniques func() []string

+ type Repo struct

+ func NewRepo[T Document](collection *mongo.Collection) *Repo[T]

+ func (r *Repo[T]) Aggregate(ctx context.Context, pipeline interface{}, res interface{}, ...) error

+ func (r *Repo[T]) Clone(opts ...*options.CollectionOptions) (*mongo.Collection, error)

+ func (r *Repo[T]) Collection() *mongo.Collection

+ func (r *Repo[T]) Count(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

+ func (r *Repo[T]) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

+ func (r *Repo[T]) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (deletedCount int64, err error)

+ func (r *Repo[T]) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (deletedCount int64, err error)

+ func (r *Repo[T]) Distinct(ctx context.Context, fieldName string, filter interface{}, ...) ([]interface{}, error)

+ func (r *Repo[T]) EnsureIndexes(ctx context.Context, uniques []string, indexes []string) error

+ func (r *Repo[T]) EnsureIndexesByModel(ctx context.Context, model Indexes) error

+ func (r *Repo[T]) EstimatedCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)

+ func (r *Repo[T]) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)

+ func (r *Repo[T]) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (docs []T, err error)

+ func (r *Repo[T]) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) (doc T, err error)

+ func (r *Repo[T]) FindOneAndDelete(ctx context.Context, filter interface{}, ...) (doc T, err error)

+ func (r *Repo[T]) FindOneAndUpdate(ctx context.Context, filter interface{}, updateOrDoc interface{}, ...) (T, error)

+ func (r *Repo[T]) Get(ctx context.Context, id interface{}, opts ...*options.FindOneOptions) (T, error)

+ func (r *Repo[T]) InsertMany(ctx context.Context, docs []T, opts ...*options.InsertManyOptions) error

+ func (r *Repo[T]) InsertOne(ctx context.Context, doc T, opts ...*options.InsertOneOptions) (T, error)

+ func (r *Repo[T]) Name() string

+ func (r *Repo[T]) UpdateByID(ctx context.Context, id interface{}, updateOrDoc interface{}, ...) (modifiedCount int64, err error)

+ func (r *Repo[T]) UpdateMany(ctx context.Context, filter interface{}, updateOrDoc interface{}, ...) (modifiedCount int64, err error)

+ func (r *Repo[T]) UpdateOne(ctx context.Context, filter interface{}, updateOrDoc interface{}, ...) (modifiedCount int64, err error)

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