Documentation
¶
Index ¶
- func ToString(queryMap interface{}) string
- func ToStringD(queryMap bson.D) string
- type MongoContext
- func (c *MongoContext) Close()
- func (c *MongoContext) GetCollection(db string, collection string) *mgo.Collection
- func (c *MongoContext) SetCollection(collection string, s func(*mgo.Collection) error) error
- func (c *MongoContext) SetCollectionByDB(db string, collection string, s func(*mgo.Collection) error) error
- func (c *MongoContext) SetCollectionCount(collection string, s func(*mgo.Collection) (int, error)) (int, error)
- type OptionDbRepo
- type OptionDbRepository
- func (r *OptionDbRepository) CallClose()
- func (r *OptionDbRepository) InsertOptionDb(collection string, value interface{}) error
- func (r *OptionDbRepository) OptionDbFind(collection string, key string, value interface{}) (interface{}, error)
- func (r *OptionDbRepository) OptionDbUpdate(collection string, key string, value interface{}, updatekey string, ...) error
- func (r *OptionDbRepository) RemoveAllOptionDb(collection string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MongoContext ¶
type MongoContext struct {
// contains filtered or unexported fields
}
MongoContext is a plugin db for option db, you can chose different db if you like.
func GetSession ¶
func GetSession(url string) (*MongoContext, error)
GetSession is to create session to mongodb
func (*MongoContext) GetCollection ¶
func (c *MongoContext) GetCollection(db string, collection string) *mgo.Collection
GetCollection is to get mongodb collection
func (*MongoContext) SetCollection ¶
func (c *MongoContext) SetCollection(collection string, s func(*mgo.Collection) error) error
SetCollection is to set mongodb collection
func (*MongoContext) SetCollectionByDB ¶
func (c *MongoContext) SetCollectionByDB(db string, collection string, s func(*mgo.Collection) error) error
SetCollectionByDB is to set mongodb collection by specific database
func (*MongoContext) SetCollectionCount ¶
func (c *MongoContext) SetCollectionCount(collection string, s func(*mgo.Collection) (int, error)) (int, error)
SetCollectionCount is to set mongodb collection by returning records number
type OptionDbRepo ¶
type OptionDbRepo interface {
InsertOptionDb(collection string, value interface{}) error
OptionDbFind(collection string, key string, value interface{}) (interface{}, error)
OptionDbUpdate(collection string, key string, value interface{}, updatekey string, updatevalue interface{}) error
CallClose()
}
OptionDbRepo is the interface for plugin db for user queries
type OptionDbRepository ¶
type OptionDbRepository struct {
// contains filtered or unexported fields
}
OptionDbRepository is the option db struct
func NewOptionDbRepository ¶
func NewOptionDbRepository(endpoint string) *OptionDbRepository
NewOptionDbRepository creates a new OptionDbRepository
func (*OptionDbRepository) CallClose ¶
func (r *OptionDbRepository) CallClose()
func (*OptionDbRepository) InsertOptionDb ¶
func (r *OptionDbRepository) InsertOptionDb(collection string, value interface{}) error
InsertOptionDb is to insert record in option db
func (*OptionDbRepository) OptionDbFind ¶
func (r *OptionDbRepository) OptionDbFind(collection string, key string, value interface{}) (interface{}, error)
OptionDbFind is to find record in option db
func (*OptionDbRepository) OptionDbUpdate ¶
func (r *OptionDbRepository) OptionDbUpdate(collection string, key string, value interface{}, updatekey string, updatevalue interface{}) error
OptionDbUpdate is to update record in option db
func (*OptionDbRepository) RemoveAllOptionDb ¶
func (r *OptionDbRepository) RemoveAllOptionDb(collection string) error
RemoveAllOptionDb is to remove all records in option db
Source Files
Click to show internal directories.
Click to hide internal directories.