Documentation
¶
Index ¶
- type ClientWrapper
- type IndexServiceWrapper
- type IndicesCreateServiceWrapper
- type IndicesExistsServiceWrapper
- type MultiSearchServiceWrapper
- type SearchServiceWrapper
- func (s SearchServiceWrapper) Aggregation(name string, aggregation elastic.Aggregation) es.SearchService
- func (s SearchServiceWrapper) Do(ctx context.Context) (*elastic.SearchResult, error)
- func (s SearchServiceWrapper) IgnoreUnavailable(ignoreUnavailable bool) es.SearchService
- func (s SearchServiceWrapper) Query(query elastic.Query) es.SearchService
- func (s SearchServiceWrapper) Size(size int) es.SearchService
- type TemplateCreateServiceWrapper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientWrapper ¶
type ClientWrapper struct {
// contains filtered or unexported fields
}
ClientWrapper is a wrapper around elastic.Client
func WrapESClient ¶
func WrapESClient(client *elastic.Client, s *elastic.BulkProcessor, esVersion uint) ClientWrapper
WrapESClient creates a ESClient out of *elastic.Client.
func (ClientWrapper) Close ¶
func (c ClientWrapper) Close() error
Close closes ESClient and flushes all data to the storage.
func (ClientWrapper) GetVersion ¶
func (c ClientWrapper) GetVersion() uint
GetVersion returns the ElasticSearch Version
func (ClientWrapper) Index ¶
func (c ClientWrapper) Index() es.IndexService
Index calls this function to internal client.
func (ClientWrapper) MultiSearch ¶
func (c ClientWrapper) MultiSearch() es.MultiSearchService
MultiSearch calls this function to internal client.
func (ClientWrapper) Search ¶
func (c ClientWrapper) Search(indices ...string) es.SearchService
Search calls this function to internal client.
type IndexServiceWrapper ¶
type IndexServiceWrapper struct {
// contains filtered or unexported fields
}
IndexServiceWrapper is a wrapper around elastic.ESIndexService. See wrapper_nolint.go for more functions.
func WrapESIndexService ¶
func WrapESIndexService(indexService *elastic.BulkIndexRequest, bulkService *elastic.BulkProcessor, esVersion uint) IndexServiceWrapper
WrapESIndexService creates an ESIndexService out of *elastic.ESIndexService.
func (IndexServiceWrapper) Add ¶
func (i IndexServiceWrapper) Add()
Add adds the request to bulk service
func (IndexServiceWrapper) BodyJson ¶
func (i IndexServiceWrapper) BodyJson(body interface{}) es.IndexService
BodyJson calls this function to internal service.
func (IndexServiceWrapper) Id ¶
func (i IndexServiceWrapper) Id(id string) es.IndexService
Id calls this function to internal service.
func (IndexServiceWrapper) Index ¶
func (i IndexServiceWrapper) Index(index string) es.IndexService
Index calls this function to internal service.
func (IndexServiceWrapper) Type ¶
func (i IndexServiceWrapper) Type(typ string) es.IndexService
Type calls this function to internal service.
type IndicesCreateServiceWrapper ¶
type IndicesCreateServiceWrapper struct {
// contains filtered or unexported fields
}
IndicesCreateServiceWrapper is a wrapper around elastic.IndicesCreateService
func WrapESIndicesCreateService ¶
func WrapESIndicesCreateService(indicesCreateService *elastic.IndicesCreateService) IndicesCreateServiceWrapper
WrapESIndicesCreateService creates an ESIndicesCreateService out of *elastic.IndicesCreateService.
func (IndicesCreateServiceWrapper) Body ¶
func (c IndicesCreateServiceWrapper) Body(mapping string) es.IndicesCreateService
Body calls this function to internal service.
func (IndicesCreateServiceWrapper) Do ¶
func (c IndicesCreateServiceWrapper) Do(ctx context.Context) (*elastic.IndicesCreateResult, error)
Do calls this function to internal service.
type IndicesExistsServiceWrapper ¶
type IndicesExistsServiceWrapper struct {
// contains filtered or unexported fields
}
IndicesExistsServiceWrapper is a wrapper around elastic.IndicesExistsService
func WrapESIndicesExistsService ¶
func WrapESIndicesExistsService(indicesExistsService *elastic.IndicesExistsService) IndicesExistsServiceWrapper
WrapESIndicesExistsService creates an ESIndicesExistsService out of *elastic.IndicesExistsService.
type MultiSearchServiceWrapper ¶
type MultiSearchServiceWrapper struct {
// contains filtered or unexported fields
}
MultiSearchServiceWrapper is a wrapper around elastic.ESMultiSearchService
func WrapESMultiSearchService ¶
func WrapESMultiSearchService(multiSearchService *elastic.MultiSearchService) MultiSearchServiceWrapper
WrapESMultiSearchService creates an ESSearchService out of *elastic.ESSearchService.
func (MultiSearchServiceWrapper) Add ¶
func (s MultiSearchServiceWrapper) Add(requests ...*elastic.SearchRequest) es.MultiSearchService
Add calls this function to internal service.
func (MultiSearchServiceWrapper) Do ¶
func (s MultiSearchServiceWrapper) Do(ctx context.Context) (*elastic.MultiSearchResult, error)
Do calls this function to internal service.
func (MultiSearchServiceWrapper) Index ¶
func (s MultiSearchServiceWrapper) Index(indices ...string) es.MultiSearchService
Index calls this function to internal service.
type SearchServiceWrapper ¶
type SearchServiceWrapper struct {
// contains filtered or unexported fields
}
SearchServiceWrapper is a wrapper around elastic.ESSearchService
func WrapESSearchService ¶
func WrapESSearchService(searchService *elastic.SearchService) SearchServiceWrapper
WrapESSearchService creates an ESSearchService out of *elastic.ESSearchService.
func (SearchServiceWrapper) Aggregation ¶
func (s SearchServiceWrapper) Aggregation(name string, aggregation elastic.Aggregation) es.SearchService
Aggregation calls this function to internal service.
func (SearchServiceWrapper) Do ¶
func (s SearchServiceWrapper) Do(ctx context.Context) (*elastic.SearchResult, error)
Do calls this function to internal service.
func (SearchServiceWrapper) IgnoreUnavailable ¶
func (s SearchServiceWrapper) IgnoreUnavailable(ignoreUnavailable bool) es.SearchService
IgnoreUnavailable calls this function to internal service.
func (SearchServiceWrapper) Query ¶
func (s SearchServiceWrapper) Query(query elastic.Query) es.SearchService
Query calls this function to internal service.
func (SearchServiceWrapper) Size ¶
func (s SearchServiceWrapper) Size(size int) es.SearchService
Size calls this function to internal service.
type TemplateCreateServiceWrapper ¶
type TemplateCreateServiceWrapper struct {
// contains filtered or unexported fields
}
TemplateCreateServiceWrapper is a wrapper around elastic.IndicesPutTemplateService.
func WrapESTemplateCreateService ¶
func WrapESTemplateCreateService(mappingCreateService *elastic.IndicesPutTemplateService) TemplateCreateServiceWrapper
WrapESTemplateCreateService creates an TemplateCreateService out of *elastic.IndicesPutTemplateService.
func (TemplateCreateServiceWrapper) Body ¶
func (c TemplateCreateServiceWrapper) Body(mapping string) es.TemplateCreateService
Body calls this function to internal service.
func (TemplateCreateServiceWrapper) Do ¶
func (c TemplateCreateServiceWrapper) Do(ctx context.Context) (*elastic.IndicesPutTemplateResponse, error)
Do calls this function to internal service.
Source Files