mongo

Documentation

Overview

Package mongo provides mongo connectivity support.

Index

• func CloseSession(goRoutine string, mongoSession *mgo.Session)
• func CopySession(goRoutine string) (*mgo.Session, error)
• func GetCollection(mongoSession *mgo.Session, collectionName string) (collection *mgo.Collection)
• func GetSession(goRoutine string) (*mgo.Session, error)
• func Shutdown(goRoutine string) error
• func Startup(goRoutine string) error

Functions

func CloseSession

func CloseSession(goRoutine string, mongoSession *mgo.Session)

CloseSession puts the connection back into the pool.

func CopySession

func CopySession(goRoutine string) (*mgo.Session, error)

CopySession get a new connection based on an existing connection.

func GetCollection

func GetCollection(mongoSession *mgo.Session, collectionName string) (collection *mgo.Collection)

GetCollection returns a reference to a collection for the specified database and collection name.

func GetSession

func GetSession(goRoutine string) (*mgo.Session, error)

GetSession grabs a connection from the pool for use.

func Shutdown

func Shutdown(goRoutine string) error

Shutdown systematically brings the manager down gracefully.

func Startup

func Startup(goRoutine string) error

Startup brings the manager to a running state.