mongo

Documentation

Index

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

Types

type Client

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

func NewClient

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

func SetUp

func SetUp(conf settings.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 监测心跳和重连