endrMongoPool

README

go-mongo-pool

Documentation

Index

• type DBConfig
• type MongoConnection
  • func NewMongoConnection(dbConfig DBConfig) *MongoConnection
  • func (conn *MongoConnection) CloseMongoDB() (err error)
  • func (conn *MongoConnection) DBAsync(wg *sync.WaitGroup, f func(db *mongo.Database, errChan chan error) error) (err error)
  • func (conn *MongoConnection) GetMongoDB() (*mongo.Database, error)
  • func (conn *MongoConnection) NewMongoDB() (*mongo.Database, error)
  • func (conn *MongoConnection) PutMongoDB(db *mongo.Database) error

Types

type DBConfig

type DBConfig struct {
	Uri            string `default:"mongodb://localhost:27017"`
	ConnectTimeout int    `default:"10"`
	DBName         string `default:"wares_info"`
	//GoodsCollection string `default:"goods_catalog"`
	PoolSize int `default:"5"`
}

type MongoConnection

type MongoConnection struct {
	Errors chan error
	// contains filtered or unexported fields
}

func NewMongoConnection

func NewMongoConnection(dbConfig DBConfig) *MongoConnection

func (*MongoConnection) CloseMongoDB

func (conn *MongoConnection) CloseMongoDB() (err error)

func (*MongoConnection) DBAsync

func (conn *MongoConnection) DBAsync(wg *sync.WaitGroup, f func(db *mongo.Database, errChan chan error) error) (err error)

func (*MongoConnection) GetMongoDB

func (conn *MongoConnection) GetMongoDB() (*mongo.Database, error)

func (*MongoConnection) NewMongoDB

func (conn *MongoConnection) NewMongoDB() (*mongo.Database, error)

func (*MongoConnection) PutMongoDB

func (conn *MongoConnection) PutMongoDB(db *mongo.Database) error