odm

Documentation

Index

• func GetClient() *mongo.Client
• type BootRepository
• type CollectionInterface
• type Config
  • func NewConfig(options ...Option) *Config
• type DbModel
• type DefaultTimer
  • func (d DefaultTimer) Now() int64
• type Option
  • func WithClient(client *mongo.Client) Option
  • func WithCollectionName(collectionName string) Option
  • func WithDatabase(database string) Option
• type Timer
• type UnimplementedBootRepository
  • func NewUnimplementedBootRepository[T any](options ...Option) UnimplementedBootRepository[T]
  • func (r *UnimplementedBootRepository[T]) Aggregate(pipeline mongo.Pipeline) (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

Functions

func GetClient

func GetClient() *mongo.Client

Types

type BootRepository

type BootRepository[T any] interface {
	Save(model DbModel) chan error
	FindOneById(id string) (chan *T, chan error)
	IsExistsById(id string) bool
	CountDocuments(filters bson.M) (chan int64, chan error)
	Distinct(fieldName string, filters bson.D, serverMaxTime time.Duration) (chan []interface{}, chan error)
	FindOne(filters bson.M) (chan *T, chan error)
	Find(filters bson.M, sort bson.D, limit, skip int64) (chan []T, chan error)
	DeleteById(id string) chan error
	DeleteOne(filters bson.M) chan error
	GetModel(proto interface{}) *T
	Aggregate(pipeline mongo.Pipeline) (chan []T, chan error)
}

type CollectionInterface

type CollectionInterface interface {
	UpdateOne(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)
	FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *mongo.SingleResult
	Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (cur *mongo.Cursor, err error)
	DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
	Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error)
	CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)
	Distinct(ctx context.Context, fieldName string, filter interface{}, opts ...*options.DistinctOptions) ([]interface{}, error)
}

type Config

type Config struct {
	Database       string
	CollectionName string
	Client         *mongo.Client
}

func NewConfig

func NewConfig(options ...Option) *Config

type DbModel

type DbModel interface {
	Id() string
}

type DefaultTimer

type DefaultTimer struct{}

func (DefaultTimer) Now

func (d DefaultTimer) Now() int64

type Option

type Option func(*Config)

func WithClient

func WithClient(client *mongo.Client) Option

func WithCollectionName

func WithCollectionName(collectionName string) Option

func WithDatabase

func WithDatabase(database string) Option

type Timer

type Timer interface {
	Now() int64
}

type UnimplementedBootRepository

type UnimplementedBootRepository[T any] struct {
	// contains filtered or unexported fields
}

func NewUnimplementedBootRepository

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

func (*UnimplementedBootRepository[T]) Aggregate

func (r *UnimplementedBootRepository[T]) Aggregate(pipeline mongo.Pipeline) (chan []T, chan error)

func (*UnimplementedBootRepository[T]) CountDocuments

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

Finds documents count on filters.

func (*UnimplementedBootRepository[T]) DeleteById

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

func (*UnimplementedBootRepository[T]) DeleteOne

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

func (*UnimplementedBootRepository[T]) Distinct

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

Finds all unique values for a field

func (*UnimplementedBootRepository[T]) Find

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

func (*UnimplementedBootRepository[T]) FindOne

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

Finds one object based on filters.

func (*UnimplementedBootRepository[T]) FindOneById

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

Finds one object based on Id.

func (*UnimplementedBootRepository[T]) GetModel

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

Gets an instance of model from proto or othe object.

func (*UnimplementedBootRepository[T]) IsExistsById

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

checks if a record exists by id. Synchronous becuase it is expected to be very light-weighted without deserialization etc.

func (*UnimplementedBootRepository[T]) Save

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