mongodb

Documentation

Index

• Variables
• func NewMongoDB(cfg *MongoDbOptions) (*mongo.Client, error)
• func NewMongoHealthChecker(client *mongo.Client) health.Health
• func Paginate[T any](ctx context.Context, listQuery *utils.ListQuery, collection *mongo.Collection, ...) (*utils.ListResult[T], error)
• type MongoDbOptions

Variables

var (
	// Module provided to fxlog
	// https://uber-go.github.io/fx/modules.html
	Module = fx.Module(
		"mongofx",
		mongoProviders,
		mongoInvokes,
	)
)

Functions

func NewMongoDB

func NewMongoDB(cfg *MongoDbOptions) (*mongo.Client, error)

NewMongoDB Create new MongoDB client

func NewMongoHealthChecker

func NewMongoHealthChecker(client *mongo.Client) health.Health

func Paginate

func Paginate[T any](
	ctx context.Context,
	listQuery *utils.ListQuery,
	collection *mongo.Collection,
	filter interface{},
) (*utils.ListResult[T], error)

Types

type MongoDbOptions

type MongoDbOptions struct {
	Host     string `mapstructure:"host"`
	Port     int    `mapstructure:"port"`
	User     string `mapstructure:"user"`
	Password string `mapstructure:"password"`
	Database string `mapstructure:"database"`
	UseAuth  bool   `mapstructure:"useAuth"`
}