eswrapper

Documentation

Index

• type ClientWrapper
  • func WrapESClient(client *elastic.Client, s *elastic.BulkProcessor, esVersion uint) ClientWrapper
  • func (c ClientWrapper) Close() error
  • func (c ClientWrapper) CreateIndex(index string) es.IndicesCreateService
  • func (c ClientWrapper) CreateTemplate(ttype string) es.TemplateCreateService
  • func (c ClientWrapper) GetVersion() uint
  • func (c ClientWrapper) Index() es.IndexService
  • func (c ClientWrapper) IndexExists(index string) es.IndicesExistsService
  • func (c ClientWrapper) MultiSearch() es.MultiSearchService
  • func (c ClientWrapper) Search(indices ...string) es.SearchService
• type IndexServiceWrapper
  • func WrapESIndexService(indexService *elastic.BulkIndexRequest, bulkService *elastic.BulkProcessor, ...) IndexServiceWrapper
  • func (i IndexServiceWrapper) Add()
  • func (i IndexServiceWrapper) BodyJson(body interface{}) es.IndexService
  • func (i IndexServiceWrapper) Id(id string) es.IndexService
  • func (i IndexServiceWrapper) Index(index string) es.IndexService
  • func (i IndexServiceWrapper) Type(typ string) es.IndexService
• type IndicesCreateServiceWrapper
  • func WrapESIndicesCreateService(indicesCreateService *elastic.IndicesCreateService) IndicesCreateServiceWrapper
  • func (c IndicesCreateServiceWrapper) Body(mapping string) es.IndicesCreateService
  • func (c IndicesCreateServiceWrapper) Do(ctx context.Context) (*elastic.IndicesCreateResult, error)
• type IndicesExistsServiceWrapper
  • func WrapESIndicesExistsService(indicesExistsService *elastic.IndicesExistsService) IndicesExistsServiceWrapper
  • func (e IndicesExistsServiceWrapper) Do(ctx context.Context) (bool, error)
• type MultiSearchServiceWrapper
  • func WrapESMultiSearchService(multiSearchService *elastic.MultiSearchService) MultiSearchServiceWrapper
  • func (s MultiSearchServiceWrapper) Add(requests ...*elastic.SearchRequest) es.MultiSearchService
  • func (s MultiSearchServiceWrapper) Do(ctx context.Context) (*elastic.MultiSearchResult, error)
  • func (s MultiSearchServiceWrapper) Index(indices ...string) es.MultiSearchService
• type SearchServiceWrapper
  • func WrapESSearchService(searchService *elastic.SearchService) 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
  • func WrapESTemplateCreateService(mappingCreateService *elastic.IndicesPutTemplateService) TemplateCreateServiceWrapper
  • func (c TemplateCreateServiceWrapper) Body(mapping string) es.TemplateCreateService
  • func (c TemplateCreateServiceWrapper) Do(ctx context.Context) (*elastic.IndicesPutTemplateResponse, error)

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) CreateIndex

func (c ClientWrapper) CreateIndex(index string) es.IndicesCreateService

CreateIndex calls this function to internal client.

func (ClientWrapper) CreateTemplate

func (c ClientWrapper) CreateTemplate(ttype string) es.TemplateCreateService

CreateTemplate calls this function to internal client.

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) IndexExists

func (c ClientWrapper) IndexExists(index string) es.IndicesExistsService

IndexExists 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.

func (IndicesExistsServiceWrapper) Do

func (e IndicesExistsServiceWrapper) Do(ctx context.Context) (bool, error)

Do calls this function to internal service.

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.