v7

package
v1.7.0 Latest Latest
Warning

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

Go to latest
Published: Dec 25, 2025 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetDefaultLogger

func GetDefaultLogger() *log.Logger

func NewBoolQuery

func NewBoolQuery() *elastic.BoolQuery

func NewMatchAllQuery

func NewMatchAllQuery() *elastic.MatchAllQuery

func NewQueryStringQuery

func NewQueryStringQuery(query string) *elastic.QueryStringQuery

func NewRangeQuery

func NewRangeQuery(field string) *elastic.RangeQuery

func NewRawStringQuery

func NewRawStringQuery(rawQuery string) elastic.RawStringQuery

func SetBasicAuth

func SetBasicAuth(username, password string) elastic.ClientOptionFunc

func SetErrorLog

func SetErrorLog(logger *log.Logger) elastic.ClientOptionFunc

func SetHealthcheckInterval

func SetHealthcheckInterval(interval time.Duration) elastic.ClientOptionFunc

func SetHttpClient

func SetHttpClient(httpClient *http.Client) elastic.ClientOptionFunc

func SetSniff

func SetSniff(enabled bool) elastic.ClientOptionFunc

func SetTraceLog

func SetTraceLog(logger *log.Logger) elastic.ClientOptionFunc

func SetURL

func SetURL(urls ...string) elastic.ClientOptionFunc

Types

type Client

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

func NewClient

func NewClient(esOpts []elastic.ClientOptionFunc) (*Client, error)

func (*Client) Count

func (c *Client) Count(ctx context.Context, index string, query elastic.Query) (int64, error)

func (*Client) Scroll

func (c *Client) Scroll(index string, size int, query elastic.Query) *ScrollService

func (*Client) Stop

func (c *Client) Stop()

type ScrollService

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

func (*ScrollService) Clear

func (s *ScrollService) Clear(ctx context.Context) error

func (*ScrollService) Do

func (*ScrollService) FetchSourceContext

func (s *ScrollService) FetchSourceContext(includeFields []string) *ScrollService

type SearchHit

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

func (*SearchHit) GetSource

func (h *SearchHit) GetSource() []byte

func (*SearchHit) Unwrap

func (h *SearchHit) Unwrap() *elastic.SearchHit

type SearchResult

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

func (*SearchResult) Hits

func (r *SearchResult) Hits() []*SearchHit

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL