db

Documentation

Overview

本包只做mongodb的异步操作实现 只实现常用功能

复杂操作可以使用mongodb的原始接口进行操作

Index

• type Config
• type MongoDriver
  • func NewMongoDriver() *MongoDriver
  • func (self *MongoDriver) Execute(dbfunc func(sess *mgo.Session))
  • func (self *MongoDriver) Start(cfg *Config) error
  • func (self *MongoDriver) Stop()

Types

type Config

type Config struct {
	URL       string // username:password@tcp(address:port)/dbname   ?authSource=admin
	ConnCount int32  // 连接量
}

type MongoDriver

type MongoDriver struct {
	*Config
	// contains filtered or unexported fields
}

func NewMongoDriver

func NewMongoDriver() *MongoDriver

func (*MongoDriver) Execute

func (self *MongoDriver) Execute(dbfunc func(sess *mgo.Session))

func (*MongoDriver) Start

func (self *MongoDriver) Start(cfg *Config) error

func (*MongoDriver) Stop

func (self *MongoDriver) Stop()