mongodb

Documentation

Index

• func DeleteSession(hostName string) error
• func GetMongoConnection(hostName string) (*mgo.Session, error)
• func InitNewSession(hostDetails MongoHost) error
• func InitUsingJSON(configs []MongoHost) error
• type MongoDAO
  • func GetMongoDAO(collection string) *MongoDAO
  • func GetMongoDAOWithHost(host, collection string) *MongoDAO
  • func (mg *MongoDAO) BulkDeleteData(data []interface{}) error
  • func (mg *MongoDAO) BulkSaveData(data []interface{}) error
  • func (mg *MongoDAO) BulkUpdateData(data []interface{}) error
  • func (mg *MongoDAO) BulkUpsertData(data []interface{}) error
  • func (mg *MongoDAO) CustomUpdate(selector map[string]interface{}, data interface{}) error
  • func (mg *MongoDAO) CustomUpdateOne(selector map[string]interface{}, data interface{}) error
  • func (mg *MongoDAO) DeleteAll(selector map[string]interface{}) error
  • func (mg *MongoDAO) DeleteData(selector map[string]interface{}) error
  • func (mg *MongoDAO) GetAggregateData(selector interface{}) (*gjson.Result, error)
  • func (mg *MongoDAO) GetData(selector map[string]interface{}) (*gjson.Result, error)
  • func (mg *MongoDAO) GetProjectedData(selector map[string]interface{}, projector map[string]interface{}) (*gjson.Result, error)
  • func (mg *MongoDAO) PushData(selector map[string]interface{}, data interface{}) error
  • func (mg *MongoDAO) SaveData(data interface{}) error
  • func (mg *MongoDAO) Update(selector map[string]interface{}, data interface{}) error
  • func (mg *MongoDAO) UpdateAll(selector map[string]interface{}, data interface{}) error
  • func (mg *MongoDAO) Upsert(selector map[string]interface{}, data interface{}) error
• type MongoHost
• type TomlConfig

Functions

func DeleteSession

func DeleteSession(hostName string) error

DeleteSession -DeleteSession

func GetMongoConnection

func GetMongoConnection(hostName string) (*mgo.Session, error)

GetMongoConnection method

func InitNewSession

func InitNewSession(hostDetails MongoHost) error

InitNewSession - InitNewSession

func InitUsingJSON

func InitUsingJSON(configs []MongoHost) error

InitUsingJSON initializes Mongo Connections for give JSON data

Types

type MongoDAO

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

MongoDAO mongo DAO struct

func GetMongoDAO

func GetMongoDAO(collection string) *MongoDAO

GetMongoDAO return mongo DAO instance

func GetMongoDAOWithHost

func GetMongoDAOWithHost(host, collection string) *MongoDAO

GetMongoDAOWithHost return mongo DAO instance

func (*MongoDAO) BulkDeleteData

func (mg *MongoDAO) BulkDeleteData(data []interface{}) error

BulkDeleteData delete data in mongo db in bulk

func (*MongoDAO) BulkSaveData

func (mg *MongoDAO) BulkSaveData(data []interface{}) error

BulkSaveData ata Save data in mongo db in bulk

func (*MongoDAO) BulkUpdateData

func (mg *MongoDAO) BulkUpdateData(data []interface{}) error

BulkUpdateData update data in mongo db in bulk

func (*MongoDAO) BulkUpsertData

func (mg *MongoDAO) BulkUpsertData(data []interface{}) error

BulkUpsertData Upsert data in mongo db in bulk

func (*MongoDAO) CustomUpdate

func (mg *MongoDAO) CustomUpdate(selector map[string]interface{}, data interface{}) error

CustomUpdate - CustomUpdate

func (*MongoDAO) CustomUpdateOne

func (mg *MongoDAO) CustomUpdateOne(selector map[string]interface{}, data interface{}) error

CustomUpdateOne - CustomUpdateOne

func (*MongoDAO) DeleteAll

func (mg *MongoDAO) DeleteAll(selector map[string]interface{}) error

DeleteAll will delete all the matching data given for selector

func (*MongoDAO) DeleteData

func (mg *MongoDAO) DeleteData(selector map[string]interface{}) error

DeleteData will delete data given for selector

func (*MongoDAO) GetAggregateData

func (mg *MongoDAO) GetAggregateData(selector interface{}) (*gjson.Result, error)

GetAggregateData - return result using aggregation query

func (*MongoDAO) GetData

func (mg *MongoDAO) GetData(selector map[string]interface{}) (*gjson.Result, error)

GetData will return query for selector

func (*MongoDAO) GetProjectedData

func (mg *MongoDAO) GetProjectedData(selector map[string]interface{}, projector map[string]interface{}) (*gjson.Result, error)

GetProjectedData will return query for selector and projector

func (*MongoDAO) PushData

func (mg *MongoDAO) PushData(selector map[string]interface{}, data interface{}) error

PushData - append in array

func (*MongoDAO) SaveData

func (mg *MongoDAO) SaveData(data interface{}) error

SaveData Save data in mongo db

func (*MongoDAO) Update

func (mg *MongoDAO) Update(selector map[string]interface{}, data interface{}) error

Update will update single entry

func (*MongoDAO) UpdateAll

func (mg *MongoDAO) UpdateAll(selector map[string]interface{}, data interface{}) error

UpdateAll update all

func (*MongoDAO) Upsert

func (mg *MongoDAO) Upsert(selector map[string]interface{}, data interface{}) error

Upsert will update single entry

type MongoHost

type MongoHost struct {
	HostName        string        `json:"hostName"`
	Server          string        `json:"server"`
	Port            int           `json:"port"`
	Username        string        `json:"username"`
	Password        string        `json:"password"`
	Database        string        `json:"database"`
	IsDefault       bool          `json:"isDefault"`
	MaxIdleConns    int           `json:"maxIdleConns" `
	MaxOpenConns    int           `json:"maxOpenConns"`
	ConnMaxLifetime time.Duration `json:"connMaxLifetime" `
	IsDisabled      bool          `json:"isDisabled" `
}

MongoHost -MongoHost

type TomlConfig

type TomlConfig struct {
	MongoHosts map[string]MongoHost
}

TomlConfig - TomlConfig