mongo

Documentation

Index

• func ConnectToMongo(dbConfig *DatabaseConfig) (*mongo.Database, error)
• func CreateUniqueIndexOnAFields(collection mongoORM.MongoCollectionDerived, indexModel bson.D) error
• func DisconnectFromMongo(ctx context.Context) error
• func GetMongoCollection(collectionName string, opts ...*options.CollectionOptions) mongoORM.MongoCollectionDerived
• func GetMongoDBInstance(dbConfig *DatabaseConfig) (*mongo.Database, error)
• type DatabaseConfig

Functions

func ConnectToMongo

func ConnectToMongo(dbConfig *DatabaseConfig) (*mongo.Database, error)

ConnectToMongo establishes a connection to MongoDB using the provided configuration.

func CreateUniqueIndexOnAFields

func CreateUniqueIndexOnAFields(collection mongoORM.MongoCollectionDerived, indexModel bson.D) error

func DisconnectFromMongo

func DisconnectFromMongo(ctx context.Context) error

DisconnectFromMongo disconnects from MongoDB.

func GetMongoCollection

func GetMongoCollection(collectionName string, opts ...*options.CollectionOptions) mongoORM.MongoCollectionDerived

func GetMongoDBInstance

func GetMongoDBInstance(dbConfig *DatabaseConfig) (*mongo.Database, error)

Types

type DatabaseConfig

type DatabaseConfig struct {
	Host      string `yaml:"host"`
	Port      int    `yaml:"port"`
	DBName    string `yaml:"dbname"`
	Username  string `yaml:"username"`
	Password  string `yaml:"password"`
	UserTable string `yaml:"usertable"`
	JobTable  string `yaml:"jobtable"`
}