Versions in this module Expand all Collapse all v1 v1.3.1 Mar 5, 2019 v1.3.0 Mar 14, 2018 Changes in this version + const MaxLen + var MgoPool = pool.ClassicPool(config.MGO_CONN_CAP, config.MGO_CONN_CAP / 5, func() (pool.Src, error) { ... }, ...) + func Call(fn func(pool.Src) error) error + func Close() + func CollectionNames(dbname string) (names []string, err error) + func DatabaseNames() (names []string, err error) + func Error() error + func Len() int + func Mgo(resultPtr interface{}, operate string, option map[string]interface{}) error + func Refresh() + type Count struct + Collection string + Database string + Query map[string]interface{} + func (self *Count) Exec(resultPtr interface{}) (err error) + type Find struct + Collection string + Database string + Limit int + Query map[string]interface{} + Select interface{} + Skip int + Sort []string + func (self *Find) Exec(resultPtr interface{}) (err error) + type Insert struct + Collection string + Database string + Docs []map[string]interface{} + func (self *Insert) Exec(resultPtr interface{}) (err error) + type List struct + Dbs []string + func (self *List) Exec(resultPtr interface{}) (err error) + type MgoSrc struct + func (*MgoSrc) Reset() + func (self *MgoSrc) Close() + func (self *MgoSrc) Usable() bool + type Operator interface + Exec func(resultPtr interface{}) (err error) + type Remove struct + Collection string + Database string + Selector map[string]interface{} + func (self *Remove) Exec(_ interface{}) error + type Update struct + Change map[string]interface{} + Collection string + Database string + Selector map[string]interface{} + func (self *Update) Exec(_ interface{}) error + type UpdateAll struct + Change map[string]interface{} + Collection string + Database string + Selector map[string]interface{} + func (self *UpdateAll) Exec(resultPtr interface{}) (err error) + type Upsert struct + Change map[string]interface{} + Collection string + Database string + Selector map[string]interface{} + func (self *Upsert) Exec(resultPtr interface{}) (err error)