Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
Abstract wrapper to allow connection pools
type InitFunction func() (interface{}, error)
type ConnectionPoolWrapper struct {
size int
conn chan interface{}
Call the init function size times. If the init function fails during any call, then
the creation of the pool is considered a failure.
We call the same function size times to make sure each connection shares the same
func (p *ConnectionPoolWrapper) InitPool(size int, initfn InitFunction) error {
// Create a buffered channel allowing size senders
p.conn = make(chan interface{}, size)
for x := 0; x < size; x++ {
conn, err := initfn()
if err != nil {
return err
// If the init function succeeded, add the connection to the channel
p.conn <- conn
p.size = size
return nil
func (p *ConnectionPoolWrapper) GetConnection() interface{} {
return <-p.conn
func (p *ConnectionPoolWrapper) ReleaseConnection(conn interface{}) {
p.conn <- conn
var dbPool = &ConnectionPoolWrapper{}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment