database

Documentation

Index

• func ConnectMongoDB(ctx context.Context, dsn string, opts ...*options.ClientOptions) *mongo.Database
• func ConnectRedis(dsn string, opts ...RedisPoolOption) *redis.Pool
• func ConnectSQLDatabase(dsn string) *sql.DB
• func InitMongoDB(ctx context.Context, opts ...*options.ClientOptions) interfaces.MongoDatabase
• func InitRedis(opts ...RedisPoolOption) interfaces.RedisPool
• func InitSQLDatabase() interfaces.SQLDatabase
• func ParseSQLDSN(source string) (driverName string, dsn string)
• type RedisPoolOption
  • func RedisPoolOptionSetIdleTimeout(dur time.Duration) RedisPoolOption
  • func RedisPoolOptionSetMaxActive(count int) RedisPoolOption
  • func RedisPoolOptionSetMaxConnLifetime(dur time.Duration) RedisPoolOption
  • func RedisPoolOptionSetMaxIdle(count int) RedisPoolOption

Functions

func ConnectMongoDB

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

ConnectMongoDB connect to mongodb with dsn

func ConnectRedis

func ConnectRedis(dsn string, opts ...RedisPoolOption) *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, opts ...*options.ClientOptions) interfaces.MongoDatabase

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

func InitRedis

func InitRedis(opts ...RedisPoolOption) 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

func ParseSQLDSN

func ParseSQLDSN(source string) (driverName string, dsn string)

ParseSQLDSN parse sql dsn

Types

type RedisPoolOption

type RedisPoolOption func(pool *redis.Pool)

func RedisPoolOptionSetIdleTimeout

func RedisPoolOptionSetIdleTimeout(dur time.Duration) RedisPoolOption

func RedisPoolOptionSetMaxActive

func RedisPoolOptionSetMaxActive(count int) RedisPoolOption

func RedisPoolOptionSetMaxConnLifetime

func RedisPoolOptionSetMaxConnLifetime(dur time.Duration) RedisPoolOption

func RedisPoolOptionSetMaxIdle

func RedisPoolOptionSetMaxIdle(count int) RedisPoolOption