database

Documentation

Index

• func ConnectMongoDB(ctx context.Context, dsn string) *mongo.Database
• func ConnectRedis(dsn string) *redis.Pool
• func ConnectSQLDatabase(dsn string) *sql.DB
• func InitMongoDB(ctx context.Context) interfaces.MongoDatabase
• func InitRedis() interfaces.RedisPool
• func InitSQLDatabase() interfaces.SQLDatabase

Functions

func ConnectMongoDB

func ConnectMongoDB(ctx context.Context, dsn string) *mongo.Database

ConnectMongoDB connect to mongodb with dsn

func ConnectRedis

func ConnectRedis(dsn string) *redis.Pool

ConnectRedis connect to redis with dsn

func ConnectSQLDatabase

func ConnectSQLDatabase(dsn string) *sql.DB

ConnectSQLDatabase connect to sql database with dsn

func InitMongoDB

func InitMongoDB(ctx context.Context) interfaces.MongoDatabase

InitMongoDB return mongo db read & write instance from environment: MONGODB_HOST_WRITE, MONGODB_HOST_READ

func InitRedis

func InitRedis() interfaces.RedisPool

InitRedis connection from environment: REDIS_READ_DSN, REDIS_WRITE_DSN

func InitSQLDatabase

func InitSQLDatabase() interfaces.SQLDatabase

InitSQLDatabase return sql db read & write instance from environment: SQL_DB_READ_DSN, SQL_DB_WRITE_DSN