pool

Documentation

Overview

Package pool contain an implementation of a connection pool to multiple database pointing to the same instance

Index

• type ConnectionPool
  • func NewConnectionPool(baseConnectionString string) *ConnectionPool
  • func (pool *ConnectionPool) Connection(dbname string) (*sql.DB, error)
  • func (pool *ConnectionPool) ShutdownConnections()

Types

type ConnectionPool

type ConnectionPool struct {
	// contains filtered or unexported fields
}

ConnectionPool is a repository of DB connections, pointing to the same instance given a base DSN without the "dbname" parameter

func NewConnectionPool

func NewConnectionPool(baseConnectionString string) *ConnectionPool

NewConnectionPool creates a new connectionMap of connections given the base connection string

func (*ConnectionPool) Connection

func (pool *ConnectionPool) Connection(dbname string) (*sql.DB, error)

Connection gets the connection for the given database

func (*ConnectionPool) ShutdownConnections

func (pool *ConnectionPool) ShutdownConnections()

ShutdownConnections closes every database connection