elastic

Documentation

Index

• type Adapter
  • func (a *Adapter) Connect() error
  • func (a *Adapter) Disconnect() error
  • func (a *Adapter) Find(params moleculer.Payload) moleculer.Payload
  • func (a *Adapter) FindOne(params moleculer.Payload) moleculer.Payload
  • func (a *Adapter) Init(log *log.Entry, settings map[string]interface{})
  • func (a *Adapter) Insert(params moleculer.Payload) moleculer.Payload
  • func (a *Adapter) RemoveAll() moleculer.Payload
  • func (a *Adapter) RemoveById(id moleculer.Payload) moleculer.Payload
  • func (adapter *Adapter) Update(params moleculer.Payload) moleculer.Payload
  • func (a *Adapter) UpdateById(id, update moleculer.Payload) moleculer.Payload

Types

type Adapter

type Adapter struct {
	URIs []string
	// contains filtered or unexported fields
}

func (*Adapter) Connect

func (a *Adapter) Connect() error

func (*Adapter) Disconnect

func (a *Adapter) Disconnect() error

func (*Adapter) Find

func (a *Adapter) Find(params moleculer.Payload) moleculer.Payload

func (*Adapter) FindOne

func (a *Adapter) FindOne(params moleculer.Payload) moleculer.Payload

FindOne find document return just the first match

func (*Adapter) Init

func (a *Adapter) Init(log *log.Entry, settings map[string]interface{})

func (*Adapter) Insert

func (a *Adapter) Insert(params moleculer.Payload) moleculer.Payload

Insert index document

func (*Adapter) RemoveAll

func (a *Adapter) RemoveAll() moleculer.Payload

RemoveAll remove all documents from the index

func (*Adapter) RemoveById

func (a *Adapter) RemoveById(id moleculer.Payload) moleculer.Payload

RemoveById remove document from the index by id

func (*Adapter) Update

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

func (*Adapter) UpdateById

func (a *Adapter) UpdateById(id, update moleculer.Payload) moleculer.Payload

UpdateById update document by id