mongo

package

v5.9.0+incompatible Latest Latest Go to latest Published: Mar 6, 2018 License: GPL-3.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Andals/gobox

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewMongoLogger(logger golog.ILogger) *mongoLogger
type Client
- func NewClient(config *Config, logger golog.ILogger) *Client
type CmdLogFmtFunc
type Config
- func NewConfig(host, port, user, pass, dbname string) *Config
type PConfig
type Pool
- func NewPool(config *PConfig) *Pool
- func (this *Pool) Get() (*Client, error)
- func (this *Pool) Put(client *Client) error
type Query
- func NewQuery() *Query

Constants ¶

View Source

const (
	DEFAULT_QUERY_TIMEOUT = 10 * time.Second
)

Variables ¶

This section is empty.

Functions ¶

func NewMongoLogger ¶

func NewMongoLogger(logger golog.ILogger) *mongoLogger

Types ¶

type Client ¶

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

func NewClient ¶

func NewClient(config *Config, logger golog.ILogger) *Client

func (*Client) BuildQuery ¶

func (this *Client) BuildQuery(query *Query) *mgo.Query

func (*Client) Collection ¶

func (this *Client) Collection(col string) *mgo.Collection

func (*Client) Connect ¶

func (this *Client) Connect() error

func (*Client) Connected ¶

func (this *Client) Connected() bool

func (*Client) Count ¶

func (this *Client) Count() (n int, err error)

func (*Client) DB ¶

func (this *Client) DB(name string) *mgo.Database

func (*Client) Find ¶

func (this *Client) Find(query interface{}) *mgo.Query

func (*Client) FindId ¶

func (this *Client) FindId(id interface{}) *mgo.Query

func (*Client) Free ¶

func (this *Client) Free()

func (*Client) Indexes ¶

func (this *Client) Indexes() (indexes []mgo.Index, err error)

func (*Client) Insert ¶

func (this *Client) Insert(docs ...interface{}) error

func (*Client) Query ¶

func (this *Client) Query(query *Query) (result []bson.M, err error)

func (*Client) QueryCount ¶

func (this *Client) QueryCount(query *Query) (n int, err error)

func (*Client) QueryId ¶

func (this *Client) QueryId(id interface{}) (result bson.M, err error)

func (*Client) QueryOne ¶

func (this *Client) QueryOne(query *Query) (result bson.M, err error)

func (*Client) Remove ¶

func (this *Client) Remove(selector interface{}) error

func (*Client) RemoveAll ¶

func (this *Client) RemoveAll(selector interface{}) error

func (*Client) RemoveId ¶

func (this *Client) RemoveId(id interface{}) error

func (*Client) SetCmdLogFmtFunc ¶

func (this *Client) SetCmdLogFmtFunc(clff CmdLogFmtFunc) *Client

func (*Client) SetDebug ¶

func (this *Client) SetDebug(debug bool)

func (*Client) SetLogger ¶

func (this *Client) SetLogger(logger golog.ILogger) *Client

func (*Client) Update ¶

func (this *Client) Update(selector, updater interface{}) error

func (*Client) UpdateAll ¶

func (this *Client) UpdateAll(selector, updater interface{}) error

func (*Client) UpdateId ¶

func (this *Client) UpdateId(id interface{}, updater interface{}) error

func (*Client) Upsert ¶

func (this *Client) Upsert(selector, updater interface{}) error

type CmdLogFmtFunc ¶

type CmdLogFmtFunc func(cmd string, args ...interface{}) []byte

type Config ¶

type Config struct {
	LogLevel int

	Host   string
	Port   string
	User   string
	Pass   string
	DBName string

	QueryTimeout time.Duration
}

func NewConfig ¶

func NewConfig(host, port, user, pass, dbname string) *Config

type PConfig ¶

type PConfig struct {
	pool.Config

	NewClientFunc func() (*Client, error)
}

type Pool ¶

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

func NewPool ¶

func NewPool(config *PConfig) *Pool

func (*Pool) Get ¶

func (this *Pool) Get() (*Client, error)

func (*Pool) Put ¶

func (this *Pool) Put(client *Client) error

type Query ¶

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

func NewQuery ¶

func NewQuery() *Query

func (*Query) Limit ¶

func (this *Query) Limit(n int) *Query

func (*Query) Query ¶

func (this *Query) Query(query interface{}) *Query

func (*Query) Select ¶

func (this *Query) Select(selector interface{}) *Query

func (*Query) SetMaxTime ¶

func (this *Query) SetMaxTime(maxTime time.Duration) *Query

func (*Query) Skip ¶

func (this *Query) Skip(n int) *Query

func (*Query) Sort ¶

func (this *Query) Sort(fields ...string) *Query

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL