internal

Dec 22, 2018

Changes in this version

+ type MongoCollection struct

+ func (_m *MongoCollection) Bulk() *mgo.Bulk

+ func (_m *MongoCollection) Count() (int, error)

+ func (_m *MongoCollection) Create(info *mgo.CollectionInfo) error

+ func (_m *MongoCollection) DropAllIndexes() error

+ func (_m *MongoCollection) DropCollection() error

+ func (_m *MongoCollection) DropIndex(key ...string) error

+ func (_m *MongoCollection) DropIndexName(name string) error

+ func (_m *MongoCollection) EnsureIndex(index mgo.Index) error

+ func (_m *MongoCollection) EnsureIndexKey(key ...string) error

+ func (_m *MongoCollection) Find(query interface{}) *mgo.Query

+ func (_m *MongoCollection) FindId(id interface{}) *mgo.Query

+ func (_m *MongoCollection) Indexes() ([]mgo.Index, error)

+ func (_m *MongoCollection) Insert(docs ...interface{}) error

+ func (_m *MongoCollection) NewIter(session *mgo.Session, firstBatch []bson.Raw, cursorID int64, err error) *mgo.Iter

+ func (_m *MongoCollection) Pipe(pipeline interface{}) *mgo.Pipe

+ func (_m *MongoCollection) Remove(selector interface{}) error

+ func (_m *MongoCollection) RemoveAll(selector interface{}) (*mgo.ChangeInfo, error)

+ func (_m *MongoCollection) RemoveId(id interface{}) error

+ func (_m *MongoCollection) Repair() *mgo.Iter

+ func (_m *MongoCollection) Update(selector interface{}, update interface{}) error

+ func (_m *MongoCollection) UpdateAll(selector interface{}, update interface{}) (*mgo.ChangeInfo, error)

+ func (_m *MongoCollection) UpdateId(id interface{}, update interface{}) error

+ func (_m *MongoCollection) Upsert(selector interface{}, update interface{}) (*mgo.ChangeInfo, error)

+ func (_m *MongoCollection) UpsertId(id interface{}, update interface{}) (*mgo.ChangeInfo, error)

+ func (_m *MongoCollection) Watch(pipeline interface{}, options mgo.ChangeStreamOptions) (*mgo.ChangeStream, error)

+ func (_m *MongoCollection) With(s *mgo.Session) *mgo.Collection

+ type MongoQuery struct

+ func (_m *MongoQuery) All(result interface{}) error

+ func (_m *MongoQuery) Apply(change mgo.Change, result interface{}) (*mgo.ChangeInfo, error)

+ func (_m *MongoQuery) Batch(n int) *mgo.Query

+ func (_m *MongoQuery) Collation(collation *mgo.Collation) *mgo.Query

+ func (_m *MongoQuery) Comment(comment string) *mgo.Query

+ func (_m *MongoQuery) Count() (int, error)

+ func (_m *MongoQuery) Distinct(key string, result interface{}) error

+ func (_m *MongoQuery) Explain(result interface{}) error

+ func (_m *MongoQuery) For(result interface{}, f func() error) error

+ func (_m *MongoQuery) Hint(indexKey ...string) *mgo.Query

+ func (_m *MongoQuery) Iter() *mgo.Iter

+ func (_m *MongoQuery) Limit(n int) *mgo.Query

+ func (_m *MongoQuery) LogReplay() *mgo.Query

+ func (_m *MongoQuery) MapReduce(job *mgo.MapReduce, result interface{}) (*mgo.MapReduceInfo, error)

+ func (_m *MongoQuery) One(result interface{}) error

+ func (_m *MongoQuery) Prefetch(p float64) *mgo.Query

+ func (_m *MongoQuery) Select(selector interface{}) *mgo.Query

+ func (_m *MongoQuery) SetMaxScan(n int) *mgo.Query

+ func (_m *MongoQuery) SetMaxTime(d time.Duration) *mgo.Query

+ func (_m *MongoQuery) Skip(n int) *mgo.Query

+ func (_m *MongoQuery) Snapshot() *mgo.Query

