dbConnPool

Documentation

Index

• type MongoConnPool
  • func (p *MongoConnPool) Init(size int, mongoUrl string, usrName string, pass string) error
  • func (p *MongoConnPool) ReturnConn(client *mongo.Client)
  • func (p *MongoConnPool) WaitForOneConn(ctx context.Context) (*mongo.Client, error)

Types

type MongoConnPool

type MongoConnPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*MongoConnPool) Init

func (p *MongoConnPool) Init(size int, mongoUrl string, usrName string, pass string) error

func (*MongoConnPool) ReturnConn

func (p *MongoConnPool) ReturnConn(client *mongo.Client)

func (*MongoConnPool) WaitForOneConn

func (p *MongoConnPool) WaitForOneConn(ctx context.Context) (*mongo.Client, error)