mongo

Documentation

Index

• func Find(collectionName string, selector map[string]interface{}, ...) *common.Error
• func FindOne(collectionName string, selector map[string]interface{}, ...) *common.Error
• func Insert(collectionName string, doc interface{}, result *[]interface{}) *common.Error
• func InvalidObjectIdError(objectId string) *common.Error
• func MongoDBError(b error) *common.Error
• func ObjectAlreadyExistsError(objectName string) *common.Error
• func ObjectNotExistsError(objectName string) *common.Error
• func Remove(collectionName string, selector map[string]interface{}, result *[]interface{}) *common.Error
• func SetMongoDBInv(mongoDB settings.DBConfig)
• func StartMongod()
• func TestMongoConnection()
• func Update(collectionName string, selector map[string]interface{}, update interface{}, ...) *common.Error
• func Upsert(collectionName string, selector map[string]interface{}, update interface{}, ...) *common.Error
• type AtlasMongo
  • func (mi *AtlasMongo) GetCollection(collectionName string) *mongo.Collection
  • func (mi *AtlasMongo) GetDatabaseConfig() *Database
  • func (mi *AtlasMongo) GetSession() *mongo.Client
• type DB
• type Database
• type LocalMongo
  • func (mi *LocalMongo) GetCollection(collectionName string) *mongo.Collection
  • func (mi *LocalMongo) GetDatabaseConfig() *Database
  • func (mi *LocalMongo) GetSession() *mongo.Client

Functions

func Find

func Find(collectionName string, selector map[string]interface{}, inputOptions interface{}, result *[]interface{}) *common.Error

func FindOne

func FindOne(collectionName string, selector map[string]interface{}, result *map[string]interface{}) *common.Error

func Insert

func Insert(collectionName string, doc interface{}, result *[]interface{}) *common.Error

func InvalidObjectIdError

func InvalidObjectIdError(objectId string) *common.Error

func MongoDBError

func MongoDBError(b error) *common.Error

func ObjectAlreadyExistsError

func ObjectAlreadyExistsError(objectName string) *common.Error

func ObjectNotExistsError

func ObjectNotExistsError(objectName string) *common.Error

func Remove

func Remove(collectionName string, selector map[string]interface{}, result *[]interface{}) *common.Error

func SetMongoDBInv

func SetMongoDBInv(mongoDB settings.DBConfig)

func StartMongod

func StartMongod()

func TestMongoConnection

func TestMongoConnection()

func Update

func Update(collectionName string, selector map[string]interface{}, update interface{}, inputOptions interface{}, result *[]interface{}) *common.Error

func Upsert

func Upsert(collectionName string, selector map[string]interface{}, update interface{}, inputOptions interface{}, result *[]interface{}) *common.Error

Types

type AtlasMongo

type AtlasMongo struct {
	Config Database `json:"config"`
	Host   string   `json:"host"`
}

func (*AtlasMongo) GetCollection

func (mi *AtlasMongo) GetCollection(collectionName string) *mongo.Collection

func (*AtlasMongo) GetDatabaseConfig

func (mi *AtlasMongo) GetDatabaseConfig() *Database

func (*AtlasMongo) GetSession

func (mi *AtlasMongo) GetSession() *mongo.Client

type DB

type DB interface {
	GetSession() *mongo.Client
	GetDatabaseConfig() *Database
	GetCollection(collectionName string) *mongo.Collection
}

var Instance DB

type Database

type Database struct {
	Username string `json:"username"`
	Password string `json:"password"`
	Database string `json:"database"`
}

type LocalMongo

type LocalMongo struct {
	Config Database `json:"config"`
	Host   string   `json:"host"`
}

func (*LocalMongo) GetCollection

func (mi *LocalMongo) GetCollection(collectionName string) *mongo.Collection

func (*LocalMongo) GetDatabaseConfig

func (mi *LocalMongo) GetDatabaseConfig() *Database

func (*LocalMongo) GetSession

func (mi *LocalMongo) GetSession() *mongo.Client