mongo

Documentation

Index

• type Client
  • func NewClient(cli *mongo.Client, db *mongo.Database, rawConfig Mongo) *Client
  • func SetUp(conf Mongo) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) GetDB() *mongo.Database
  • func (c *Client) Heartbeat() error
  • func (c *Client) WatchHeartbeat()
• type Mongo

Types

type Client

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

func NewClient

func NewClient(cli *mongo.Client, db *mongo.Database, rawConfig Mongo) *Client

func SetUp

func SetUp(conf Mongo) (*Client, error)

SetUp 初始化mongo.

func (*Client) Close

func (c *Client) Close() error

Close 关闭连接.

func (*Client) GetDB

func (c *Client) GetDB() *mongo.Database

GetDB 获取原生db.

func (*Client) Heartbeat

func (c *Client) Heartbeat() error

Heartbeat ping连接.

func (*Client) WatchHeartbeat

func (c *Client) WatchHeartbeat()

WatchHeartbeat 监测心跳和重连.

type Mongo

type Mongo struct {
	// Uri mongo Uri example:"mongodb://localhost:27017"
	Uri string `json:"uri" yaml:"uri"`
	// Database 数据库
	Database string `json:"database" yaml:"database"`
	// MaxOpenConnCount 最大连接数量
	MaxOpenConnCount uint64 `json:"maxOpenConnCount" yaml:"maxOpenConnCount"`
	// MinOpenConnCount 最小连接数量
	MinOpenConnCount uint64 `json:"minOpenConnCount" yaml:"minOpenConnCount"`
	// FreeMaxLifetime 闲置连接最大存活时间, 单位: 秒
	FreeMaxLifetime int `yaml:"freeMaxLifetime" json:"freeMaxLifetime"`
}