connection

Documentation

Index

• func AddDatabaseToPool(name string, DB *sqlx.DB)
• func Get() (*sqlx.DB, error)
• func GetDatabase() string
• func GetFromPool(dbName string) (*sqlx.DB, error)
• func GetURI(DBName string) string
• func MustGet() *sqlx.DB
• func SetDatabase(name string)
• type Pool
  • func GetPool() *Pool

Functions

func AddDatabaseToPool

func AddDatabaseToPool(name string, DB *sqlx.DB)

AddDatabaseToPool add connection to pool

func Get

func Get() (*sqlx.DB, error)

Get get postgres connection

func GetDatabase

func GetDatabase() string

GetDatabase get current database in use

func GetFromPool

func GetFromPool(dbName string) (*sqlx.DB, error)

GetFromPool tries to get the db name from the db pool will return error if not found

func GetURI

func GetURI(DBName string) string

GetURI postgres connection URI

func MustGet

func MustGet() *sqlx.DB

MustGet get postgres connection

func SetDatabase

func SetDatabase(name string)

SetDatabase set current database in use

Types

type Pool

type Pool struct {
	Mtx *sync.Mutex
	DB  map[string]*sqlx.DB
}

Pool struct

func GetPool

func GetPool() *Pool

GetPool of connection