Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExecuteWithCollection ¶
func ExecuteWithCollection(database, collection string, f func(*mgo.Collection) error) error
func GetSession ¶
func LoadSessions ¶
func LoadSessions(dataSourceConfig map[string]*config.DataSourceConfiguration)
Types ¶
type MgoConnection ¶
func (*MgoConnection) FindAll ¶
func (conn *MgoConnection) FindAll(m bson.M, d interface{})
func (*MgoConnection) FindOne ¶
func (conn *MgoConnection) FindOne(m bson.M, d interface{})
func (*MgoConnection) Insert ¶
func (conn *MgoConnection) Insert(d interface{})
func (conn *MgoConnection) Update(selector interface{}, d interface{}) {
ExecuteWithCollection(conn.Database, conn.Collection, func(c *mgo.Collection) error { return c.Update(selector, d) })
}
func (conn *MgoConnection) UpdateAll(selector interface{}, d interface{}) {
ExecuteWithCollection(conn.Database, conn.Collection, func(c *mgo.Collection) error { return c.UpdateAll(selector, d) })
}
func (conn *MgoConnection) Upsert(selector interface{}, d interface{}) {
ExecuteWithCollection(conn.Database, conn.Collection, func(c *mgo.Collection) error { return c.Upsert(selector, d) })
}
Source Files
Click to show internal directories.
Click to hide internal directories.