import (
  "gopkg.in/mgo.v2"
  "gopkg.in/mgo.v2/bson"
  "github.com/danteay/gomongo"
)

conf := gomongo.MongoOptions{
  Host:     "MONGO_HOST",
  User:     "MONGO_USER",
  Pass:     "MONGO_PASS",
  Dbas:     "MONGO_DBAS",
  Poolsize: 10,
  FailRate: 0.25,
  Universe: 4,
  TimeOut:  time.Second * 1,
}

pool, err := gomongo.InitPool(conf)

if err != nil {
  fmt.Println(err)
}

type Person struct {
    Name string
    Phone string
}

errQuery := pool.Execute(func(db *mgo.Database) error {
  return db.C("people").Insert(
    &Person{"Ale", "+55 53 8116 9639"},
    &Person{"Cla", "+55 53 8402 8510"},
  )
})

if errQuery != nil {
  fmt.Println(errQuery)
}

fmt.Println("==>> State: ", pool.State())