lxDb

Documentation

Index

• Constants
• func GetMongoDbConnection(url string) *mgo.Session
• type AuditModel
  • func (am *AuditModel) ToJson() string
• type ChangeInfo
• type MongoDb
  • func NewMongoDb(connection *mgo.Session, dbName, collection string) *MongoDb
  • func (db *MongoDb) AuditLog(action string, user, data interface{}) error
  • func (db *MongoDb) Setup(indexes []mgo.Index) error
• type Options

Constants

const (
	ActionInsert = "insert"
	ActionFind   = "find"
	ActionUpdate = "update"
	ActionUpsert = "upsert"
	ActionRemove = "remove"
)

Functions

func GetMongoDbConnection

func GetMongoDbConnection(url string) *mgo.Session

NewMongoDbConn, get a new db connection

Types

type AuditModel

type AuditModel struct {
	TimeStamp  time.Time   `json:"timestamp" bson:"timestamp"`
	Collection string      `json:"collection" bson:"collection"`
	Action     string      `json:"action" bson:"action"`
	User       interface{} `json:"user" bson:"user"`
	Data       interface{} `json:"data" bson:"data"`
}

func (*AuditModel) ToJson

func (am *AuditModel) ToJson() string

ToJson, convert model to json string for log

type ChangeInfo

type ChangeInfo struct {
	Updated int // Number of documents updated
	Removed int // Number of documents removed
	Matched int // Number of documents matched but not necessarily changed
}

ChangeInfo holds details about the outcome of an update operation.

type MongoDb

type MongoDb struct {
	Conn       *mgo.Session
	Name       string
	Collection string
}

Db struct for mongodb

func NewMongoDb

func NewMongoDb(connection *mgo.Session, dbName, collection string) *MongoDb

func (*MongoDb) AuditLog

func (db *MongoDb) AuditLog(action string, user, data interface{}) error

AuditLog log db audit

func (*MongoDb) Setup

func (db *MongoDb) Setup(indexes []mgo.Index) error

Setup create indexes for user collection.

type Options

type Options struct {
	Sort  string `json:"sort,omitempty"`
	Skip  int    `json:"skip"`
	Limit int    `json:"limit"`
	Count bool   `json:"count"`
}