golang mgo_go

Posted 2021-05-24

func Init(addr string) {
	var err error
	session, err = mgo.DialWithTimeout(addr, 10*time.Second)
	if err == nil {
		session.SetMode(mgo.Monotonic, true)
	}
	// 连接池数量
	//session.SetPoolLimit(64)
}
func withCollection(collection string, handle func(*mgo.Collection) error) error {
	if session == nil {
		fmt.Println("error: mongo session is nil")
		return errors.New("mongo session is nil")
	}
	conn := session.Copy()
	defer conn.Close()
	return handle(conn.DB("Dsers").C(collection))
}
func WithCollection(collection string, handle func(*mgo.Collection) error) error {
	return withCollection(collection, handle)
}

【golang】解决etcd安装出现的问题

参考技术A 解决办法修改依赖版本：

在GOPATH/src下执行

在go mod里加入