mongo

Documentation

Index

• type MongoDB
  • func (m *MongoDB) Check() error
  • func (m *MongoDB) Close()
  • func (m *MongoDB) GetConnection() *qmgo.Database
  • func (m *MongoDB) GetTransactionClient(collName string) (*qmgo.QmgoClient, error)
  • func (m *MongoDB) Init(mongodbConfigUrl string)
• type MongoDBConf

Types

type MongoDB

type MongoDB struct {
	// contains filtered or unexported fields
}

func (*MongoDB) Check

func (m *MongoDB) Check() error

func (*MongoDB) Close

func (m *MongoDB) Close()

func (*MongoDB) GetConnection

func (m *MongoDB) GetConnection() *qmgo.Database

func (*MongoDB) GetTransactionClient

func (m *MongoDB) GetTransactionClient(collName string) (*qmgo.QmgoClient, error)

GetTransactionClient 这个方法肯定是在初始化后才有可能被调用

func (*MongoDB) Init

func (m *MongoDB) Init(mongodbConfigUrl string)

type MongoDBConf

type MongoDBConf struct {
	Uri      string
	Username string
	Password string
	DB       string
	Timeout  int64
	Max      uint64
	Min      uint64
}