+ func (_m *MongoQuery) Sort(fields ...string) *mgo.Query

+ func (_m *MongoQuery) Tail(timeout time.Duration) *mgo.Iter

+ type MongoSession struct

+ func (_m *MongoSession) BuildInfo() (mgo.BuildInfo, error)

+ func (_m *MongoSession) Clone() *mgo.Session

+ func (_m *MongoSession) Close()

+ func (_m *MongoSession) Copy() *mgo.Session

+ func (_m *MongoSession) DB(name string) *mgo.Database

+ func (_m *MongoSession) DatabaseNames() ([]string, error)

+ func (_m *MongoSession) EnsureSafe(safe *mgo.Safe)

+ func (_m *MongoSession) FindRef(ref *mgo.DBRef) *mgo.Query

+ func (_m *MongoSession) Fsync(async bool) error

+ func (_m *MongoSession) FsyncLock() error

+ func (_m *MongoSession) FsyncUnlock() error

+ func (_m *MongoSession) LiveServers() []string

+ func (_m *MongoSession) Login(cred *mgo.Credential) error

+ func (_m *MongoSession) LogoutAll()

+ func (_m *MongoSession) Mode() mgo.Mode

+ func (_m *MongoSession) New() *mgo.Session

+ func (_m *MongoSession) Ping() error

+ func (_m *MongoSession) Refresh()

+ func (_m *MongoSession) ResetIndexCache()

+ func (_m *MongoSession) Run(cmd interface{}, result interface{}) error

+ func (_m *MongoSession) Safe() *mgo.Safe

+ func (_m *MongoSession) SelectServers(tags ...bson.D)

+ func (_m *MongoSession) SetBatch(n int)

+ func (_m *MongoSession) SetBypassValidation(bypass bool)

+ func (_m *MongoSession) SetCursorTimeout(d time.Duration)

+ func (_m *MongoSession) SetMode(consistency mgo.Mode, refresh bool)

+ func (_m *MongoSession) SetPoolLimit(limit int)

+ func (_m *MongoSession) SetPoolTimeout(timeout time.Duration)

+ func (_m *MongoSession) SetPrefetch(p float64)

+ func (_m *MongoSession) SetSafe(safe *mgo.Safe)

+ func (_m *MongoSession) SetSocketTimeout(d time.Duration)

+ func (_m *MongoSession) SetSyncTimeout(d time.Duration)

+ type SQLDatabase struct

+ func (_m *SQLDatabase) Begin() (*sql.Tx, error)

+ func (_m *SQLDatabase) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ func (_m *SQLDatabase) Close() error

+ func (_m *SQLDatabase) Conn(ctx context.Context) (*sql.Conn, error)

+ func (_m *SQLDatabase) Driver() driver.Driver

+ func (_m *SQLDatabase) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (_m *SQLDatabase) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (_m *SQLDatabase) Ping() error

+ func (_m *SQLDatabase) PingContext(ctx context.Context) error

+ func (_m *SQLDatabase) Prepare(query string) (*sql.Stmt, error)

+ func (_m *SQLDatabase) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

+ func (_m *SQLDatabase) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (_m *SQLDatabase) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (_m *SQLDatabase) QueryRow(query string, args ...interface{}) *sql.Row

+ func (_m *SQLDatabase) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (_m *SQLDatabase) SetConnMaxLifetime(d time.Duration)

+ func (_m *SQLDatabase) SetMaxIdleConns(n int)

+ func (_m *SQLDatabase) SetMaxOpenConns(n int)

+ func (_m *SQLDatabase) Stats() sql.DBStats

+ type SQLRows struct

+ func (_m *SQLRows) Close() error

+ func (_m *SQLRows) ColumnTypes() ([]*sql.ColumnType, error)

+ func (_m *SQLRows) Columns() ([]string, error)

+ func (_m *SQLRows) Err() error

+ func (_m *SQLRows) Next() bool

+ func (_m *SQLRows) NextResultSet() bool

+ func (_m *SQLRows) Scan(dest ...interface{}) error

+ func (_m *SQLRows) SetLimit(n int)