Documentation ¶
Index ¶
- 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
- type Indexer
- 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
- 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
- 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigParserES6 ¶
ConfigParserES6 config parser for elastic search 6
func ConfigParserES7 ¶
ConfigParserES7 config parser for elastic search 7
func ConfigParserES8 ¶
ConfigParserES8 config parser for elastic search 8
func NewIndexer ¶
func NewIndexer(version ESVersion, cfg interface{}) (adapter.IIndexerEngine, error)
NewIndexer new Elastic Search Indexer
func NewIndexerES6 ¶
func NewIndexerES6(cfg es6.Config) (adapter.IIndexerEngine, error)
NewIndexerES6 new Elastic Search 6 Indexer
func NewIndexerES7 ¶
func NewIndexerES7(cfg es7.Config) (adapter.IIndexerEngine, error)
NewIndexerES7 new Elastic Search 7 Indexer
func NewIndexerES8 ¶
func NewIndexerES8(cfg es8.Config) (adapter.IIndexerEngine, error)
NewIndexerES8 new Elastic Search 8 Indexer
Types ¶
type Indexer ¶
type Indexer struct {
// contains filtered or unexported fields
}
Indexer type
func (*Indexer) CreateIndex ¶
CreateIndex is a function to Create Index
func (*Indexer) IndexExist ¶
IndexExist is a function to check Index is Exist
type IndexerES6 ¶
type IndexerES6 struct {
// contains filtered or unexported fields
}
IndexerES6 type
func (*IndexerES6) CreateIndex ¶
func (i *IndexerES6) CreateIndex(index string, mapping io.Reader) error
CreateIndex is a function to Create Index
func (*IndexerES6) DeleteDoc ¶
func (i *IndexerES6) DeleteDoc(index string, id string) error
DeleteDoc is a function to Delete Doc
func (*IndexerES6) DocExist ¶
func (i *IndexerES6) DocExist(index string, id string) (bool, error)
DocExist is a function to check Doc is Exist
func (*IndexerES6) DropIndex ¶
func (i *IndexerES6) DropIndex(indexs []string) error
DropIndex is a function to Drop Index
func (*IndexerES6) GetDoc ¶
func (i *IndexerES6) GetDoc(index string, id string) ([]byte, error)
GetDoc is a function to Get Doc
func (*IndexerES6) GetEngine ¶
func (i *IndexerES6) GetEngine() interface{}
GetEngine get Indexer Engine
func (*IndexerES6) IndexExist ¶
func (i *IndexerES6) IndexExist(indexs []string) (bool, error)
IndexExist is a function to check Index is Exist
func (*IndexerES6) SearchIndexDoc ¶
func (i *IndexerES6) SearchIndexDoc(index string, query io.Reader, size int, prettify bool) ([]byte, error)
SearchIndexDoc is a function to Search Index Doc
type IndexerES7 ¶
type IndexerES7 struct {
// contains filtered or unexported fields
}
IndexerES7 type
func (*IndexerES7) CreateIndex ¶
func (i *IndexerES7) CreateIndex(index string, mapping io.Reader) error
CreateIndex is a function to Create Index
func (*IndexerES7) DeleteDoc ¶
func (i *IndexerES7) DeleteDoc(index string, id string) error
DeleteDoc is a function to Delete Doc
func (*IndexerES7) DocExist ¶
func (i *IndexerES7) DocExist(index string, id string) (bool, error)
DocExist is a function to check Doc is Exist
func (*IndexerES7) DropIndex ¶
func (i *IndexerES7) DropIndex(indexs []string) error
DropIndex is a function to Drop Index
func (*IndexerES7) GetDoc ¶
func (i *IndexerES7) GetDoc(index string, id string) ([]byte, error)
GetDoc is a function to Get Doc
func (*IndexerES7) GetEngine ¶
func (i *IndexerES7) GetEngine() interface{}
GetEngine get Indexer Engine
func (*IndexerES7) IndexExist ¶
func (i *IndexerES7) IndexExist(indexs []string) (bool, error)
IndexExist is a function to check Index is Exist
func (*IndexerES7) SearchIndexDoc ¶
func (i *IndexerES7) SearchIndexDoc(index string, query io.Reader, size int, prettify bool) ([]byte, error)
SearchIndexDoc is a function to Search Index Doc
type IndexerES8 ¶
type IndexerES8 struct {
// contains filtered or unexported fields
}
IndexerES8 type
func (*IndexerES8) CreateIndex ¶
func (i *IndexerES8) CreateIndex(index string, mapping io.Reader) error
CreateIndex is a function to Create Index
func (*IndexerES8) DeleteDoc ¶
func (i *IndexerES8) DeleteDoc(index string, id string) error
DeleteDoc is a function to Delete Doc
func (*IndexerES8) DocExist ¶
func (i *IndexerES8) DocExist(index string, id string) (bool, error)
DocExist is a function to check Doc is Exist
func (*IndexerES8) DropIndex ¶
func (i *IndexerES8) DropIndex(indexs []string) error
DropIndex is a function to Drop Index
func (*IndexerES8) GetDoc ¶
func (i *IndexerES8) GetDoc(index string, id string) ([]byte, error)
GetDoc is a function to Get Doc
func (*IndexerES8) GetEngine ¶
func (i *IndexerES8) GetEngine() interface{}
GetEngine get Indexer Engine
func (*IndexerES8) IndexExist ¶
func (i *IndexerES8) IndexExist(indexs []string) (bool, error)
IndexExist is a function to check Index is Exist
func (*IndexerES8) SearchIndexDoc ¶
func (i *IndexerES8) SearchIndexDoc(index string, query io.Reader, size int, prettify bool) ([]byte, error)
SearchIndexDoc is a function to Search Index Doc