Versions in this module Expand all Collapse all v0 v0.2.2 Aug 28, 2020 Changes in this version + func ConfigParserES6(conf interface{}) es6.Config + func ConfigParserES7(conf interface{}) es7.Config + func ConfigParserES8(conf interface{}) es8.Config + func NewIndexer(version ESVersion, cfg interface{}) (adapter.IIndexerEngine, error) + func NewIndexerES6(cfg es6.Config) (adapter.IIndexerEngine, error) + func NewIndexerES7(cfg es7.Config) (adapter.IIndexerEngine, error) + func NewIndexerES8(cfg es8.Config) (adapter.IIndexerEngine, error) + type ESVersion string + const ESVersion6 + const ESVersion7 + const ESVersion8 + type Indexer struct + func (i *Indexer) CreateDoc(index string, id string, body io.Reader) error + func (i *Indexer) CreateIndex(index string, mapping io.Reader) error + func (i *Indexer) DeleteDoc(index string, id string) error + func (i *Indexer) DocExist(index string, id string) (bool, error) + func (i *Indexer) DropIndex(indexs []string) error + func (i *Indexer) GetDoc(index string, id string) ([]byte, error) + func (i *Indexer) GetEngine() interface{} + func (i *Indexer) IndexExist(indexs []string) (bool, error) + func (i *Indexer) Search(query io.Reader, prettify bool) ([]byte, error) + func (i *Indexer) SearchIndexDoc(index string, query io.Reader, size int, prettify bool) ([]byte, error) + func (i *Indexer) UpdateDoc(index string, id string, body io.Reader) error + type IndexerES6 struct + func (i *IndexerES6) CreateDoc(index string, id string, body io.Reader) error + func (i *IndexerES6) CreateIndex(index string, mapping io.Reader) error + func (i *IndexerES6) DeleteDoc(index string, id string) error + func (i *IndexerES6) DocExist(index string, id string) (bool, error) + func (i *IndexerES6) DropIndex(indexs []string) error + func (i *IndexerES6) GetDoc(index string, id string) ([]byte, error) + func (i *IndexerES6) GetEngine() interface{} + func (i *IndexerES6) IndexExist(indexs []string) (bool, error) + func (i *IndexerES6) Search(query io.Reader, prettify bool) ([]byte, error) + func (i *IndexerES6) SearchIndexDoc(index string, query io.Reader, size int, prettify bool) ([]byte, error) + func (i *IndexerES6) UpdateDoc(index string, id string, body io.Reader) error + type IndexerES7 struct + func (i *IndexerES7) CreateDoc(index string, id string, body io.Reader) error + func (i *IndexerES7) CreateIndex(index string, mapping io.Reader) error + func (i *IndexerES7) DeleteDoc(index string, id string) error + func (i *IndexerES7) DocExist(index string, id string) (bool, error) + func (i *IndexerES7) DropIndex(indexs []string) error + func (i *IndexerES7) GetDoc(index string, id string) ([]byte, error) + func (i *IndexerES7) GetEngine() interface{} + func (i *IndexerES7) IndexExist(indexs []string) (bool, error) + func (i *IndexerES7) Search(query io.Reader, prettify bool) ([]byte, error) + func (i *IndexerES7) SearchIndexDoc(index string, query io.Reader, size int, prettify bool) ([]byte, error) + func (i *IndexerES7) UpdateDoc(index string, id string, body io.Reader) error + type IndexerES8 struct + func (i *IndexerES8) CreateDoc(index string, id string, body io.Reader) error + func (i *IndexerES8) CreateIndex(index string, mapping io.Reader) error + func (i *IndexerES8) DeleteDoc(index string, id string) error + func (i *IndexerES8) DocExist(index string, id string) (bool, error) + func (i *IndexerES8) DropIndex(indexs []string) error + func (i *IndexerES8) GetDoc(index string, id string) ([]byte, error) + func (i *IndexerES8) GetEngine() interface{} + func (i *IndexerES8) IndexExist(indexs []string) (bool, error) + func (i *IndexerES8) Search(query io.Reader, prettify bool) ([]byte, error) + func (i *IndexerES8) SearchIndexDoc(index string, query io.Reader, size int, prettify bool) ([]byte, error) + func (i *IndexerES8) UpdateDoc(index string, id string, body io.Reader) error