db

Documentation

Index

• func MongoDb() (*mongo.Client, error)
• func MongoDbFind[T, W interface{}](filter W, doing func(*mongo.Database) *mongo.Collection) T
• func MongoDbFindAllCollection[T interface{}, W interface{}](filter W, doing func(*mongo.Database) *mongo.Collection) []T
• func MongoDbFindAllFromCollection[T interface{}, W interface{}](coll *mongo.Collection, filter W) []T
• func MongoDbFindFromCollection[T, W interface{}](filter W, coll *mongo.Collection) (T, bool)
• func MongoDbPage[T interface{}, W interface{}](req dto.PageReq[W], doing func(*mongo.Database) *mongo.Collection) dto.PageRes[T]
• func OnMongoConnection[T interface{}](doing func(*mongo.Database) T) T
• type MongoTransaction
  • func NewMongoTransaction[T interface{}](pesimisticLock bool) *MongoTransaction[T]
  • func (m *MongoTransaction[T]) Transaction(doing func(*mongo.Database) T) T

Functions

func MongoDb

func MongoDb() (*mongo.Client, error)

func MongoDbFind

func MongoDbFind[T, W interface{}](filter W, doing func(*mongo.Database) *mongo.Collection) T

func MongoDbFindAllCollection

func MongoDbFindAllCollection[T interface{}, W interface{}](filter W, doing func(*mongo.Database) *mongo.Collection) []T

func MongoDbFindAllFromCollection

func MongoDbFindAllFromCollection[T interface{}, W interface{}](coll *mongo.Collection, filter W) []T

func MongoDbFindFromCollection

func MongoDbFindFromCollection[T, W interface{}](filter W, coll *mongo.Collection) (T, bool)

func MongoDbPage

func MongoDbPage[T interface{}, W interface{}](req dto.PageReq[W], doing func(*mongo.Database) *mongo.Collection) dto.PageRes[T]

func OnMongoConnection

func OnMongoConnection[T interface{}](doing func(*mongo.Database) T) T

Types

type MongoTransaction

type MongoTransaction[T interface{}] struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMongoTransaction

func NewMongoTransaction[T interface{}](pesimisticLock bool) *MongoTransaction[T]

func (*MongoTransaction[T]) Transaction

func (m *MongoTransaction[T]) Transaction(doing func(*mongo.Database) T) T