Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrWaitTimeout = errors.New("mgo: wait timeout")
ErrWaitTimeout 获取连接池对象超时
Functions ¶
func MigrateIndex ¶
func MigrateIndex(ctx context.Context, collection *mongo.Collection, version int, idxs []IdxKey) ([]string, error)
MigrateIndex create new version index and delete old version index
Types ¶
type FieldDesribe ¶
FieldDesribe field of index
type SessionManager ¶
SessionManager session管理器
func NewSessionManager ¶
func NewSessionManager(ctx context.Context, maxIdleConns, maxOpenConns int, waitTimeout time.Duration, opts ...*options.ClientOptions) (SessionManager, error)
NewSessionManager 初始化Session管理器实例 maxIdleConns 最大空闲连接数 waitTimeout 等待可用连接超时时间
type URI ¶
type URI struct { //Hosts 主机列表 Hosts []string //Database 数据库 Database string //AuthDB 验证数据库 AuthDB string //Login 登陆账号 Login string //Passwd 登陆密码 Passwd string //ReplicaSet 复制分片 ReplicaSet string }
ConnectionString Mongo连接信息 mongodb://[username:password@]host1[:port1][,...hostN[:portN]]][/[database][?options]]
Click to show internal directories.
Click to hide internal directories.