mongo

Documentation

Index

• type MongoAdapter
  • func (adapter *MongoAdapter) Connect() error
  • func (adapter *MongoAdapter) Count(params moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) Disconnect() error
  • func (adapter *MongoAdapter) Find(params moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) FindAndUpdate(param moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) FindById(params moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) FindByIds(params moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) FindOne(params moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) Init(logger *log.Entry, settings map[string]interface{})
  • func (adapter *MongoAdapter) Insert(params moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) RemoveAll() moleculer.Payload
  • func (adapter *MongoAdapter) RemoveById(id moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) Update(params moleculer.Payload) moleculer.Payload
  • func (adapter *MongoAdapter) UpdateById(id, update moleculer.Payload) moleculer.Payload

Types

type MongoAdapter

type MongoAdapter struct {
	MongoURL   string
	Timeout    time.Duration
	Database   string
	Collection string
	// contains filtered or unexported fields
}

MongoAdapter Mongo DB Adapter :)

func (*MongoAdapter) Connect

func (adapter *MongoAdapter) Connect() error

Connect connect to mongo, stores the client and the collection.

func (*MongoAdapter) Count

func (adapter *MongoAdapter) Count(params moleculer.Payload) moleculer.Payload

Count count the number of records for the given filter.

func (*MongoAdapter) Disconnect

func (adapter *MongoAdapter) Disconnect() error

Disconnect disconnects from mongo.

func (*MongoAdapter) Find

func (adapter *MongoAdapter) Find(params moleculer.Payload) moleculer.Payload

Find search the data store with the params provided.

func (*MongoAdapter) FindAndUpdate

func (adapter *MongoAdapter) FindAndUpdate(param moleculer.Payload) moleculer.Payload

func (*MongoAdapter) FindById

func (adapter *MongoAdapter) FindById(params moleculer.Payload) moleculer.Payload

func (*MongoAdapter) FindByIds

func (adapter *MongoAdapter) FindByIds(params moleculer.Payload) moleculer.Payload

func (*MongoAdapter) FindOne

func (adapter *MongoAdapter) FindOne(params moleculer.Payload) moleculer.Payload

func (*MongoAdapter) Init

func (adapter *MongoAdapter) Init(logger *log.Entry, settings map[string]interface{})

func (*MongoAdapter) Insert

func (adapter *MongoAdapter) Insert(params moleculer.Payload) moleculer.Payload

func (*MongoAdapter) RemoveAll

func (adapter *MongoAdapter) RemoveAll() moleculer.Payload

func (*MongoAdapter) RemoveById

func (adapter *MongoAdapter) RemoveById(id moleculer.Payload) moleculer.Payload

func (*MongoAdapter) Update

func (adapter *MongoAdapter) Update(params moleculer.Payload) moleculer.Payload

func (*MongoAdapter) UpdateById

func (adapter *MongoAdapter) UpdateById(id, update moleculer.Payload) moleculer.Payload