mgo

package
v1.4.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 24, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StorageIndexMgo = tingyun3.StorageIndexMgo
)

Variables

This section is empty.

Functions

func WrapmgoCollectionCount

func WrapmgoCollectionCount(c *mgo.Collection) (int, error)

func WrapmgoCollectionCreate

func WrapmgoCollectionCreate(c *mgo.Collection, info *mgo.CollectionInfo) error

func WrapmgoCollectionDropCollection

func WrapmgoCollectionDropCollection(c *mgo.Collection) error

func WrapmgoCollectionDropIndex

func WrapmgoCollectionDropIndex(c *mgo.Collection, key ...string) error

func WrapmgoCollectionDropIndexName

func WrapmgoCollectionDropIndexName(c *mgo.Collection, name string) error

func WrapmgoCollectionEnsureIndex

func WrapmgoCollectionEnsureIndex(c *mgo.Collection, index mgo.Index) error

func WrapmgoCollectionEnsureIndexKey

func WrapmgoCollectionEnsureIndexKey(c *mgo.Collection, key ...string) error

func WrapmgoCollectionFind

func WrapmgoCollectionFind(c *mgo.Collection, query interface{}) *mgo.Query

func WrapmgoCollectionFindId

func WrapmgoCollectionFindId(c *mgo.Collection, query interface{}) *mgo.Query

func WrapmgoCollectionIndexes

func WrapmgoCollectionIndexes(c *mgo.Collection) ([]mgo.Index, error)

func WrapmgoCollectionInsert

func WrapmgoCollectionInsert(c *mgo.Collection, docs ...interface{}) error

func WrapmgoCollectionPipe

func WrapmgoCollectionPipe(c *mgo.Collection, pipeline interface{}) *mgo.Pipe

func WrapmgoCollectionRemove

func WrapmgoCollectionRemove(c *mgo.Collection, selector interface{}) error

func WrapmgoCollectionRemoveAll

func WrapmgoCollectionRemoveAll(c *mgo.Collection, selector interface{}) (*mgo.ChangeInfo, error)

func WrapmgoCollectionRemoveId

func WrapmgoCollectionRemoveId(c *mgo.Collection, id interface{}) error

func WrapmgoCollectionRepair

func WrapmgoCollectionRepair(c *mgo.Collection) *mgo.Iter

func WrapmgoCollectionUpdate

func WrapmgoCollectionUpdate(c *mgo.Collection, selector interface{}, update interface{}) error

func WrapmgoCollectionUpdateAll

func WrapmgoCollectionUpdateAll(c *mgo.Collection, selector interface{}, update interface{}) (*mgo.ChangeInfo, error)

func WrapmgoCollectionUpdateId

func WrapmgoCollectionUpdateId(c *mgo.Collection, id interface{}, update interface{}) error

func WrapmgoCollectionUpsert

func WrapmgoCollectionUpsert(c *mgo.Collection, selector interface{}, update interface{}) (*mgo.ChangeInfo, error)

func WrapmgoCollectionUpsertId

func WrapmgoCollectionUpsertId(c *mgo.Collection, id interface{}, update interface{}) (*mgo.ChangeInfo, error)

func WrapmgoDatabaseFindRef

func WrapmgoDatabaseFindRef(db *mgo.Database, ref *mgo.DBRef) *mgo.Query

func WrapmgoDialWithInfo

func WrapmgoDialWithInfo(info *mgo.DialInfo) (*mgo.Session, error)

func WrapmgoPipeAll

func WrapmgoPipeAll(q *mgo.Pipe, result interface{}) error

func WrapmgoPipeExplain

func WrapmgoPipeExplain(q *mgo.Pipe, result interface{}) error

func WrapmgoPipeIter

func WrapmgoPipeIter(q *mgo.Pipe) *mgo.Iter

func WrapmgoPipeOne

func WrapmgoPipeOne(q *mgo.Pipe, result interface{}) error

func WrapmgoQueryAll

func WrapmgoQueryAll(q *mgo.Query, result interface{}) error

func WrapmgoQueryApply

func WrapmgoQueryApply(q *mgo.Query, change mgo.Change, result interface{}) (*mgo.ChangeInfo, error)

func WrapmgoQueryCount

func WrapmgoQueryCount(q *mgo.Query) (int, error)

func WrapmgoQueryDistinct

func WrapmgoQueryDistinct(q *mgo.Query, key string, result interface{}) error

func WrapmgoQueryExplain

func WrapmgoQueryExplain(q *mgo.Query, result interface{}) error

func WrapmgoQueryFor

func WrapmgoQueryFor(q *mgo.Query, result interface{}, f func() error) error

func WrapmgoQueryIter

func WrapmgoQueryIter(q *mgo.Query) *mgo.Iter

func WrapmgoQueryMapReduce

func WrapmgoQueryMapReduce(q *mgo.Query, job *mgo.MapReduce, result interface{}) (*mgo.MapReduceInfo, error)

func WrapmgoQueryOne

func WrapmgoQueryOne(q *mgo.Query, result interface{}) error

func WrapmgoQueryTail

func WrapmgoQueryTail(q *mgo.Query, timeout time.Duration) *mgo.Iter

func WrapmgoSessionClose

func WrapmgoSessionClose(session *mgo.Session)

func WrapmgoSessionFindRef

func WrapmgoSessionFindRef(s *mgo.Session, ref *mgo.DBRef) *mgo.Query

func WrapmgocopySession

func WrapmgocopySession(session *mgo.Session, keepCreds bool) *mgo.Session

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL