mongo

Documentation

Index

• func Connect(ctx context.Context, baseLogger model.Logger, uri, database string) *mongo.Database
• func NewOrderRepository(baseLogger model.Logger, db *mongo.Database, timeout time.Duration, ...) model.OrderRepository
• func NewProductRepository(baseLogger model.Logger, db *mongo.Database, timeout time.Duration) model.ProductRepository
• type FilterBuilder
  • func NewFilterBuilder() *FilterBuilder
  • func (b *FilterBuilder) AppendAndOpFilter(filter bson.M) *FilterBuilder
  • func (b *FilterBuilder) AppendAndOpFilterIf(condition bool, filter bson.M) *FilterBuilder
  • func (b *FilterBuilder) AppendOperationFilter(op string, filter bson.M) *FilterBuilder
  • func (b *FilterBuilder) Build() bson.M

Functions

func Connect

func Connect(ctx context.Context, baseLogger model.Logger, uri, database string) *mongo.Database

func NewOrderRepository

func NewOrderRepository(baseLogger model.Logger, db *mongo.Database, timeout time.Duration, database string) model.OrderRepository

func NewProductRepository

func NewProductRepository(baseLogger model.Logger, db *mongo.Database, timeout time.Duration) model.ProductRepository

Types

type FilterBuilder

type FilterBuilder struct {
	// contains filtered or unexported fields
}

func NewFilterBuilder

func NewFilterBuilder() *FilterBuilder

func (*FilterBuilder) AppendAndOpFilter

func (b *FilterBuilder) AppendAndOpFilter(filter bson.M) *FilterBuilder

func (*FilterBuilder) AppendAndOpFilterIf

func (b *FilterBuilder) AppendAndOpFilterIf(condition bool, filter bson.M) *FilterBuilder

func (*FilterBuilder) AppendOperationFilter

func (b *FilterBuilder) AppendOperationFilter(op string, filter bson.M) *FilterBuilder

func (*FilterBuilder) Build

func (b *FilterBuilder) Build() bson.M