mongo

Documentation

Index

• Variables
• type Attr
  • func (a Attr) GetExpression() bson.M
• type Criteria
  • func ConvertToMongoCriteria(c criteria.Criteria, subject entity.Entity) (Criteria, error)
• type MongoAnd
  • func (a MongoAnd) GetExpression() bson.M
• type MongoNot
  • func (n MongoNot) GetExpression() bson.M
• type MongoOr
  • func (o MongoOr) GetExpression() bson.M
• type Repository
  • func NewMongoRepository[K entity.Entity](collection *mongo.Collection) *Repository[K]
  • func NewMongoRepositoryWithOpts[K entity.Entity](collection *mongo.Collection, logger *logrus.Entry) *Repository[K]
  • func (r *Repository[K]) Create(ctx context.Context, e K) (K, error)
  • func (r *Repository[K]) Delete(ctx context.Context, entity K) error
  • func (r *Repository[K]) Match(ctx context.Context, c criteria.Criteria) ([]K, error)
  • func (r *Repository[K]) MatchOne(ctx context.Context, c criteria.Criteria) (k K, err error)
  • func (r *Repository[K]) Read(ctx context.Context, id entity.Id) (e K, err error)
  • func (r *Repository[K]) ReadAll(ctx context.Context) ([]K, error)
  • func (r *Repository[K]) Start(ctx context.Context, onBootstrap func(ctx context.Context) error) error
  • func (r *Repository[K]) Update(ctx context.Context, entity K) error

Variables

var ComparisonConversion = map[criteria.Comparator]string{
	criteria.ComparisonEq:  "$eq",
	criteria.ComparisonGt:  "$gt",
	criteria.ComparisonGte: "$gte",
	criteria.ComparisonLt:  "$lt",
	criteria.ComparisonLte: "$lte",
	criteria.ComparisonNe:  "$ne",
}

Types

type Attr

type Attr struct {
	Name       string
	Value      any
	Comparison criteria.Comparator
}

func (Attr) GetExpression

func (a Attr) GetExpression() bson.M

type Criteria

type Criteria interface {
	GetExpression() bson.M
}

func ConvertToMongoCriteria

func ConvertToMongoCriteria(c criteria.Criteria, subject entity.Entity) (Criteria, error)

type MongoAnd

type MongoAnd struct {
	Operands []Criteria
}

func (MongoAnd) GetExpression

func (a MongoAnd) GetExpression() bson.M

type MongoNot

type MongoNot struct {
	Operand Criteria
}

func (MongoNot) GetExpression

func (n MongoNot) GetExpression() bson.M

type MongoOr

type MongoOr struct {
	Operands []Criteria
}

func (MongoOr) GetExpression

func (o MongoOr) GetExpression() bson.M

type Repository

type Repository[K entity.Entity] struct {
	Collection *mongo.Collection
	// contains filtered or unexported fields
}

func NewMongoRepository

func NewMongoRepository[K entity.Entity](collection *mongo.Collection) *Repository[K]

func NewMongoRepositoryWithOpts

func NewMongoRepositoryWithOpts[K entity.Entity](collection *mongo.Collection, logger *logrus.Entry) *Repository[K]

func (*Repository[K]) Create

func (r *Repository[K]) Create(ctx context.Context, e K) (K, error)

func (*Repository[K]) Delete

func (r *Repository[K]) Delete(ctx context.Context, entity K) error

func (*Repository[K]) Match

func (r *Repository[K]) Match(ctx context.Context, c criteria.Criteria) ([]K, error)

func (*Repository[K]) MatchOne

func (r *Repository[K]) MatchOne(ctx context.Context, c criteria.Criteria) (k K, err error)

func (*Repository[K]) Read

func (r *Repository[K]) Read(ctx context.Context, id entity.Id) (e K, err error)

func (*Repository[K]) ReadAll

func (r *Repository[K]) ReadAll(ctx context.Context) ([]K, error)

func (*Repository[K]) Start

func (r *Repository[K]) Start(ctx context.Context, onBootstrap func(ctx context.Context) error) error

func (*Repository[K]) Update

func (r *Repository[K]) Update(ctx context.Context, entity K) error