mongodb

Documentation

Index

• type MongoDB
  • func NewMongoDB(opts ...Option) *MongoDB
  • func (db *MongoDB) GetCollection(name string) *mongo.Collection
  • func (db *MongoDB) Init(opts ...Option) error
  • func (db *MongoDB) IsInvalid() bool
  • func (db *MongoDB) Start() error
  • func (db *MongoDB) UnInit() error
• type Option
• type Options

Types

type MongoDB

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

func NewMongoDB

func NewMongoDB(opts ...Option) *MongoDB

func (*MongoDB) GetCollection

func (db *MongoDB) GetCollection(name string) *mongo.Collection

func (*MongoDB) Init

func (db *MongoDB) Init(opts ...Option) error

Init 初始化, 处理用户配置，生成mongo uri

func (*MongoDB) IsInvalid

func (db *MongoDB) IsInvalid() bool

func (*MongoDB) Start

func (db *MongoDB) Start() error

func (*MongoDB) UnInit

func (db *MongoDB) UnInit() error

type Option

type Option func(o *Options)

type Options

type Options struct {
	// User 用户名
	User string `yaml:"user"`
	// PassWord 密码
	Password string `yaml:"password"`
	// DB 数据库名
	DB string `yaml:"db"`
	//Mongos mongo 集群节点地址
	Mongos []string `yaml:"mongos"`
}