odm

May 25, 2024

Changes in this version

+ type CollectionInterface interface

+ Aggregate func(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error)

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

+ DeleteOne func(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

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

+ Find func(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (cur *mongo.Cursor, err error)

+ FindOne func(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *mongo.SingleResult

+ UpdateOne func(ctx context.Context, filter interface{}, update interface{}, ...) (*mongo.UpdateResult, error)

+ type Config struct

+ Client *mongo.Client

+ CollectionName string

+ Database string

+ func NewConfig(options ...Option) *Config

+ type DefaultTimer struct

+ func (d DefaultTimer) Now() int64

+ type Option func(*Config)

+ func WithClient(client *mongo.Client) Option

+ func WithCollectionName(collectionName string) Option

+ func WithDatabase(database string) Option

+ type Timer interface

+ Now func() int64

type UnimplementedBootRepository

+ func NewUnimplementedBootRepository[T any](options ...Option) UnimplementedBootRepository[T]

Feb 9, 2024

Changes in this version

+ type BootRepository interface

+ Aggregate func(pipeline bson.A) (chan []T, chan error)

+ CountDocuments func(filters bson.M) (chan int64, chan error)

+ DeleteById func(id string) chan error

+ DeleteOne func(filters bson.M) chan error

+ Distinct func(fieldName string, filters bson.D, serverMaxTime time.Duration) (chan []interface{}, chan error)

+ Find func(filters bson.M, sort bson.D, limit, skip int64) (chan []T, chan error)

+ FindOne func(filters bson.M) (chan *T, chan error)

+ FindOneById func(id string) (chan *T, chan error)

+ GetModel func(proto interface{}) *T

+ IsExistsById func(id string) bool

+ Save func(model DbModel) chan error

+ type UnimplementedBootRepository struct

+ CollectionName string

+ Database string

+ func (r *UnimplementedBootRepository[T]) Aggregate(pipeline bson.A) (chan []T, chan error)

+ func (r *UnimplementedBootRepository[T]) CountDocuments(filters bson.M) (chan int64, chan error)

+ func (r *UnimplementedBootRepository[T]) DeleteById(id string) chan error

+ func (r *UnimplementedBootRepository[T]) DeleteOne(filters bson.M) chan error

+ func (r *UnimplementedBootRepository[T]) Distinct(fieldName string, filters bson.D, serverMaxTime time.Duration) (chan []interface{}, chan error)

+ func (r *UnimplementedBootRepository[T]) Find(filters bson.M, sort bson.D, limit, skip int64) (chan []T, chan error)

+ func (r *UnimplementedBootRepository[T]) FindOne(filters bson.M) (chan *T, chan error)

+ func (r *UnimplementedBootRepository[T]) FindOneById(id string) (chan *T, chan error)

+ func (r *UnimplementedBootRepository[T]) GetModel(proto interface{}) *T

+ func (r *UnimplementedBootRepository[T]) IsExistsById(id string) bool

+ func (r *UnimplementedBootRepository[T]) Save(model DbModel) chan error

Mar 11, 2023

Changes in this version

type AbstractRepository

+ func (r *AbstractRepository[T]) CountDocuments(filters bson.M) (chan int64, chan error)

+ func (r *AbstractRepository[T]) Distinct(fieldName string, filters bson.D, serverMaxTime time.Duration) (chan []interface{}, chan error)

Jun 15, 2021

Changes in this version

type AbstractRepository

+ func (r *AbstractRepository) DeleteById(id string) chan error

+ func (r *AbstractRepository) DeleteOne(filters bson.M) chan error

Jun 15, 2021

Changes in this version

type AbstractRepository

+ func (r *AbstractRepository) IsExistsById(id string) bool

Jun 13, 2021

Changes in this version

+ func GetClient() *mongo.Client

type AbstractRepository

+ Database string

Jun 13, 2021

Changes in this version

+ func GetDatabase() *mongo.Database

+ type AbstractRepository struct

+ CollectionName string

+ Model reflect.Type

+ func (r *AbstractRepository) Find(filters bson.M, sort bson.D, limit, skip int64) chan Result

+ func (r *AbstractRepository) FindOne(filters bson.M) chan Result

+ func (r *AbstractRepository) FindOneById(id string) chan Result

+ func (r *AbstractRepository) GetModel(proto interface{}) interface{}

+ func (r *AbstractRepository) Save(model DbModel) chan error

+ type DbModel interface

+ Id func() string

+ type Result struct

+ Err error

+ Value interface{}