eswrapper

package
v1.58.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 11, 2024 License: Apache-2.0 Imports: 7 Imported by: 14

Documentation

Index

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, clientV8 *esV8.Client) 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 added in v1.14.0 

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

CreateTemplate calls this function to internal client.

func (ClientWrapper) DeleteIndex added in v1.58.0 

func (c ClientWrapper) DeleteIndex(index string) es.IndicesDeleteService

DeleteIndex calls this function to internal client.

func (ClientWrapper) GetVersion added in v1.14.0 

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 any) 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 IndicesDeleteServiceWrapper added in v1.58.0 

type IndicesDeleteServiceWrapper struct {
	// contains filtered or unexported fields
}

IndicesDeleteServiceWrapper is a wrapper around elastic.IndicesDeleteService

func WrapESIndicesDeleteService added in v1.58.0 

func WrapESIndicesDeleteService(indicesDeleteService *elastic.IndicesDeleteService) IndicesDeleteServiceWrapper

WrapESIndicesDeleteService creates an ESIndicesDeleteService out of *elastic.IndicesDeleteService.

func (IndicesDeleteServiceWrapper) Do added in v1.58.0 

func (e IndicesDeleteServiceWrapper) Do(ctx context.Context) (*elastic.IndicesDeleteResponse, 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 added in v1.14.0 

type TemplateCreateServiceWrapper struct {
	// contains filtered or unexported fields
}

TemplateCreateServiceWrapper is a wrapper around elastic.IndicesPutTemplateService.

func WrapESTemplateCreateService added in v1.14.0 

func WrapESTemplateCreateService(mappingCreateService *elastic.IndicesPutTemplateService) TemplateCreateServiceWrapper

WrapESTemplateCreateService creates an TemplateCreateService out of *elastic.IndicesPutTemplateService.

func (TemplateCreateServiceWrapper) Body added in v1.14.0 

func (c TemplateCreateServiceWrapper) Body(mapping string) es.TemplateCreateService

Body calls this function to internal service.

func (TemplateCreateServiceWrapper) Do added in v1.14.0 

func (c TemplateCreateServiceWrapper) Do(ctx context.Context) (*elastic.IndicesPutTemplateResponse, error)

Do calls this function to internal service.

type TemplateCreatorWrapperV8 added in v1.52.0 

type TemplateCreatorWrapperV8 struct {
	// contains filtered or unexported fields
}

TemplateCreatorWrapperV8 implements es.TemplateCreateService.

func (TemplateCreatorWrapperV8) Body added in v1.52.0 

func (c TemplateCreatorWrapperV8) Body(mapping string) es.TemplateCreateService

Body adds mapping to the future request.

func (TemplateCreatorWrapperV8) Do added in v1.52.0 

func (c TemplateCreatorWrapperV8) Do(context.Context) (*elastic.IndicesPutTemplateResponse, error)

Do executes Put Template command.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.